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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest attribute) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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) details (momotor.rpc.exception.GRPCError 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest attribute) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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 class method) (momotor.rpc.proto.asset_pb2.AssetQuery class method) (momotor.rpc.proto.asset_pb2.DownloadAssetRequest class method) (momotor.rpc.proto.asset_pb2.DownloadAssetResponse class method) (momotor.rpc.proto.asset_pb2.UploadAssetRequest class method) (momotor.rpc.proto.asset_pb2.UploadAssetResponse class method) (momotor.rpc.proto.auth_pb2.AuthenticateRequest class method) (momotor.rpc.proto.auth_pb2.AuthenticateResponse class method) (momotor.rpc.proto.auth_pb2.Challenge class method) (momotor.rpc.proto.auth_pb2.ServerInfoResponse class method) (momotor.rpc.proto.job_pb2.CreateJobRequest class method) (momotor.rpc.proto.job_pb2.CreateJobResponse class method) (momotor.rpc.proto.job_pb2.EndJobRequest class method) (momotor.rpc.proto.job_pb2.EndJobResponse class method) (momotor.rpc.proto.job_pb2.JobStatus class method) (momotor.rpc.proto.job_pb2.JobStatusRequest class method) (momotor.rpc.proto.job_pb2.JobStatusResponse class method) (momotor.rpc.proto.job_pb2.JobStatusStream class method) (momotor.rpc.proto.job_pb2.StartJobRequest class method) (momotor.rpc.proto.job_pb2.StartJobResponse class method) (momotor.rpc.proto.resource_pb2.Resource class method) (momotor.rpc.proto.resource_pb2.UpdateResourceRequest class method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse class method) (momotor.rpc.proto.shared_pb2.SharedLockRequest class method) (momotor.rpc.proto.shared_pb2.SharedLockResponse class method) (momotor.rpc.proto.task_pb2.GetTaskRequest class method) (momotor.rpc.proto.task_pb2.GetTaskResponse class method) (momotor.rpc.proto.task_pb2.TaskId class method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusRequest class method) (momotor.rpc.proto.worker_pb2.UpdateTaskStatusResponse class 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) GRPCError 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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 (momotor.rpc.exception.GRPCError attribute) 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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) ProtocolError 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) 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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) statistics() (momotor.rpc.proto.client_grpc.ClientBase method) status (momotor.rpc.exception.GRPCError attribute) StreamTerminatedError 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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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) UpdateResourceRequest (class in momotor.rpc.proto.resource_pb2) UpdateResourceResponse (class in momotor.rpc.proto.resource_pb2) updateResources() (momotor.rpc.proto.client_grpc.ClientBase 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_resource_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.resource_pb2.UpdateResourceRequest method) (momotor.rpc.proto.resource_pb2.UpdateResourceResponse 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)