Default package

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc RegisterNode (RegisterNodeRequest, SimpleResponse)

  app_master_service.proto:26

  message RegisterNodeRequest

  app_master.proto:45

  • int64 version = 1

  • optional NodeSpec node_spec = 2

• rpc HeartBeatNode (HeartBeatRequest, SimpleResponse)

  app_master_service.proto:28

  message HeartBeatRequest

  app_master.proto:62

  • int64 version = 1

  • optional NodeSpec node_spec = 2

• rpc NodeFinish (FinishNodeRequest, SimpleResponse)

  app_master_service.proto:30

  message FinishNodeRequest

  app_master.proto:67

  • int64 version = 1

  • optional NodeSpec node_spec = 2

• rpc GetClusterInfo (GetClusterInfoRequest, GetClusterInfoResponse)

  app_master_service.proto:32

  message GetClusterInfoRequest

  app_master.proto:77

  • int64 version = 1

  • string message = 2

  message GetClusterInfoResponse

  app_master.proto:82

  • int32 code = 1

    code=0 means the cluster is ready.

  • optional MLClusterDef cluster_def = 2

  • string message = 3

• rpc GetVersion (GetVersionRequest, GetVersionResponse)

  app_master_service.proto:34

  message GetVersionRequest

  app_master.proto:37

  • string message = 1

  message GetVersionResponse

  app_master.proto:41

  • int64 version = 1

• rpc StopAllWorker (StopAllWorkerRequest, SimpleResponse)

  app_master_service.proto:36

  message StopAllWorkerRequest

  app_master.proto:56

  • int64 version = 1

  • string job_name = 2

  • int32 index = 3

• rpc GetAMStatus (GetAMStatusRequest, AMStatusMessage)

  app_master_service.proto:38

  message GetAMStatusRequest

  app_master.proto:88

  • string message = 1

  message AMStatusMessage

  app_master.proto:32

  • AMStatus status = 1

• rpc RegisterFailNode (RegisterFailedNodeRequest, SimpleResponse)

  app_master_service.proto:40

  message RegisterFailedNodeRequest

  app_master.proto:50

  • int64 version = 1

  • optional NodeSpec node_spec = 2

  • string message = 3

• rpc GetTaskIndex (GetTaskIndexRequest, GetTaskIndexResponse)

  app_master_service.proto:42

  message GetTaskIndexRequest

  app_master.proto:92

  • int64 version = 1

  • string scope = 2

  • string key = 3

  message GetTaskIndexResponse

  app_master.proto:98

  • int32 code = 1

  • int32 index = 2

  • string message = 3

• rpc GetFinishedNode (GetFinishedNodeRequest, GetFinishNodeResponse)

  app_master_service.proto:44

  message GetFinishedNodeRequest

  app_master.proto:104

  • int64 version = 1

  message GetFinishNodeResponse

  app_master.proto:108

  • int32 code = 1

  • string message = 2

  • repeated int32 workers = 3

• rpc GetNodeSpec (NodeSpecRequest, NodeSpecResponse)

  node_service.proto:27

  message NodeSpecRequest

  node.proto:56

  • string message = 1

  message NodeSpecResponse

  node.proto:60

  • int32 code = 1

  • optional NodeSpec node_spec = 2

  • string message = 3

• rpc NodeRestart (NodeRestartRequest, NodeRestartResponse)

  node_service.proto:29

  message NodeRestartRequest

  node.proto:66

  • string message = 1

  message NodeRestartResponse

  node.proto:70

  • int32 code = 1

  • string message = 2

• rpc NodeStop (NodeStopRequest, NodeStopResponse)

  node_service.proto:31

  message NodeStopRequest

  node.proto:75

  • string message = 1

  message NodeStopResponse

  node.proto:79

  • int32 code = 1

  • string message = 2

• rpc GetContext (ContextRequest, ContextResponse)

  node_service.proto:33

  message ContextRequest

  node.proto:108

  • string message = 1

  message ContextResponse

  node.proto:112

  • int32 code = 1

  • optional ContextProto context = 2

  • string message = 3

• rpc GetFinishWorker (NodeSimpleRequest, FinishWorkerResponse)

  node_service.proto:35

  message FinishWorkerResponse

  node.proto:127

  • repeated int32 workers = 1

  • int32 code = 2

  • string message = 3

• rpc FinishJob (NodeSimpleRequest, NodeSimpleResponse)

  node_service.proto:37

  message NodeSimpleResponse

  node.proto:122

  • int32 code = 1

  • string message = 2

Used in: AMStatusMessage

• AM_UNKNOW = 0

• AM_INIT = 1

• AM_FAILOVER = 2

• AM_RUNNING = 3

• AM_FINISH = 4

Used in: ContextProto

• string name = 1

• string type = 2

Used in: ContextResponse

• string mode = 1

• string roleName = 2

• int32 index = 3

• map<string, int32> roleParallelism = 4

• optional MLClusterDef cluster = 5

• map<string, string> props = 6

• string userScript = 7

• string identity = 8

• string funcName = 9

• int32 failNum = 10

• string outQueueName = 11

  used for ipc queue

• string inQueueName = 12

• int64 outQueueMMapLen = 13

• int64 inQueueMMapLen = 14

• repeated ColumnInfoPB columnInfos = 15

Used in: ContextProto, GetClusterInfoResponse, MLConfigProto

• repeated MLJobDef job = 1

• optional MLClusterDef cluster = 1

• string roleName = 2

  valid values are ["master", "worker", "ps"]

• int32 taskIndex = 3

Used in: MLClusterDef

• string name = 1

• map<int32, NodeSpec> tasks = 2

Used as request type in: NodeService.FinishJob, NodeService.GetFinishWorker

• int32 code = 1

Used in: FinishNodeRequest, HeartBeatRequest, MLJobDef, NodeSpecList, NodeSpecResponse, RegisterFailedNodeRequest, RegisterNodeRequest

• string roleName = 1

• int32 index = 2

• string ip = 3

• int32 client_port = 4

• map<string, string> props = 5

• repeated NodeSpec nodes = 1

Used in: NodeStatusMessage

• NODE_UNKNOW = 0

• NODE_INIT = 1

• NODE_FAIL = 2

• NODE_RUNNING = 3

• NODE_FINISH = 4

• NodeStatus status = 1

Used as response type in: AppMasterService.HeartBeatNode, AppMasterService.NodeFinish, AppMasterService.RegisterFailNode, AppMasterService.RegisterNode, AppMasterService.StopAllWorker

• int32 code = 1

• string message = 2