Index A | B | C | D | E | F | G | H | I | J | L | M | N | P | R | S | T | U | V | W A API_KEY_CHARSET (in module momotor.rpc.auth.utils) API_KEY_LENGTH (in module momotor.rpc.auth.utils) API_SECRET_CHARSET (in module momotor.rpc.auth.utils) API_SECRET_LENGTH (in module momotor.rpc.auth.utils) AssetData (class in momotor.rpc.proto.asset_pb2) AssetException AssetHashMismatchError AssetNotFoundException AssetQuery (class in momotor.rpc.proto.asset_pb2) AssetSizeMismatchError AuthBase (class in momotor.rpc.proto.auth_grpc) authenticate() (in module momotor.rpc.auth.client) (momotor.rpc.proto.auth_grpc.AuthBase method) AuthenticateRequest (class in momotor.rpc.proto.auth_pb2) AuthenticateResponse (class in momotor.rpc.proto.auth_pb2) AuthenticatingChannel (class in momotor.rpc.auth.client) AuthException AuthStub (class in momotor.rpc.proto.auth_grpc) B block_size (momotor.rpc.hash.identity.IdentityHash property) ByteSize() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) C calculate_challenge_response() (in module momotor.rpc.auth.utils) Challenge (class in momotor.rpc.proto.auth_pb2) CHALLENGE_LENGTH (in module momotor.rpc.auth.utils) CHUNK_SIZE (in module momotor.rpc.const) Clear() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) ClearExtension() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) ClearField() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) ClientBase (class in momotor.rpc.proto.client_grpc) ClientStub (class in momotor.rpc.proto.client_grpc) constant_time_compare() (in module momotor.rpc.auth.utils) copy() (momotor.rpc.hash.identity.IdentityHash method) CopyFrom() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) createJob() (momotor.rpc.proto.client_grpc.ClientBase method) CreateJobRequest (class in momotor.rpc.proto.job_pb2) CreateJobResponse (class in momotor.rpc.proto.job_pb2) D DEFAULT_PORT (in module momotor.rpc.const) DEFAULT_SSL_PORT (in module momotor.rpc.const) DESCRIPTOR (momotor.rpc.proto.asset_pb2.AssetData attribute) (momotor.rpc.proto.asset_pb2.AssetQuery attribute) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest attribute) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse attribute) (momotor.rpc.proto.asset_pb2.UploadAssetRequest attribute) (momotor.rpc.proto.asset_pb2.UploadAssetResponse attribute) (momotor.rpc.proto.auth_pb2.AuthenticateRequest attribute) (momotor.rpc.proto.auth_pb2.AuthenticateResponse attribute) (momotor.rpc.proto.auth_pb2.Challenge attribute) (momotor.rpc.proto.auth_pb2.ServerInfoResponse attribute) (momotor.rpc.proto.exception_pb2.Exception attribute) (momotor.rpc.proto.job_pb2.CreateJobRequest attribute) (momotor.rpc.proto.job_pb2.CreateJobResponse attribute) (momotor.rpc.proto.job_pb2.EndJobRequest attribute) (momotor.rpc.proto.job_pb2.EndJobResponse attribute) (momotor.rpc.proto.job_pb2.JobStatus attribute) (momotor.rpc.proto.job_pb2.JobStatusRequest attribute) (momotor.rpc.proto.job_pb2.JobStatusResponse attribute) (momotor.rpc.proto.job_pb2.JobStatusStream attribute) (momotor.rpc.proto.job_pb2.StartJobRequest attribute) (momotor.rpc.proto.job_pb2.StartJobResponse attribute) (momotor.rpc.proto.resource_pb2.Resource attribute) (momotor.rpc.proto.shared_pb2.SharedLockRequest attribute) (momotor.rpc.proto.shared_pb2.SharedLockResponse attribute) (momotor.rpc.proto.task_pb2.GetTaskRequest attribute) (momotor.rpc.proto.task_pb2.GetTaskResponse attribute) (momotor.rpc.proto.task_pb2.TaskId attribute) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest attribute) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse attribute) digest() (momotor.rpc.hash.identity.IdentityHash method) digest_size (in module momotor.rpc.hash.identity) (momotor.rpc.hash.identity.IdentityHash property) DiscardUnknownFields() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) download_asset_stream() (in module momotor.rpc.asset.server) downloadAsset() (momotor.rpc.proto.client_grpc.ClientBase method) (momotor.rpc.proto.worker_grpc.WorkerBase method) DownloadAssetRequest (class in momotor.rpc.proto.asset_pb2) DownloadAssetResponse (class in momotor.rpc.proto.asset_pb2) E endJob() (momotor.rpc.proto.client_grpc.ClientBase method) EndJobRequest (class in momotor.rpc.proto.job_pb2) EndJobResponse (class in momotor.rpc.proto.job_pb2) Exception (class in momotor.rpc.proto.exception_pb2) Extensions (momotor.rpc.proto.asset_pb2.AssetData attribute) (momotor.rpc.proto.asset_pb2.AssetQuery attribute) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest attribute) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse attribute) (momotor.rpc.proto.asset_pb2.UploadAssetRequest attribute) (momotor.rpc.proto.asset_pb2.UploadAssetResponse attribute) (momotor.rpc.proto.auth_pb2.AuthenticateRequest attribute) (momotor.rpc.proto.auth_pb2.AuthenticateResponse attribute) (momotor.rpc.proto.auth_pb2.Challenge attribute) (momotor.rpc.proto.auth_pb2.ServerInfoResponse attribute) (momotor.rpc.proto.job_pb2.CreateJobRequest attribute) (momotor.rpc.proto.job_pb2.CreateJobResponse attribute) (momotor.rpc.proto.job_pb2.EndJobRequest attribute) (momotor.rpc.proto.job_pb2.EndJobResponse attribute) (momotor.rpc.proto.job_pb2.JobStatus attribute) (momotor.rpc.proto.job_pb2.JobStatusRequest attribute) (momotor.rpc.proto.job_pb2.JobStatusResponse attribute) (momotor.rpc.proto.job_pb2.JobStatusStream attribute) (momotor.rpc.proto.job_pb2.StartJobRequest attribute) (momotor.rpc.proto.job_pb2.StartJobResponse attribute) (momotor.rpc.proto.resource_pb2.Resource attribute) (momotor.rpc.proto.shared_pb2.SharedLockRequest attribute) (momotor.rpc.proto.shared_pb2.SharedLockResponse attribute) (momotor.rpc.proto.task_pb2.GetTaskRequest attribute) (momotor.rpc.proto.task_pb2.GetTaskResponse attribute) (momotor.rpc.proto.task_pb2.TaskId attribute) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest attribute) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse attribute) F file_reader() (in module momotor.rpc.asset.utils) file_writer() (in module momotor.rpc.asset.utils) FindInitializationErrors() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) FormatException FromString() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) G gen_api_key() (in module momotor.rpc.auth.utils) gen_api_secret() (in module momotor.rpc.auth.utils) gen_challenge() (in module momotor.rpc.auth.utils) gen_key() (in module momotor.rpc.auth.utils) gen_salt() (in module momotor.rpc.auth.utils) get_algorithm_by_code() (in module momotor.rpc.hash.funcs) get_authenticated_channel() (in module momotor.rpc.auth.client) get_code_by_hash_obj() (in module momotor.rpc.hash.funcs) get_dotted_task_number() (in module momotor.rpc.task) get_file_hash() (in module momotor.rpc.asset.utils) get_file_multihash() (in module momotor.rpc.asset.utils) get_lock() (momotor.rpc.shared.SharedState method) get_step_task_id() (in module momotor.rpc.task) getTask() (momotor.rpc.proto.worker_grpc.WorkerBase method) GetTaskRequest (class in momotor.rpc.proto.task_pb2) GetTaskResponse (class in momotor.rpc.proto.task_pb2) H HasExtension() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) HasField() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) hexdigest() (momotor.rpc.hash.identity.IdentityHash method) I IdentityHash (class in momotor.rpc.hash.identity) is_authenticated() (momotor.rpc.auth.client.AuthenticatingChannel method) IsInitialized() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) J JobException JobStatus (class in momotor.rpc.proto.job_pb2) jobStatus() (momotor.rpc.proto.client_grpc.ClientBase method) JobStatusRequest (class in momotor.rpc.proto.job_pb2) JobStatusResponse (class in momotor.rpc.proto.job_pb2) JobStatusStream (class in momotor.rpc.proto.job_pb2) L ListFields() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) M MAX_HASH_LEN (in module momotor.rpc.const) MAX_IDENTITY_LENGTH (in module momotor.rpc.const) MergeFrom() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) MergeFromString() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) message_to_resources() (in module momotor.rpc.resources) module momotor.rpc.asset momotor.rpc.asset.exceptions momotor.rpc.asset.remote momotor.rpc.asset.server momotor.rpc.asset.utils momotor.rpc.auth momotor.rpc.auth.client momotor.rpc.auth.utils momotor.rpc.const momotor.rpc.exception momotor.rpc.hash.funcs momotor.rpc.hash.identity momotor.rpc.proto momotor.rpc.proto.asset_grpc momotor.rpc.proto.asset_pb2 momotor.rpc.proto.auth_grpc momotor.rpc.proto.auth_pb2 momotor.rpc.proto.client_grpc momotor.rpc.proto.client_pb2 momotor.rpc.proto.exception_grpc momotor.rpc.proto.exception_pb2 momotor.rpc.proto.job_grpc momotor.rpc.proto.job_pb2 momotor.rpc.proto.priority_grpc momotor.rpc.proto.priority_pb2 momotor.rpc.proto.resource_grpc momotor.rpc.proto.resource_pb2 momotor.rpc.proto.shared_grpc momotor.rpc.proto.shared_pb2 momotor.rpc.proto.task_grpc momotor.rpc.proto.task_pb2 momotor.rpc.proto.worker_grpc momotor.rpc.proto.worker_pb2 momotor.rpc.resources momotor.rpc.shared momotor.rpc.status.client momotor.rpc.task momotor.rpc.validate.base momotor.rpc.validate.query momotor.rpc.validate.request momotor.rpc.validate.response momotor.rpc.asset module momotor.rpc.asset.exceptions module momotor.rpc.asset.remote module momotor.rpc.asset.server module momotor.rpc.asset.utils module momotor.rpc.auth module momotor.rpc.auth.client module momotor.rpc.auth.utils module momotor.rpc.const module momotor.rpc.exception module momotor.rpc.hash.funcs module momotor.rpc.hash.identity module momotor.rpc.proto module momotor.rpc.proto.asset_grpc module momotor.rpc.proto.asset_pb2 module momotor.rpc.proto.auth_grpc module momotor.rpc.proto.auth_pb2 module momotor.rpc.proto.client_grpc module momotor.rpc.proto.client_pb2 module momotor.rpc.proto.exception_grpc module momotor.rpc.proto.exception_pb2 module momotor.rpc.proto.job_grpc module momotor.rpc.proto.job_pb2 module momotor.rpc.proto.priority_grpc module momotor.rpc.proto.priority_pb2 module momotor.rpc.proto.resource_grpc module momotor.rpc.proto.resource_pb2 module momotor.rpc.proto.shared_grpc module momotor.rpc.proto.shared_pb2 module momotor.rpc.proto.task_grpc module momotor.rpc.proto.task_pb2 module momotor.rpc.proto.worker_grpc module momotor.rpc.proto.worker_pb2 module momotor.rpc.resources module momotor.rpc.shared module momotor.rpc.status.client module momotor.rpc.task module momotor.rpc.validate.base module momotor.rpc.validate.query module momotor.rpc.validate.request module momotor.rpc.validate.response module multi_job_status_stream() (in module momotor.rpc.status.client) multiJobStatusStream() (momotor.rpc.proto.client_grpc.ClientBase method) N name (momotor.rpc.hash.identity.IdentityHash attribute) new() (in module momotor.rpc.hash.identity) P ParseFromString() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) Python Enhancement Proposals PEP 452, [1], [2], [3], [4] R raise_message_exception() (in module momotor.rpc.exception) receive_asset() (in module momotor.rpc.asset.remote) RegisterExtension() (momotor.rpc.proto.asset_pb2.AssetData static method) (momotor.rpc.proto.asset_pb2.AssetQuery static method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest static method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse static method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest static method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse static method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest static method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse static method) (momotor.rpc.proto.auth_pb2.Challenge static method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse static method) (momotor.rpc.proto.job_pb2.CreateJobRequest static method) (momotor.rpc.proto.job_pb2.CreateJobResponse static method) (momotor.rpc.proto.job_pb2.EndJobRequest static method) (momotor.rpc.proto.job_pb2.EndJobResponse static method) (momotor.rpc.proto.job_pb2.JobStatus static method) (momotor.rpc.proto.job_pb2.JobStatusRequest static method) (momotor.rpc.proto.job_pb2.JobStatusResponse static method) (momotor.rpc.proto.job_pb2.JobStatusStream static method) (momotor.rpc.proto.job_pb2.StartJobRequest static method) (momotor.rpc.proto.job_pb2.StartJobResponse static method) (momotor.rpc.proto.resource_pb2.Resource static method) (momotor.rpc.proto.shared_pb2.SharedLockRequest static method) (momotor.rpc.proto.shared_pb2.SharedLockResponse static method) (momotor.rpc.proto.task_pb2.GetTaskRequest static method) (momotor.rpc.proto.task_pb2.GetTaskResponse static method) (momotor.rpc.proto.task_pb2.TaskId static method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest static method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse static method) request() (momotor.rpc.auth.client.AuthenticatingChannel method) Resource (class in momotor.rpc.proto.resource_pb2) resources_to_message() (in module momotor.rpc.resources) RPCException S SALT_CHARSET (in module momotor.rpc.auth.utils) SALT_LENGTH (in module momotor.rpc.auth.utils) send_asset() (in module momotor.rpc.asset.remote) SerializePartialToString() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) SerializeToString() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) serverInfo() (momotor.rpc.proto.auth_grpc.AuthBase method) ServerInfoResponse (class in momotor.rpc.proto.auth_pb2) SetInParent() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) sharedLock() (momotor.rpc.proto.worker_grpc.WorkerBase method) SharedLockRequest (class in momotor.rpc.proto.shared_pb2) SharedLockResponse (class in momotor.rpc.proto.shared_pb2) SharedState (class in momotor.rpc.shared) startJob() (momotor.rpc.proto.client_grpc.ClientBase method) StartJobRequest (class in momotor.rpc.proto.job_pb2) StartJobResponse (class in momotor.rpc.proto.job_pb2) SUPPORTED_HASH_FUNCS (in module momotor.rpc.const) T TaskId (class in momotor.rpc.proto.task_pb2) test_lock() (momotor.rpc.shared.SharedState method) type_code (momotor.rpc.exception.AssetException attribute) (momotor.rpc.exception.AssetNotFoundException attribute) (momotor.rpc.exception.AuthException attribute) (momotor.rpc.exception.FormatException attribute) (momotor.rpc.exception.JobException attribute) (momotor.rpc.exception.RPCException attribute) type_name (momotor.rpc.exception.AssetException attribute) (momotor.rpc.exception.AssetNotFoundException attribute) (momotor.rpc.exception.AuthException attribute) (momotor.rpc.exception.FormatException attribute) (momotor.rpc.exception.JobException attribute) (momotor.rpc.exception.RPCException attribute) U UnexpectedEndOfStream UnknownFields() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) update() (momotor.rpc.hash.identity.IdentityHash method) updateTaskStatus() (momotor.rpc.proto.worker_grpc.WorkerBase method) UpdateTaskStatusRequest (class in momotor.rpc.proto.worker_pb2) UpdateTaskStatusResponse (class in momotor.rpc.proto.worker_pb2) upload_asset_stream() (in module momotor.rpc.asset.server) uploadAsset() (momotor.rpc.proto.client_grpc.ClientBase method) (momotor.rpc.proto.worker_grpc.WorkerBase method) UploadAssetRequest (class in momotor.rpc.proto.asset_pb2) UploadAssetResponse (class in momotor.rpc.proto.asset_pb2) V validate_authenticate_request() (in module momotor.rpc.validate.request) validate_authenticate_response() (in module momotor.rpc.validate.response) validate_create_job_request() (in module momotor.rpc.validate.request) validate_download_asset_request() (in module momotor.rpc.validate.request) validate_end_job_request() (in module momotor.rpc.validate.request) validate_get_task_request() (in module momotor.rpc.validate.request) validate_job_status_request() (in module momotor.rpc.validate.request) validate_oneof() (in module momotor.rpc.validate.base) validate_query() (in module momotor.rpc.validate.query) validate_query_field() (in module momotor.rpc.validate.query) validate_required() (in module momotor.rpc.validate.base) validate_shared_lock_request() (in module momotor.rpc.validate.request) validate_start_job_request() (in module momotor.rpc.validate.request) validate_update_status_request() (in module momotor.rpc.validate.request) validate_upload_asset_request() (in module momotor.rpc.validate.request) W WhichOneof() (momotor.rpc.proto.asset_pb2.AssetData method) (momotor.rpc.proto.asset_pb2.AssetQuery method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse method) (momotor.rpc.proto.auth_pb2.Challenge method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse method) (momotor.rpc.proto.job_pb2.CreateJobRequest method) (momotor.rpc.proto.job_pb2.CreateJobResponse method) (momotor.rpc.proto.job_pb2.EndJobRequest method) (momotor.rpc.proto.job_pb2.EndJobResponse method) (momotor.rpc.proto.job_pb2.JobStatus method) (momotor.rpc.proto.job_pb2.JobStatusRequest method) (momotor.rpc.proto.job_pb2.JobStatusResponse method) (momotor.rpc.proto.job_pb2.JobStatusStream method) (momotor.rpc.proto.job_pb2.StartJobRequest method) (momotor.rpc.proto.job_pb2.StartJobResponse method) (momotor.rpc.proto.resource_pb2.Resource method) (momotor.rpc.proto.shared_pb2.SharedLockRequest method) (momotor.rpc.proto.shared_pb2.SharedLockResponse method) (momotor.rpc.proto.task_pb2.GetTaskRequest method) (momotor.rpc.proto.task_pb2.GetTaskResponse method) (momotor.rpc.proto.task_pb2.TaskId method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse method) wire_message (momotor.rpc.exception.RPCException property) WorkerBase (class in momotor.rpc.proto.worker_grpc) WorkerStub (class in momotor.rpc.proto.worker_grpc)