package taskmanager
Get desktop application:
View/edit binary Protocol Buffers messages
/ RPC Api for Task Manager
/ Send all events batchly
message
taskmanager.proto:36(message has no fields)
/ Attempt to create a sub-dataflow
message
taskmanager.proto:42optional job_id = 1
optional dataflow = 2
message
taskmanager.proto:47common.DataflowStatus status = 1
rpc GetSubDataflow (, )
taskmanager.proto:23Get sub dataflow states
rpc ReceiveAck (, )
taskmanager.proto:19/ Receive ack
rpc ReceiveHeartbeat (, )
taskmanager.proto:17/ Receive heartbeat
/ Send event to operator
message
taskmanager.proto:26SendEventToOperatorStatusEnum status = 1
rpc StopDataflow (, )
taskmanager.proto:13/ Attempt to terminate a sub-dataflow
message
taskmanager.proto:38optional resp = 1
Used in:
DISPATCHING = 0
DONE = 1
FAILURE = 2