Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

abort() (in arvados.commands.arv_copy)	api_client (in arvados.commands.put)	ArvadosFileWriter (in arvados.arvfile)
acquire() (in NoopLock)	api_for_instance() (in arvados.commands.arv_copy)	arvfile (in arvados)
activate_remote_user() (in arvados.commands.federation_migrate)	api_response() (in Collection)	ArvFile (in arvados.commands.run)
ADD (in arvados.collection)	ApiError	ArvPutArgumentConflict (in arvados.commands.put)
add() (in RichCollectionBase)	append() (in _BufferBlock)	ArvPutLogFormatter (in arvados.commands.put)
add() (in Counter)	append() (in FileUploadList)	ArvPutUploadIsPending (in arvados.commands.put)
add_segment() (in ArvadosFile)	apply() (in RichCollectionBase)	ArvPutUploadJob (in arvados.commands.put)
add_task() (in KeepWriterThreadPool)	arg_parser (in arvados.commands.keepdocker)	ArvPutUploadNotPending (in arvados.commands.put)
add_writer() (in ArvadosFile)	arg_parser (in arvados.commands.put)	as_manifest() (in StreamFileReader)
all_files() (in CollectionReader)	ArgumentError	AssertionError
all_files() (in StreamReader)	arv_copy (in arvados.commands)	attempts() (in RetryLoop)
all_streams() (in CollectionReader)	arvados	attempts_str() (in RetryLoop)
alloc_bufferblock() (in _BlockManager)	ArvadosFile (in arvados.arvfile)	attr_filtered() (in arvados.commands.arv_copy)
api (in arvados)	ArvadosFileReader (in arvados.arvfile)
api_client (in arvados.commands.get)	ArvadosFileReaderBase (in arvados.arvfile)

B

block_prefetch() (in _BlockManager)	build_services_list() (in KeepClient)

C

cache (in arvados)	close() (in EventClient)	COMMITTED (in _BufferBlock)
CACHE_DIR (in ArvPutUploadJob)	close() (in PollClient)	committed() (in ArvadosFile)
CACHE_DIR (in ResumeCache)	close() (in _EventClient)	committed() (in RichCollectionBase)
CacheSlot (in KeepBlockCache)	closed() (in ArvadosFile)	config (in arvados)
cap_cache() (in KeepBlockCache)	closed() (in _EventClient)	connect_clusters() (in arvados.commands.federation_migrate)
CAUGHT_SIGNALS (in arvados.commands._util)	collection (in arvados)	container_uuid_pattern (in arvados.util)
check_cache() (in ResumeCache)	COLLECTION (in arvados.collection)	copy() (in RichCollectionBase)
check_dependencies() (in ResumableCollectionWriter)	Collection (in arvados.collection)	copy_collection() (in arvados.commands.arv_copy)
check_docker() (in arvados.commands.keepdocker)	collection_file_paths() (in ArvPutUploadJob)	copy_collections() (in arvados.commands.arv_copy)
check_git_availability() (in arvados.commands.arv_copy)	collection_name() (in ArvPutUploadJob)	copy_docker_image() (in arvados.commands.arv_copy)
choose_new_user() (in arvados.commands.federation_migrate)	collection_trash_at() (in ArvPutUploadJob)	copy_workflow() (in arvados.commands.arv_copy)
clear() (in _BufferBlock)	collection_uuid_pattern (in arvados.util)	Counter (in arvados.keep)
clone() (in ArvadosFile)	CollectionBase (in arvados.collection)	CR_COMMITTED (in arvados.util)
clone() (in _BufferBlock)	CollectionReader (in arvados.collection)	CR_FINAL (in arvados.util)
clone() (in Collection)	collections_copied (in arvados.commands.arv_copy)	CR_UNCOMMITTED (in arvados.util)
clone() (in RichCollectionBase)	CollectionUpdateError (in arvados.commands.put)	create_collection_from() (in arvados.commands.arv_copy)
clone() (in Subcollection)	CollectionWriter (in arvados.collection)	crunch (in arvados)
close() (in ArvadosFileWriter)	CommandFailedError	current_file_name() (in CollectionWriter)
close() (in WrappableFile)	commands (in arvados)	current_job() (in arvados)
close() (in _FileLikeObjectBase)	commit_all() (in _BlockManager)	current_stream_name() (in CollectionWriter)
close() (in _WriterFile)	commit_bufferblock() (in _BlockManager)	current_task() (in arvados)
close() (in ResumeCache)	COMMIT_HASH_RE (in arvados.commands.arv_copy)	current_timeout() (in KeepClient)

D

data_locators() (in CollectionWriter)	delete() (in SafeHTTPCache)	do_task() (in KeepWriterThread)
data_locators() (in ArvPutUploadJob)	delete_bufferblock() (in _BlockManager)	docker_image_compatible() (in arvados.commands.keepdocker)
decompress() (in ArvadosFileReaderBase)	DELETED (in _BufferBlock)	docker_image_format() (in arvados.commands.keepdocker)
decompressed_name() (in ArvadosFileReaderBase)	deserialize() (in OrderedJsonModel)	docker_images() (in arvados.commands.keepdocker)
default_config_file (in arvados.config)	desired_project_uuid() (in arvados.commands.put)	docker_link_sort_key() (in arvados.commands.keepdocker)
DEFAULT_GET_THREADS (in _BlockManager)	destroy() (in ResumeCache)	DockerError (in arvados.commands.keepdocker)
DEFAULT_PROXY_TIMEOUT (in KeepClient)	destroy_cache() (in ArvPutUploadJob)	DockerImage (in arvados.commands.keepdocker)
DEFAULT_PUT_THREADS (in _BlockManager)	determine_project() (in arvados.commands.run)	done() (in KeepWriterThreadPool)
DEFAULT_TIMEOUT (in KeepClient)	diff() (in RichCollectionBase)	dump_state() (in ResumableCollectionWriter)
DEL (in arvados.collection)	do_queued_work() (in CollectionWriter)	dup_block() (in _BlockManager)

E

F

FeatureNotEnabledError	find() (in RichCollectionBase)	flush() (in ArvadosFile)
federation_migrate (in arvados.commands)	find_image_hashes() (in arvados.commands.keepdocker)	flush() (in ArvadosFileReader)
fetch_users() (in arvados.commands.federation_migrate)	find_one_image_hash() (in arvados.commands.keepdocker)	flush() (in ArvadosFileWriter)
FILE (in arvados.collection)	find_or_create() (in Collection)	flush() (in WrappableFile)
FileInfo (in arvados.commands.ls)	find_or_create() (in RichCollectionBase)	flush() (in RichCollectionBase)
files() (in StreamReader)	finish() (in CollectionWriter)	flush() (in _WriterFile)
files_in_collection() (in arvados.commands.get)	finish() (in ProgressWriter)	flush_data() (in CollectionWriter)
files_in_collection() (in arvados.commands.ls)	finish_current_file() (in CollectionWriter)	format() (in ArvPutLogFormatter)
FileUploadList (in arvados.commands.put)	finish_current_stream() (in CollectionWriter)	from_state() (in ResumableCollectionWriter)
filter_iter() (in arvados.commands.arv_copy)	finished() (in KeepService)
find() (in Collection)	first_block() (in arvados._ranges)

G

get (in arvados.commands)	get_block_contents() (in _BlockManager)	get_task_param_mount() (in arvados)
get() (in SafeHTTPCache)	get_bufferblock() (in _BlockManager)	get_trash_at() (in Collection)
get() (in Counter)	get_cache_dir() (in arvados.commands.keepdocker)	getjobparam() (in arvados)
get() (in Keep)	get_from_cache() (in KeepClient)	git_rev_parse() (in arvados.commands.arv_copy)
get() (in CacheSlot)	get_job_param_mount() (in arvados)	global_client_object (in arvados.keep)
get() (in KeepBlockCache)	get_next_task() (in KeepWriterQueue)	global_client_object() (in Keep)
get() (in KeepService)	get_padding_block() (in _BlockManager)	group (in arvados.commands.get)
get() (in KeepClient)	get_properties() (in Collection)	group_uuid_pattern (in arvados.util)

H

has_remote_blocks() (in ArvadosFile)	HINT_RE (in KeepLocator)	human_progress() (in arvados.commands.arv_copy)
has_remote_blocks() (in RichCollectionBase)	HOMECLUSTER (in arvados.commands.federation_migrate)	human_progress() (in arvados.commands.put)
head() (in KeepClient)	HTTP_ERRORS (in KeepService)
HEX_RE (in arvados.util)	HttpError

I

install_signal_handlers() (in arvados.commands._util)	is_cached() (in KeepClient)	items() (in RichCollectionBase)
is_bufferblock() (in _BlockManager)	is_in_collection() (in arvados.commands.run)	items_owned_by() (in arvados.commands.keepdocker)

J

job_setup (in arvados)	JobTask (in arvados)
job_uuid_pattern (in arvados.util)	join() (in KeepWriterThreadPool)

K

keep (in arvados)	keepdocker (in arvados.commands)	KeepWriteError
Keep (in arvados.keep)	keepdocker_parser (in arvados.commands.keepdocker)	KeepWriterQueue (in KeepClient)
KEEP_BLOCK_SIZE (in arvados.config)	KeepLocator (in arvados.keep)	KeepWriterThread (in KeepClient)
keep_locator_pattern (in arvados.util)	KeepReadError	KeepWriterThreadPool (in KeepClient)
KeepBlockCache (in arvados.keep)	KeepRequestError	keys() (in RichCollectionBase)
KeepClient (in arvados.keep)	KeepService (in KeepClient)	known_past_version() (in Collection)

L

last_result() (in KeepService)	local_store_put() (in KeepClient)	log_handler (in arvados)
last_result() (in RetryLoop)	localapi() (in ThreadSafeApiCache)	logger (in arvados.commands.arv_copy)
link_uuid_pattern (in arvados.util)	locator() (in _BufferBlock)	logger (in arvados.commands.get)
list_images_in_arv() (in arvados.commands.keepdocker)	LocatorAndRange (in arvados._ranges)	logger (in arvados.commands.keepdocker)
load() (in ResumeCache)	locators_and_ranges() (in arvados._ranges)	logger (in arvados.commands.migrate19)
local_repo_dir (in arvados.commands.arv_copy)	locators_and_ranges() (in StreamReader)	logger (in arvados.commands.run)
local_store_get() (in KeepClient)	log_date_format (in arvados)	logger (in arvados)
local_store_head() (in KeepClient)	log_format (in arvados)	ls (in arvados.commands)

M

machine_progress() (in arvados.commands.arv_copy)	make_link() (in arvados.commands.keepdocker)	MAX_IDLE_CONNECTION_DURATION (in arvados.api)
machine_progress() (in arvados.commands.put)	make_path() (in ResumeCache)	md5sum (in KeepLocator)
main() (in arvados.commands.arv_copy)	manifest_locator() (in Collection)	migrate19 (in arvados.commands)
main() (in arvados.commands.federation_migrate)	manifest_locator() (in ArvPutUploadJob)	migrate_repository_filter() (in arvados.commands.arv_copy)
main() (in arvados.commands.get)	manifest_pattern (in arvados.util)	migrate_script_version_filter() (in arvados.commands.arv_copy)
main() (in arvados.commands.keepdocker)	manifest_text() (in ArvadosFile)	migrate_user() (in arvados.commands.federation_migrate)
main() (in arvados.commands.ls)	manifest_text() (in CollectionWriter)	MigrationFailed (in arvados.commands.migrate19)
main() (in arvados.commands.migrate19)	manifest_text() (in RichCollectionBase)	mkdirs() (in RichCollectionBase)
main() (in arvados.commands.put)	manifest_text() (in ArvPutUploadJob)	MOD (in arvados.arvfile)
main() (in arvados.commands.run)	manifest_text() (in TaskOutputDir)	MOD (in arvados.collection)
main() (in arvados.commands.ws)	manifest_text() (in StreamReader)	modified() (in RichCollectionBase)
make_home_conf_dir() (in arvados.commands._util)	map_new_services() (in KeepClient)	must_be_writable() (in arvados.arvfile)

N

name() (in StreamReader)	normalize() (in CollectionReader)	notify() (in RichCollectionBase)
name_formatter() (in arvados.commands.ls)	normalize_stream() (in arvados._normalize_stream)	NotImplementedError
NoKeepServersError	NotFoundError
NoopLock (in arvados.arvfile)	notify() (in Collection)

O

on_closed() (in EventClient)	one_task_per_input_stream() (in job_setup)	opened() (in _EventClient)
on_event() (in EventClient)	open() (in CollectionWriter)	OrderedJsonModel
one_task_per_input_file() (in job_setup)	open() (in RichCollectionBase)	outfile (in ProgressWriter)

P

parse_args() (in arvados.commands.ls)	perm_sig (in KeepLocator)	portable_manifest_text() (in RichCollectionBase)
parse_arguments() (in arvados.commands.get)	permission_expired() (in ArvadosFile)	prep_image_file() (in arvados.commands.keepdocker)
parse_arguments() (in arvados.commands.put)	permission_expired() (in KeepLocator)	progress_writer() (in arvados.commands.put)
parse_permission_hint() (in KeepLocator)	permission_hint() (in KeepLocator)	ProgressWriter (in arvados.commands.arv_copy)
parser (in arvados.commands.get)	PollClient (in arvados.events)	pull_image() (in arvados.commands.keepdocker)
PathDoesNotExistError (in arvados.commands.put)	popen_docker() (in arvados.commands.keepdocker)	put (in arvados.commands)
pathname_match() (in arvados.commands.put)	portable_data_hash() (in CollectionWriter)	put() (in Keep)
PENDING (in _BufferBlock)	portable_data_hash() (in RichCollectionBase)	put() (in KeepService)
pending_copies() (in KeepWriterQueue)	portable_data_hash() (in ArvPutUploadJob)	put() (in KeepClient)
perm_expiry() (in KeepLocator)	portable_data_hash_pattern (in arvados.util)

R

Range (in arvados._ranges)	received_message() (in _EventClient)	ResumeCache (in arvados.commands.put)
RANGES_SPAM (in arvados._ranges)	refresh_signature() (in KeepClient)	ResumeCacheConflict (in arvados.commands.put)
read() (in ArvadosFileReader)	release() (in NoopLock)	ResumeCacheInvalidError (in arvados.commands.put)
read() (in ArvadosFileReaderBase)	remove() (in Collection)	retry (in arvados)
read() (in StreamFileReader)	remove() (in RichCollectionBase)	RETRY_COUNT (in arvados.api)
read() (in WrappableFile)	remove_writer() (in ArvadosFile)	RETRY_DELAY_BACKOFF (in arvados.api)
read_migrations() (in arvados.commands.federation_migrate)	rename() (in RichCollectionBase)	RETRY_DELAY_INITIAL (in arvados.api)
readable() (in ArvadosFileReaderBase)	repack_small_blocks() (in _BlockManager)	retry_opt (in arvados.commands._util)
readable() (in WrappableFile)	repack_writes() (in _BufferBlock)	RetryLoop
readall() (in ArvadosFileReaderBase)	replace_contents() (in ArvadosFile)	RichCollectionBase (in arvados.collection)
readall_decompressed() (in ArvadosFileReaderBase)	replace_range() (in arvados._ranges)	root_collection() (in Collection)
readfrom() (in ArvadosFile)	report() (in ProgressWriter)	root_collection() (in RichCollectionBase)
readfrom() (in ArvadosFileReader)	report_progress() (in ArvPutUploadJob)	root_collection() (in Subcollection)
readfrom() (in ArvadosFileReaderBase)	request_errors() (in KeepRequestError)	run (in arvados.commands)
readfrom() (in StreamFileReader)	request_id_informed (in ArvPutLogFormatter)	run() (in PollClient)
readfrom() (in StreamReader)	reserve_cache() (in KeepBlockCache)	run() (in KeepWriterThread)
readinto() (in ArvadosFileReader)	response() (in KeepWriterThreadPool)	run_forever() (in EventClient)
readinto() (in WrappableFile)	restart() (in ResumeCache)	run_forever() (in PollClient)
readline() (in ArvadosFileReaderBase)	restore_signal_handlers() (in arvados.commands._util)	run_opts (in arvados.commands.put)
readlines() (in ArvadosFileReaderBase)	ResumableCollectionWriter (in arvados.collection)	running() (in RetryLoop)

S

safeapi (in arvados)	set_src_owner_uuid() (in arvados.commands.arv_copy)	StateChangeError (in arvados.arvfile)
SafeHTTPCache (in arvados.cache)	set_state() (in _BufferBlock)	statfile() (in arvados.commands.run)
save() (in Collection)	signed_locator_pattern (in arvados.util)	std_fmtr (in ArvPutLogFormatter)
save() (in ResumeCache)	size() (in ArvadosFile)	stop_threads() (in _BlockManager)
save_collection() (in ArvPutUploadJob)	size() (in ArvadosFileReader)	stop_threads() (in Collection)
save_image() (in arvados.commands.keepdocker)	size() (in ArvadosFileReaderBase)	stream (in arvados)
save_new() (in Collection)	size() (in StreamFileReader)	stream_name() (in ArvadosFileReader)
save_new() (in CollectionWriter)	size() (in _BufferBlock)	stream_name() (in StreamFileReader)
save_result() (in RetryLoop)	size() (in CacheSlot)	stream_name() (in Collection)
scripts_copied (in arvados.commands.arv_copy)	size() (in StreamReader)	stream_name() (in RichCollectionBase)
seek() (in ArvadosFileReaderBase)	size_formatter() (in arvados.commands.ls)	stream_name() (in Subcollection)
seek() (in WrappableFile)	split() (in arvados.arvfile)	StreamFileReader (in arvados.arvfile)
seekable() (in ArvadosFileReaderBase)	src_owner_uuid (in arvados.commands.arv_copy)	StreamReader (in arvados.stream)
seekable() (in WrappableFile)	StaleWriterStateError	stripped() (in KeepLocator)
segments() (in ArvadosFile)	start() (in ArvPutUploadJob)	stripped_manifest() (in CollectionBase)
select_git_url() (in arvados.commands.arv_copy)	start_get_threads() (in _BlockManager)	Subcollection (in arvados.collection)
set() (in SafeHTTPCache)	start_new_file() (in CollectionWriter)	subscribe() (in RichCollectionBase)
set() (in CacheSlot)	start_new_stream() (in CollectionWriter)	subscribe() (in EventClient)
set_committed() (in ArvadosFile)	start_put_threads() (in _BlockManager)	subscribe() (in PollClient)
set_committed() (in RichCollectionBase)	STAT_CACHE_ERRORS (in arvados.commands.keepdocker)	subscribe() (in _EventClient)
set_current_file_name() (in CollectionWriter)	stat_cache_name() (in arvados.commands.keepdocker)	subscribe() (in arvados.events)
set_current_stream_name() (in CollectionWriter)	state() (in _BufferBlock)	success() (in RetryLoop)
set_has_remote_blocks() (in RichCollectionBase)	STATE_PROPS (in ResumableCollectionWriter)	synchronized() (in arvados.arvfile)
set_segments() (in ArvadosFile)	STATE_TRANSITIONS (in _BufferBlock)	SyntaxError

T

task_set_output() (in arvados)	TextIOWrapper (in arvados.collection)	total_collection_size() (in arvados.commands.arv_copy)
TaskFailed (in KeepWriterThread)	ThreadSafeApiCache (in arvados.safeapi)	truncate() (in ArvadosFile)
TaskOutputDir (in arvados.crunch)	timer (in arvados)	truncate() (in ArvadosFileWriter)
tell() (in ArvadosFileReaderBase)	Timer
tell() (in WrappableFile)	TOK (in arvados.collection)

U

V

values() (in RichCollectionBase)

W

weighted_service_roots() (in KeepClient)	writable() (in RichCollectionBase)	write_directory_tree() (in CollectionWriter)
workflow_collections() (in arvados.commands.arv_copy)	writable() (in Subcollection)	write_fail() (in KeepWriterQueue)
WrappableFile (in arvados.arvfile)	WRITE (in arvados.arvfile)	write_file() (in CollectionWriter)
WRITABLE (in _BufferBlock)	write() (in ArvadosFileWriter)	write_file() (in arvados.commands.run)
writable() (in ArvadosFile)	write() (in WrappableFile)	write_success() (in KeepWriterQueue)
writable() (in ArvadosFileReaderBase)	write() (in CollectionWriter)	writelines() (in ArvadosFileWriter)
writable() (in ArvadosFileWriter)	write() (in ResumableCollectionWriter)	writelines() (in _WriterFile)
writable() (in WrappableFile)	write() (in TextIOWrapper)	writeto() (in ArvadosFile)
writable() (in Collection)	write() (in _WriterFile)	ws (in arvados.commands)
writable() (in CollectionReader)	write_block_or_manifest() (in arvados.commands.get)

_

__call__() (in _NameAttribute)	__init__() (in KeepLocator)	_lock_file() (in ArvPutUploadJob)
__contains__() (in RichCollectionBase)	__init__() (in RetryLoop)	_lock_file() (in ResumeCache)
__delitem__() (in RichCollectionBase)	__init__() (in ThreadSafeApiCache)	_logger (in arvados._ranges)
__enter__() (in NoopLock)	__init__() (in StreamReader)	_logger (in arvados.api)
__enter__() (in _BlockManager)	__init__() (in Timer)	_logger (in arvados.arvfile)
__enter__() (in _FileLikeObjectBase)	__iter__() (in ArvadosFileReaderBase)	_logger (in arvados.collection)
__enter__() (in _FileLikeObjectBase)	__iter__() (in RichCollectionBase)	_logger (in arvados.events)
__enter__() (in Collection)	__iter__() (in RetryLoop)	_logger (in arvados.keep)
__enter__() (in CollectionBase)	__len__() (in RichCollectionBase)	_machine_format (in arvados.commands.put)
__enter__() (in Timer)	__ne__() (in ArvadosFile)	_make_hex_prop() (in KeepLocator)
__eq__() (in LocatorAndRange)	__ne__() (in RichCollectionBase)	_migration_link_class (in arvados.commands.migrate19)
__eq__() (in Range)	__next__() (in RetryLoop)	_migration_link_name (in arvados.commands.migrate19)
__eq__() (in ArvadosFile)	__repr__() (in LocatorAndRange)	_my_api() (in Collection)
__eq__() (in RichCollectionBase)	__repr__() (in Range)	_my_api() (in RichCollectionBase)
__eq__() (in ArvFile)	__repr__() (in _BufferBlock)	_my_api() (in Subcollection)
__exit__() (in NoopLock)	__str__() (in SafeHTTPCache)	_my_block_manager() (in Collection)
__exit__() (in _BlockManager)	__str__() (in TaskOutputDir)	_my_block_manager() (in RichCollectionBase)
__exit__() (in _FileLikeObjectBase)	__str__() (in KeepLocator)	_my_block_manager() (in Subcollection)
__exit__() (in _FileLikeObjectBase)	_add_segment() (in ArvadosFile)	_my_collection() (in ArvPutUploadJob)
__exit__() (in Collection)	_alloc_bufferblock() (in _BlockManager)	_my_keep() (in Collection)
__exit__() (in CollectionBase)	_any_nondisk_services() (in KeepClient)	_my_keep() (in CollectionBase)
__exit__() (in CollectionWriter)	_before_close() (in _FileLikeObjectBase)	_my_keep() (in RichCollectionBase)
__exit__() (in Timer)	_before_close() (in _FileLikeObjectBase)	_my_keep() (in Subcollection)
__getattr__() (in ThreadSafeApiCache)	_block_prefetch_worker() (in _BlockManager)	_NameAttribute (in StreamFileReader)
__getitem__() (in RichCollectionBase)	_block_re (in Collection)	_new_image_listing() (in arvados.commands.keepdocker)
__hash__() (in ArvFile)	_BlockManager (in arvados.arvfile)	_normalize_stream (in arvados)
__init__() (in JobTask)	_BufferBlock (in arvados.arvfile)	_populate() (in Collection)
__init__() (in LocatorAndRange)	_build_upload_list() (in ArvPutUploadJob)	_populate_from_api_server() (in Collection)
__init__() (in Range)	_cached_manifest_valid() (in ArvPutUploadJob)	_populate_streams() (in CollectionReader)
__init__() (in ArvadosFile)	_cast_orig (in arvados.api)	_pos_int() (in arvados.commands._util)
__init__() (in ArvadosFileReader)	_check_file() (in ArvPutUploadJob)	_progress_func (in ProgressWriter)
__init__() (in ArvadosFileReaderBase)	_check_loop_result() (in KeepClient)	_put_user_agent() (in KeepService)
__init__() (in ArvadosFileWriter)	_clean() (in SafeHTTPCache)	_queue_dirents() (in CollectionWriter)
__init__() (in StateChangeError)	_clonefrom() (in RichCollectionBase)	_queue_file() (in CollectionWriter)
__init__() (in StreamFileReader)	_collection_size() (in ArvPutUploadJob)	_queue_file() (in ResumableCollectionWriter)
__init__() (in WrappableFile)	_collection_trash_at() (in ArvPutUploadJob)	_queue_tree() (in CollectionWriter)
__init__() (in _BlockManager)	_commit_bufferblock_worker() (in _BlockManager)	_raise_error() (in arvados.commands._util)
__init__() (in _BufferBlock)	_copy_remote_blocks() (in ArvadosFile)	_ranges (in arvados)
__init__() (in _FileLikeObjectBase)	_copy_remote_blocks() (in RichCollectionBase)	_remember_api_response() (in Collection)
__init__() (in SafeHTTPCache)	_current_job (in arvados)	_reparent() (in ArvadosFile)
__init__() (in Collection)	_current_task (in arvados)	_reparent() (in Subcollection)
__init__() (in CollectionReader)	_datablocks_on_item() (in ArvPutUploadJob)	_save_state() (in ArvPutUploadJob)
__init__() (in CollectionWriter)	_delete_bufferblock() (in _BlockManager)	_segment_re (in Collection)
__init__() (in ResumableCollectionWriter)	_EventClient (in arvados.events)	_service_weight() (in KeepClient)
__init__() (in RichCollectionBase)	_FileLikeObjectBase (in arvados.arvfile)	_setcurltimeouts() (in KeepService)
__init__() (in Subcollection)	_filename() (in SafeHTTPCache)	_settings (in arvados.config)
__init__() (in _WriterFile)	_format_error() (in KeepRequestError)	_setup_event_client() (in EventClient)
__init__() (in ProgressWriter)	_get() (in KeepBlockCache)	_setup_state() (in ArvPutUploadJob)
__init__() (in ArvPutLogFormatter)	_get_cache_filepath() (in ArvPutUploadJob)	_socket_open() (in KeepService)
__init__() (in ArvPutUploadJob)	_get_docker_links() (in arvados.commands.keepdocker)	_socket_open_pycurl_7_19_3() (in KeepService)
__init__() (in FileUploadList)	_get_manifest_text() (in RichCollectionBase)	_socket_open_pycurl_7_21_5() (in KeepService)
__init__() (in ResumeCache)	_get_manifest_text() (in Subcollection)	_subscribe_websocket() (in arvados.events)
__init__() (in ArvFile)	_get_or_head() (in KeepClient)	_token_re (in Collection)
__init__() (in TaskOutputDir)	_get_reason() (in ApiError)	_unescape_manifest_path() (in Collection)
__init__() (in HttpError)	_get_src_target() (in RichCollectionBase)	_update() (in ArvPutUploadJob)
__init__() (in KeepRequestError)	_get_user_agent() (in KeepService)	_update_task() (in ArvPutUploadJob)
__init__() (in EventClient)	_group (in arvados.commands.keepdocker)	_upload_files() (in ArvPutUploadJob)
__init__() (in PollClient)	_group (in arvados.commands.put)	_util (in arvados.commands)
__init__() (in _EventClient)	_has_collection_uuid() (in Collection)	_uuid2pdh() (in arvados.commands.keepdocker)
__init__() (in Counter)	_has_local_collection_uuid() (in Collection)	_version (in arvados)
__init__() (in CacheSlot)	_headerfunction() (in KeepService)	_work_dirents() (in CollectionWriter)
__init__() (in KeepBlockCache)	_HTTP_CAN_RETRY (in arvados.retry)	_work_file() (in CollectionWriter)
__init__() (in KeepService)	_HTTP_SUCCESSES (in arvados.retry)	_work_trees() (in CollectionWriter)
__init__() (in KeepWriterQueue)	_ignore_error() (in arvados.commands._util)	_write() (in ArvPutUploadJob)
__init__() (in KeepWriterThread)	_import_manifest() (in Collection)	_write_stdin() (in ArvPutUploadJob)
__init__() (in KeepWriterThreadPool)	_keepget() (in StreamReader)	_WriterFile (in arvados.collection)
__init__() (in KeepClient)	_last_key (in Keep)