Package arvados :: Module stream :: Class StreamReader
[hide private]
[frames] | no frames]

Class StreamReader

source code

keep.object --+
              |
             StreamReader

Instance Methods [hide private]
 
__init__(self, tokens, keep=None, debug=False, _empty=False, num_retries=0) source code
 
name(self) source code
 
files(self) source code
 
all_files(self) source code
 
size(self) source code
 
locators_and_ranges(self, range_start, range_size) source code
 
_keepget(self, locator, num_retries=None) source code
 
readfrom(self, start, size, num_retries=None)
Read up to 'size' bytes from the stream, starting at 'start'
source code
 
manifest_text(self, strip=False) source code
Method Details [hide private]

_keepget(self, locator, num_retries=None)

source code 
Decorators:
  • @retry_method

readfrom(self, start, size, num_retries=None)

source code 

Read up to 'size' bytes from the stream, starting at 'start'

Decorators:
  • @retry_method