package openfl.aggregator

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc Ping (PingRequest, PingResponse)

  aggregator.proto:12

  message PingRequest

  aggregator.proto:26

  • optional MessageHeader header = 1

  message PingResponse

  aggregator.proto:30

  • optional MessageHeader header = 1

• rpc GetTasks (GetTasksRequest, GetTasksResponse)

  aggregator.proto:13

  message GetTasksRequest

  aggregator.proto:34

  • optional MessageHeader header = 1

  message GetTasksResponse

  aggregator.proto:45

  • optional MessageHeader header = 1

  • int32 round_number = 2

  • repeated Task tasks = 3

    these next three are exclusive. Oneof is probably a good idea

    these three are exclusive

  • int32 sleep_time = 4

    these three are exclusive

  • bool quit = 5

    these three are exclusive

• rpc GetAggregatedTensor (GetAggregatedTensorRequest, GetAggregatedTensorResponse)

  aggregator.proto:14

  message GetAggregatedTensorRequest

  aggregator.proto:54

  • optional MessageHeader header = 1

  • string tensor_name = 2

  • int32 round_number = 3

  • bool report = 4

  • repeated string tags = 5

  • bool require_lossless = 6

  message GetAggregatedTensorResponse

  aggregator.proto:64

  we'll actually send this as a data stream

  • optional MessageHeader header = 1

  • int32 round_number = 2

  • optional NamedTensor tensor = 3

• rpc SendLocalTaskResults (stream DataStream, SendLocalTaskResultsResponse)

  aggregator.proto:15

  message SendLocalTaskResultsResponse

  aggregator.proto:79

  • optional MessageHeader header = 1

• rpc InteropRelay (InteropMessage, InteropMessage)

  aggregator.proto:16

  message InteropMessage

  aggregator.proto:83

  • optional MessageHeader header = 1

  • optional DataStream message = 2

  • map<string, string> metadata = 3

Used in: GetAggregatedTensorRequest, GetAggregatedTensorResponse, GetTasksRequest, GetTasksResponse, InteropMessage, PingRequest, PingResponse, SendLocalTaskResultsResponse, TaskResults

• string sender = 1

• string receiver = 2

• string federation_uuid = 3

• string single_col_cert_common_name = 4

Used in: GetTasksResponse

• string name = 1

• string function_name = 2

• string task_type = 3

• bool apply_local = 4

we'll actually send this as a data stream

• optional MessageHeader header = 1

• int32 round_number = 2

• string task_name = 3

• int32 data_size = 4

• repeated NamedTensor tensors = 5