package golem.workerexecutor.v1

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc CreateWorker (CreateWorkerRequest, CreateWorkerResponse)

  worker_executor.proto:32

  message CreateWorkerRequest

  worker_executor.proto:121

  • optional worker.WorkerId worker_id = 1

  • uint64 component_version = 2

  • repeated string args = 3

  • map<string, string> env = 4

  • optional common.AccountId account_id = 5

  • optional common.ResourceLimits account_limits = 6

  message CreateWorkerResponse

  worker_executor.proto:130

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc InvokeAndAwaitWorker (InvokeAndAwaitWorkerRequest, InvokeAndAwaitWorkerResponse)

  worker_executor.proto:34

  message InvokeAndAwaitWorkerResponse

  worker_executor.proto:149

  • oneof result

    • InvokeAndAwaitWorkerSuccess success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc InvokeAndAwaitWorkerTyped (InvokeAndAwaitWorkerRequest, InvokeAndAwaitWorkerResponseTyped)

  worker_executor.proto:35

• rpc InvokeWorker (InvokeWorkerRequest, InvokeWorkerResponse)

  worker_executor.proto:36

  message InvokeWorkerRequest

  worker_executor.proto:172

  • optional worker.TargetWorkerId worker_id = 1

  • string name = 2

  • repeated wasm.rpc.Val input = 3

  • optional worker.IdempotencyKey idempotency_key = 4

  • optional common.AccountId account_id = 5

  • optional common.ResourceLimits account_limits = 6

  • optional worker.InvocationContext context = 7

• rpc InvokeAndAwaitWorkerJson (InvokeAndAwaitWorkerJsonRequest, InvokeAndAwaitWorkerResponseTyped)

  worker_executor.proto:37

  message InvokeAndAwaitWorkerJsonRequest

  worker_executor.proto:192

  • optional worker.TargetWorkerId worker_id = 1

  • string name = 2

  • repeated string input = 3

  • optional worker.IdempotencyKey idempotency_key = 4

  • optional common.AccountId account_id = 6

  • optional common.ResourceLimits account_limits = 7

  • optional worker.InvocationContext context = 8

• rpc InvokeWorkerJson (InvokeJsonWorkerRequest, InvokeWorkerResponse)

  worker_executor.proto:38

  message InvokeJsonWorkerRequest

  worker_executor.proto:182

  • optional worker.TargetWorkerId worker_id = 1

  • string name = 2

  • repeated string input = 3

  • optional worker.IdempotencyKey idempotency_key = 4

  • optional common.AccountId account_id = 5

  • optional common.ResourceLimits account_limits = 6

  • optional worker.InvocationContext context = 7

• rpc ConnectWorker (ConnectWorkerRequest, stream worker.LogEvent)

  worker_executor.proto:40

  message ConnectWorkerRequest

  worker_executor.proto:202

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.ResourceLimits account_limits = 3

• rpc DeleteWorker (DeleteWorkerRequest, DeleteWorkerResponse)

  worker_executor.proto:41

  message DeleteWorkerRequest

  worker_executor.proto:85

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  message DeleteWorkerResponse

  worker_executor.proto:90

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc CompletePromise (CompletePromiseRequest, CompletePromiseResponse)

  worker_executor.proto:42

  message CompletePromiseRequest

  worker_executor.proto:97

  • optional worker.PromiseId promise_id = 1

  • bytes data = 2

  • optional common.AccountId account_id = 3

  message CompletePromiseResponse

  worker_executor.proto:103

  • oneof result

    • CompletePromiseSuccess success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc InterruptWorker (InterruptWorkerRequest, InterruptWorkerResponse)

  worker_executor.proto:43

  message InterruptWorkerRequest

  worker_executor.proto:208

  • optional worker.WorkerId worker_id = 1

  • bool recover_immediately = 2

  • optional common.AccountId account_id = 3

  message InterruptWorkerResponse

  worker_executor.proto:114

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc RevokeShards (RevokeShardsRequest, RevokeShardsResponse)

  worker_executor.proto:44

  message RevokeShardsRequest

  worker_executor.proto:214

  • repeated shardmanager.ShardId shard_ids = 1

  message RevokeShardsResponse

  worker_executor.proto:218

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc AssignShards (AssignShardsRequest, AssignShardsResponse)

  worker_executor.proto:45

  message AssignShardsRequest

  worker_executor.proto:225

  • repeated shardmanager.ShardId shard_ids = 1

  message AssignShardsResponse

  worker_executor.proto:229

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc GetWorkerMetadata (GetWorkerMetadataRequest, GetWorkerMetadataResponse)

  worker_executor.proto:46

  message GetWorkerMetadataRequest

  worker_executor.proto:236

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  message GetWorkerMetadataResponse

  worker_executor.proto:241

  • oneof result

    • worker.WorkerMetadata success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc ResumeWorker (ResumeWorkerRequest, ResumeWorkerResponse)

  worker_executor.proto:47

  message ResumeWorkerRequest

  worker_executor.proto:248

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional bool force = 3

  message ResumeWorkerResponse

  worker_executor.proto:254

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc GetRunningWorkersMetadata (GetRunningWorkersMetadataRequest, GetRunningWorkersMetadataResponse)

  worker_executor.proto:48

  message GetRunningWorkersMetadataRequest

  worker_executor.proto:261

  • optional component.ComponentId component_id = 1

  • optional worker.WorkerFilter filter = 2

  message GetRunningWorkersMetadataResponse

  worker_executor.proto:267

  • oneof result

    • GetRunningWorkersMetadataSuccessResponse success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc GetWorkersMetadata (GetWorkersMetadataRequest, GetWorkersMetadataResponse)

  worker_executor.proto:49

  message GetWorkersMetadataRequest

  worker_executor.proto:278

  • optional component.ComponentId component_id = 1

  • optional worker.WorkerFilter filter = 2

  • optional worker.Cursor cursor = 3

  • uint64 count = 4

  • bool precise = 5

  • optional common.AccountId account_id = 6

  message GetWorkersMetadataResponse

  worker_executor.proto:287

  • oneof result

    • GetWorkersMetadataSuccessResponse success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc UpdateWorker (UpdateWorkerRequest, UpdateWorkerResponse)

  worker_executor.proto:50

  message UpdateWorkerRequest

  worker_executor.proto:299

  • optional worker.WorkerId worker_id = 1

  • uint64 target_version = 2

  • worker.UpdateMode mode = 3

  • optional common.AccountId account_id = 4

  message UpdateWorkerResponse

  worker_executor.proto:306

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc GetOplog (GetOplogRequest, GetOplogResponse)

  worker_executor.proto:51

  message GetOplogRequest

  worker_executor.proto:313

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • uint64 from_oplog_index = 3

  • optional worker.OplogCursor cursor = 4

  • uint64 count = 5

  message GetOplogResponse

  worker_executor.proto:321

  • oneof result

    • GetOplogSuccessResponse success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc SearchOplog (SearchOplogRequest, SearchOplogResponse)

  worker_executor.proto:52

  message SearchOplogRequest

  worker_executor.proto:335

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • string query = 3

  • optional worker.OplogCursor cursor = 5

  • uint64 count = 6

  message SearchOplogResponse

  worker_executor.proto:343

  • oneof result

    • SearchOplogSuccessResponse success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc ForkWorker (ForkWorkerRequest, ForkWorkerResponse)

  worker_executor.proto:53

  message ForkWorkerRequest

  worker_executor.proto:64

  • optional common.AccountId account_id = 1

  • optional worker.WorkerId source_worker_id = 2

  • optional worker.WorkerId target_worker_id = 3

  • uint64 oplog_index_cutoff = 4

  message ForkWorkerResponse

  worker_executor.proto:71

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc RevertWorker (RevertWorkerRequest, RevertWorkerResponse)

  worker_executor.proto:54

  message RevertWorkerRequest

  worker_executor.proto:426

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.RevertWorkerTarget target = 3

  message RevertWorkerResponse

  worker_executor.proto:432

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc CancelInvocation (CancelInvocationRequest, CancelInvocationResponse)

  worker_executor.proto:55

  message CancelInvocationRequest

  worker_executor.proto:439

  • optional worker.WorkerId worker_id = 1

  • optional worker.IdempotencyKey idempotency_key = 2

  • optional common.AccountId account_id = 3

  message CancelInvocationResponse

  worker_executor.proto:445

  • oneof result

    • bool success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc ListDirectory (ListDirectoryRequest, ListDirectoryResponse)

  worker_executor.proto:57

  message ListDirectoryRequest

  worker_executor.proto:356

  • optional worker.TargetWorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.ResourceLimits account_limits = 3

  • string path = 4

  message ListDirectoryResponse

  worker_executor.proto:363

  • oneof result

    • ListDirectorySuccessResponse success = 1

    • common.Empty not_found = 2

    • common.Empty not_a_directory = 3

    • worker.v1.WorkerExecutionError failure = 4

• rpc GetFileContents (GetFileContentsRequest, stream GetFileContentsResponse)

  worker_executor.proto:58

  message GetFileContentsRequest

  worker_executor.proto:376

  • optional worker.TargetWorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.ResourceLimits account_limits = 3

  • string file_path = 4

  message GetFileContentsResponse

  worker_executor.proto:383

  • oneof result

    • GetFileContentsResponseHeader header = 1

      must always be the first chunk (except if failure) and will never be sent again.

    • bytes success = 2

    • worker.v1.WorkerExecutionError failure = 3

• rpc ActivatePlugin (ActivatePluginRequest, ActivatePluginResponse)

  worker_executor.proto:60

  message ActivatePluginRequest

  worker_executor.proto:400

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.PluginInstallationId installation_id = 3

  message ActivatePluginResponse

  worker_executor.proto:406

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

• rpc DeactivatePlugin (DeactivatePluginRequest, DeactivatePluginResponse)

  worker_executor.proto:61

  message DeactivatePluginRequest

  worker_executor.proto:413

  • optional worker.WorkerId worker_id = 1

  • optional common.AccountId account_id = 2

  • optional common.PluginInstallationId installation_id = 3

  message DeactivatePluginResponse

  worker_executor.proto:419

  • oneof result

    • common.Empty success = 1

    • worker.v1.WorkerExecutionError failure = 2

Used in: CompletePromiseResponse

• bool completed = 1

Used in: GetFileContentsResponse

• oneof result

  • common.Empty success = 1

  • common.Empty not_found = 2

  • common.Empty not_a_file = 3

Used in: GetOplogResponse

• repeated worker.OplogEntry entries = 1

• optional worker.OplogCursor next = 2

• uint64 first_index_in_chunk = 3

• uint64 last_index = 5

Used in: GetRunningWorkersMetadataResponse

• repeated worker.WorkerMetadata workers = 1

Used in: GetWorkersMetadataResponse

• repeated worker.WorkerMetadata workers = 1

• optional worker.Cursor cursor = 2

Used as request type in: WorkerExecutor.InvokeAndAwaitWorker, WorkerExecutor.InvokeAndAwaitWorkerTyped

• optional worker.TargetWorkerId worker_id = 1

• string name = 2

• repeated wasm.rpc.Val input = 3

• optional worker.IdempotencyKey idempotency_key = 4

• optional common.AccountId account_id = 6

• optional common.ResourceLimits account_limits = 7

• optional worker.InvocationContext context = 8

Used as response type in: WorkerExecutor.InvokeAndAwaitWorkerJson, WorkerExecutor.InvokeAndAwaitWorkerTyped

• oneof result

  • InvokeAndAwaitWorkerSuccessTyped success = 1

  • worker.v1.WorkerExecutionError failure = 2

Used in: InvokeAndAwaitWorkerResponse

• repeated wasm.rpc.Val output = 1

Used in: InvokeAndAwaitWorkerResponseTyped

• optional wasm.rpc.TypeAnnotatedValue output = 1

Used as response type in: WorkerExecutor.InvokeWorker, WorkerExecutor.InvokeWorkerJson

• oneof result

  • common.Empty success = 1

  • worker.v1.WorkerExecutionError failure = 2

Used in: ListDirectoryResponse

• repeated worker.FileSystemNode nodes = 1

Used in: SearchOplogResponse

• repeated worker.OplogEntryWithIndex entries = 1

• optional worker.OplogCursor next = 2

• uint64 last_index = 5