package coordinator

Get desktop application:
View/edit binary Protocol Buffers messages

/ RPC Api for Coordinator

• rpc CreateDataflow (common.Dataflow, common.Response)

  coordinator.proto:12

  / Attempt to deploy a new dataflow and create a JobManager. / Unless bump into network problems, JobManager will be informed the status of the deployed dataflow asynchronously.

• rpc GetDataflow (GetDataflowRequest, common.DataflowStates)

  coordinator.proto:19

  / Get the details of a dataflow. / The details contains: each operator's status, metrics, basic information, checkpoint status, etc.

  message GetDataflowRequest

  coordinator.proto:26

  • optional common.ResourceId job_id = 1

• rpc ReceiveAck (common.Ack, common.Response)

  coordinator.proto:21

  / Receive ack

• rpc ReceiveHeartbeat (common.Heartbeat, common.Response)

  coordinator.proto:23

  / Receive heartbeat

• rpc TerminateDataflow (common.ResourceId, common.Response)

  coordinator.proto:16

  / Attempt to terminate a dataflow / Unless bump into network problems, JobManager will be informed the status of the deployed dataflow asynchronously. / After the status is transitioned into TERMINATED, the JobManager will be removed from coordinator