package golem.worker.v1

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc LaunchNewWorker (LaunchNewWorkerRequest, LaunchNewWorkerResponse)

  worker_service.proto:28

  message LaunchNewWorkerRequest

  worker_service.proto:62

  • optional component.ComponentId componentId = 1

  • string name = 2

  • repeated string args = 3

  • map<string, string> env = 4

  message LaunchNewWorkerResponse

  worker_service.proto:69

  • oneof result

    • LaunchNewWorkerSuccessResponse success = 1

    • WorkerError error = 2

• rpc CompletePromise (CompletePromiseRequest, CompletePromiseResponse)

  worker_service.proto:29

  message CompletePromiseRequest

  worker_service.proto:90

  • optional WorkerId workerId = 1

  • optional CompleteParameters completeParameters = 2

  message CompletePromiseResponse

  worker_service.proto:95

  • oneof result

    • bool success = 1

    • WorkerError error = 2

• rpc DeleteWorker (DeleteWorkerRequest, DeleteWorkerResponse)

  worker_service.proto:30

  message DeleteWorkerRequest

  worker_service.proto:110

  • optional WorkerId workerId = 1

  message DeleteWorkerResponse

  worker_service.proto:114

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc GetWorkerMetadata (GetWorkerMetadataRequest, GetWorkerMetadataResponse)

  worker_service.proto:31

  message GetWorkerMetadataRequest

  worker_service.proto:121

  • optional WorkerId workerId = 1

  message GetWorkerMetadataResponse

  worker_service.proto:125

  • oneof result

    • WorkerMetadata success = 1

    • WorkerError error = 2

• rpc InterruptWorker (InterruptWorkerRequest, InterruptWorkerResponse)

  worker_service.proto:33

  message InterruptWorkerRequest

  worker_service.proto:132

  • optional WorkerId workerId = 1

  • bool recoverImmediately = 2

  message InterruptWorkerResponse

  worker_service.proto:137

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc InvokeAndAwait (InvokeAndAwaitRequest, InvokeAndAwaitResponse)

  worker_service.proto:34

  message InvokeAndAwaitResponse

  worker_service.proto:152

  • oneof result

    • InvokeResult success = 1

    • WorkerError error = 2

• rpc InvokeAndAwaitJson (InvokeAndAwaitJsonRequest, InvokeAndAwaitJsonResponse)

  worker_service.proto:35

  message InvokeAndAwaitJsonRequest

  worker_service.proto:166

  • optional TargetWorkerId workerId = 1

  • optional IdempotencyKey idempotencyKey = 2

  • string function = 3

  • repeated string invokeParameters = 4

  • optional InvocationContext context = 6

  message InvokeAndAwaitJsonResponse

  worker_service.proto:174

  • oneof result

    • string success = 1

    • WorkerError error = 2

• rpc InvokeAndAwaitTyped (InvokeAndAwaitRequest, InvokeAndAwaitTypedResponse)

  worker_service.proto:36

  message InvokeAndAwaitTypedResponse

  worker_service.proto:159

  • oneof result

    • InvokeResultTyped success = 1

    • WorkerError error = 2

• rpc Invoke (InvokeRequest, InvokeResponse)

  worker_service.proto:37

  message InvokeRequest

  worker_service.proto:181

  • optional TargetWorkerId workerId = 1

  • optional IdempotencyKey idempotencyKey = 2

  • string function = 3

  • optional InvokeParameters invokeParameters = 4

  • optional InvocationContext context = 6

• rpc InvokeJson (InvokeJsonRequest, InvokeResponse)

  worker_service.proto:38

  message InvokeJsonRequest

  worker_service.proto:196

  • optional TargetWorkerId workerId = 1

  • optional IdempotencyKey idempotencyKey = 2

  • string function = 3

  • repeated string invokeParameters = 4

  • optional InvocationContext context = 6

• rpc ResumeWorker (ResumeWorkerRequest, ResumeWorkerResponse)

  worker_service.proto:39

  message ResumeWorkerRequest

  worker_service.proto:204

  • optional WorkerId workerId = 1

  • optional bool force = 2

  message ResumeWorkerResponse

  worker_service.proto:209

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc ConnectWorker (ConnectWorkerRequest, stream LogEvent)

  worker_service.proto:40

  message ConnectWorkerRequest

  worker_service.proto:216

  • optional WorkerId worker_id = 1

• rpc GetWorkersMetadata (GetWorkersMetadataRequest, GetWorkersMetadataResponse)

  worker_service.proto:41

  message GetWorkersMetadataRequest

  worker_service.proto:220

  • optional component.ComponentId component_id = 1

  • optional WorkerFilter filter = 2

  • optional Cursor cursor = 3

  • uint64 count = 4

  • bool precise = 5

  message GetWorkersMetadataResponse

  worker_service.proto:229

  • oneof result

    • GetWorkersMetadataSuccessResponse success = 1

    • WorkerError error = 2

• rpc UpdateWorker (UpdateWorkerRequest, UpdateWorkerResponse)

  worker_service.proto:43

  message UpdateWorkerRequest

  worker_service.proto:242

  • optional WorkerId worker_id = 1

  • uint64 target_version = 2

  • UpdateMode mode = 3

  message UpdateWorkerResponse

  worker_service.proto:248

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc GetOplog (GetOplogRequest, GetOplogResponse)

  worker_service.proto:45

  message GetOplogRequest

  worker_service.proto:255

  • optional WorkerId worker_id = 1

  • uint64 from_oplog_index = 3

  • optional OplogCursor cursor = 4

  • uint64 count = 5

  message GetOplogResponse

  worker_service.proto:262

  • oneof result

    • GetOplogSuccessResponse success = 1

    • WorkerError error = 2

• rpc SearchOplog (SearchOplogRequest, SearchOplogResponse)

  worker_service.proto:46

  message SearchOplogRequest

  worker_service.proto:277

  • optional WorkerId worker_id = 1

  • string query = 3

  • optional OplogCursor cursor = 5

  • uint64 count = 6

  message SearchOplogResponse

  worker_service.proto:284

  • oneof result

    • SearchOplogSuccessResponse success = 1

    • WorkerError error = 2

• rpc ListDirectory (ListDirectoryRequest, ListDirectoryResponse)

  worker_service.proto:48

  message ListDirectoryRequest

  worker_service.proto:297

  • optional TargetWorkerId worker_id = 1

  • string path = 2

  message ListDirectoryResponse

  worker_service.proto:302

  • oneof result

    • ListDirectorySuccessResponse success = 1

    • WorkerError error = 2

• rpc GetFileContents (GetFileContentsRequest, stream GetFileContentsResponse)

  worker_service.proto:49

  message GetFileContentsRequest

  worker_service.proto:313

  • optional TargetWorkerId worker_id = 1

  • string file_path = 2

  message GetFileContentsResponse

  worker_service.proto:318

  • oneof result

    • bytes success = 1

    • WorkerError error = 2

• rpc ActivatePlugin (ActivatePluginRequest, ActivatePluginResponse)

  worker_service.proto:51

  message ActivatePluginRequest

  worker_service.proto:325

  • optional WorkerId worker_id = 1

  • optional common.PluginInstallationId installation_id = 2

  message ActivatePluginResponse

  worker_service.proto:330

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc DeactivatePlugin (DeactivatePluginRequest, DeactivatePluginResponse)

  worker_service.proto:52

  message DeactivatePluginRequest

  worker_service.proto:337

  • optional WorkerId worker_id = 1

  • optional common.PluginInstallationId installation_id = 2

  message DeactivatePluginResponse

  worker_service.proto:342

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc ForkWorker (ForkWorkerRequest, ForkWorkerResponse)

  worker_service.proto:54

  message ForkWorkerRequest

  worker_service.proto:83

  • optional WorkerId source_worker_id = 2

  • optional WorkerId target_worker_id = 3

  • uint64 oplog_index_cutoff = 4

  message ForkWorkerResponse

  worker_service.proto:102

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc RevertWorker (RevertWorkerRequest, RevertWorkerResponse)

  worker_service.proto:56

  message RevertWorkerRequest

  worker_service.proto:350

  • optional WorkerId worker_id = 1

  • optional common.RevertWorkerTarget target = 2

  message RevertWorkerResponse

  worker_service.proto:355

  • oneof result

    • common.Empty success = 1

    • WorkerError error = 2

• rpc CancelInvocation (CancelInvocationRequest, CancelInvocationResponse)

  worker_service.proto:57

  message CancelInvocationRequest

  worker_service.proto:362

  • optional WorkerId worker_id = 1

  • optional IdempotencyKey idempotency_key = 2

  message CancelInvocationResponse

  worker_service.proto:367

  • oneof result

    • bool success = 1

    • WorkerError error = 2

Used in: WorkerExecutionError

• optional component.ComponentId component_id = 1

• uint64 component_version = 2

• string reason = 3

Used in: WorkerExecutionError

• optional component.ComponentId component_id = 1

• uint64 component_version = 2

• string reason = 3

Used in: WorkerExecutionError

• optional WorkerId worker_id = 1

• optional WorkerExecutionError reason = 2

Used in: WorkerExecutionError

• string path = 1

• string reason = 2

Used in: WorkerExecutionError

• optional component.ComponentId component_id = 1

• string reason = 2

Used in: GetOplogResponse

• repeated OplogEntry entries = 1

• optional OplogCursor next = 2

• uint64 first_index_in_chunk = 3

• uint64 last_index = 5

Used in: GetWorkersMetadataResponse

• repeated WorkerMetadata workers = 1

• optional Cursor cursor = 2

Used in: WorkerExecutionError

• string path = 1

• string reason = 2

Used in: WorkerExecutionError

• bool recover_immediately = 1

Used in: WorkerExecutionError

(message has no fields)

Used in: WorkerExecutionError

• string details = 1

Used in: WorkerExecutionError

• optional shardmanager.ShardId shard_id = 1

• repeated shardmanager.ShardId shard_ids = 2

Used as request type in: WorkerService.InvokeAndAwait, WorkerService.InvokeAndAwaitTyped

• optional TargetWorkerId workerId = 1

• optional IdempotencyKey idempotencyKey = 2

• string function = 3

• optional InvokeParameters invokeParameters = 4

• optional InvocationContext context = 6

Used as response type in: WorkerService.Invoke, WorkerService.InvokeJson

• oneof result

  • common.Empty success = 1

  • WorkerError error = 2

Used in: LaunchNewWorkerResponse

• optional WorkerId workerId = 1

• uint64 component_version = 2

Used in: ListDirectoryResponse

• repeated FileSystemNode nodes = 1

Used in: WorkerExecutionError

(message has no fields)

Used in: WorkerExecutionError

• string details = 1

Used in: WorkerExecutionError

(message has no fields)

Used in: WorkerExecutionError

• string details = 1

Used in: WorkerExecutionError

• optional PromiseId promise_id = 1

Used in: WorkerExecutionError

• optional PromiseId promise_id = 1

Used in: WorkerExecutionError

• optional PromiseId promise_id = 1

Used in: WorkerExecutionError

• string details = 1

Used in: SearchOplogResponse

• repeated OplogEntryWithIndex entries = 1

• optional OplogCursor next = 2

• uint64 last_index = 5

Used in: WorkerExecutionError

(message has no fields)

Used in: WorkerExecutionError

• string expected = 1

• string got = 2

Used in: WorkerExecutionError

• string details = 1

Used in: WorkerExecutionError

• string details = 1

Used in: WorkerExecutionError

• optional WorkerId worker_id = 1

Used in: WorkerExecutionError

• optional WorkerId worker_id = 1

• string details = 2

Used in: ActivatePluginResponse, CancelInvocationResponse, CompletePromiseResponse, DeactivatePluginResponse, DeleteWorkerResponse, ForkWorkerResponse, GetFileContentsResponse, GetOplogResponse, GetWorkerMetadataResponse, GetWorkersMetadataResponse, InterruptWorkerResponse, InvokeAndAwaitJsonResponse, InvokeAndAwaitResponse, InvokeAndAwaitTypedResponse, InvokeResponse, LaunchNewWorkerResponse, ListDirectoryResponse, ResumeWorkerResponse, RevertWorkerResponse, SearchOplogResponse, UpdateWorkerResponse

• oneof error

  • common.ErrorsBody bad_request = 1

  • common.ErrorBody unauthorized = 2

  • common.ErrorBody limit_exceeded = 3

  • common.ErrorBody not_found = 4

  • common.ErrorBody already_exists = 5

  • WorkerExecutionError internal_error = 6

Used in: FailedToResumeWorker, WorkerError, workerexecutor.v1.ActivatePluginResponse, workerexecutor.v1.AssignShardsResponse, workerexecutor.v1.CancelInvocationResponse, workerexecutor.v1.CompletePromiseResponse, workerexecutor.v1.CreateWorkerResponse, workerexecutor.v1.DeactivatePluginResponse, workerexecutor.v1.DeleteWorkerResponse, workerexecutor.v1.ForkWorkerResponse, workerexecutor.v1.GetFileContentsResponse, workerexecutor.v1.GetOplogResponse, workerexecutor.v1.GetRunningWorkersMetadataResponse, workerexecutor.v1.GetWorkerMetadataResponse, workerexecutor.v1.GetWorkersMetadataResponse, workerexecutor.v1.InterruptWorkerResponse, workerexecutor.v1.InvokeAndAwaitWorkerResponse, workerexecutor.v1.InvokeAndAwaitWorkerResponseTyped, workerexecutor.v1.InvokeWorkerResponse, workerexecutor.v1.ListDirectoryResponse, workerexecutor.v1.ResumeWorkerResponse, workerexecutor.v1.RevertWorkerResponse, workerexecutor.v1.RevokeShardsResponse, workerexecutor.v1.SearchOplogResponse, workerexecutor.v1.UpdateWorkerResponse

• oneof error

  • InvalidRequest invalid_request = 1

  • WorkerAlreadyExists worker_already_exists = 2

  • WorkerCreationFailed worker_creation_failed = 3

  • FailedToResumeWorker failed_to_resume_worker = 4

  • ComponentDownloadFailed component_download_failed = 5

  • ComponentParseFailed component_parse_failed = 6

  • GetLatestVersionOfComponentFailed get_latest_version_of_component_failed = 7

  • PromiseNotFound promise_not_found = 8

  • PromiseDropped promise_dropped = 9

  • PromiseAlreadyCompleted promise_already_completed = 10

  • Interrupted interrupted = 11

  • ParamTypeMismatch param_type_mismatch = 12

  • NoValueInMessage no_value_in_message = 13

  • ValueMismatch value_mismatch = 14

  • UnexpectedOplogEntry unexpected_oplog_entry = 15

  • RuntimeError runtime_error = 16

  • InvalidShardId invalid_shard_id = 17

  • PreviousInvocationFailed previous_invocation_failed = 18

  • UnknownError unknown = 19

  • PreviousInvocationExited previous_invocation_exited = 20

  • InvalidAccount invalid_account = 21

  • WorkerNotFound worker_not_found = 22

  • ShardingNotReady sharding_not_ready = 23

  • InitialComponentFileDownloadFailed initial_component_file_download_failed = 24

  • FileSystemError file_system_error = 25

Used in: WorkerExecutionError

• optional WorkerId worker_id = 1