package fedvision.framework.cluster

Get desktop application:
View/edit binary Protocol Buffers messages

service in cluster manager called by worker

• rpc Enroll (Enroll.REQ, stream Enroll.REP)

  cluster.proto:11

  service for worker: enroll and fetch tasks

  message Enroll.REQ

  cluster.proto:26

  • string worker_id = 1

  • string worker_ip = 2

  • int32 max_tasks = 3

  • int32 port_start = 4

  • int32 port_end = 5

  message Enroll.REP

  cluster.proto:33

  • Status status = 1

  • optional Task task = 2

• rpc UpdateTaskStatus (UpdateStatus.REQ, UpdateStatus.REP)

  cluster.proto:13

  service for worker: update status or heartbeat

  message UpdateStatus.REQ

  cluster.proto:51

  • string worker_id = 1

  • string job_id = 2

  • string task_id = 3

  • TaskStatus task_status = 4

  • string exception_id = 5

  • string exception = 6

  • optional google.protobuf.Any exec_result = 7

  message UpdateStatus.REP

  cluster.proto:60

  • Status status = 1

• rpc TaskSubmit (TaskSubmit.REQ, TaskSubmit.REP)

  cluster.proto:15

  service for master: submit task to cluster

  message TaskSubmit.REQ

  cluster.proto:71

  • optional Task task = 1

  message TaskSubmit.REP

  cluster.proto:74

  • Status status = 1

• rpc TaskResourceRequire (TaskResourceRequire.REQ, TaskResourceRequire.REP)

  cluster.proto:16

  message TaskResourceRequire.REQ

  cluster.proto:86

  • int32 num_endpoints = 1

  message TaskResourceRequire.REP

  cluster.proto:89

  • Status status = 1

  • string worker_id = 2

  • repeated string endpoints = 3

(message has no fields)

Used in: REP

• UNKNOWN = 0

• ENROLL_SUCCESS = 1

• ALREADY_ENROLL = 2

• TASK_READY = 3

(message has no fields)

Used in: REP

• UNKNOWN = 0

• FAILED = 1

• SUCCESS = 2

(message has no fields)

Used in: REP

• UNKNOWN = 0

• FAILED = 1

• SUCCESS = 2

(message has no fields)

Used in: REP

• UNKNOWN = 0

• FAILED = 1

• SUCCESS = 2

Used in: REQ

• TASK_UNKNOWN = 0

• TASK_CANCEL = 1

• TASK_EXCEPTION = 2

• TASK_FINISH = 3