package com.webank.eggroll.core.transfer

Get desktop application:
View/edit binary Protocol Buffers messages

TODO: use transfer lib

• rpc getLog (stream GetLogRequest, stream GetLogResponse)

  extend.proto:40

  message GetLogRequest

  extend.proto:23

  • string sessionId = 1

  • string rank = 2

  • string path = 3

  • int32 startLine = 4

  • string logType = 5

  message GetLogResponse

  extend.proto:31

  • string code = 1

  • repeated string datas = 2

  • string msg = 3

TODO: use transfer lib

• rpc send (stream TransferBatch, TransferBatch)

  transfer.proto:58

• rpc recv (TransferBatch, stream TransferBatch)

  transfer.proto:59

• rpc sendRecv (stream TransferBatch, stream TransferBatch)

  transfer.proto:60

Used in: RollSitePullGetHeaderResponse

• string rollSiteSessionId = 1

• string name = 2

• string tag = 3

• string srcRole = 4

• string srcPartyId = 5

• string dstRole = 6

• string dstPartyId = 7

• string dataType = 8

• map<string, string> options = 10

• int32 totalPartitions = 15

• int32 partitionId = 16

• int64 totalStreams = 17

• int64 totalBatches = 18

• int64 streamSeq = 20

• int64 batchSeq = 21

• string stage = 30

• string tag = 1

(message has no fields)

• string tag = 1

• double timeout = 2

• optional RollSiteHeader header = 1

• string tag = 1

• double timeout = 2

• int64 partition_id = 1

• optional RollSitePullGetPartitionStatusResponse.RollSitePullGetPartitionStatusResponseStatus status = 2

Used in: RollSitePullGetPartitionStatusResponseStatus

• int64 key = 1

• int64 value = 2

Used in: RollSitePullGetPartitionStatusResponse

• string tag = 1

• bool is_finished = 2

• int64 total_batches = 3

• repeated IntKeyIntValuePair batch_seq_to_pair_counter = 4

• int64 total_streams = 5

• repeated IntKeyIntValuePair stream_seq_to_pair_counter = 6

• repeated IntKeyIntValuePair stream_seq_to_batch_seq = 7

• int64 total_pairs = 8

• string data_type = 9

Used as request type in: TransferService.recv, TransferService.send, TransferService.sendRecv

Used as response type in: TransferService.recv, TransferService.send, TransferService.sendRecv

• optional TransferHeader header = 1

• int64 batchSize = 2

• bytes data = 3

Used in: TransferBatch

• int32 id = 1

• string tag = 2

• int64 totalSize = 3

• string status = 4

• bytes ext = 5