package ray.streaming.queue.protobuf

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: StreamingQueueCheckMsg, StreamingQueueCheckRspMsg, StreamingQueueDataMsg, StreamingQueueNotificationMsg, StreamingQueuePullRequestMsg, StreamingQueuePullResponseMsg, StreamingQueueResendDataMsg

• bytes src_actor_id = 1

• bytes dst_actor_id = 2

• bytes queue_id = 3

• optional MessageCommon common = 1

• optional MessageCommon common = 1

• StreamingQueueError err_code = 2

• optional MessageCommon common = 1

• uint64 seq_id = 2

• uint64 msg_id_start = 3

• uint64 msg_id_end = 4

• uint64 length = 5

• bool raw = 6

Used in: StreamingQueueCheckRspMsg, StreamingQueuePullResponseMsg

• OK = 0

• QUEUE_NOT_EXIST = 1

• DATA_LOST = 2

• NO_VALID_DATA = 3

• StreamingQueueDataMsgType = 0

• StreamingQueueCheckMsgType = 1

• StreamingQueueCheckRspMsgType = 2

• StreamingQueueNotificationMsgType = 3

• StreamingQueueTestInitMsgType = 4

• StreamingQueueTestCheckStatusRspMsgType = 5

• StreamingQueuePullRequestMsgType = 6

• StreamingQueuePullResponseMsgType = 7

• StreamingQueueResendDataMsgType = 8

• optional MessageCommon common = 1

• uint64 seq_id = 2

• uint64 bundle_id = 3

• optional MessageCommon common = 1

• uint64 msg_id = 2

• optional MessageCommon common = 1

• uint64 seq_id = 2

• uint64 msg_id = 3

• StreamingQueueError err_code = 4

• bool is_upstream_first_pull = 5

• optional MessageCommon common = 1

• uint64 first_seq_id = 2

• uint64 last_seq_id = 3

• uint64 seq_id = 4

• uint64 msg_id_start = 5

• uint64 msg_id_end = 6

• uint64 length = 7

• bool raw = 8

• string test_name = 1

• bool status = 2

• StreamingQueueTestRole role = 1

• bytes src_actor_id = 2

• bytes dst_actor_id = 3

• bytes actor_handle = 4

• repeated bytes queue_ids = 5

• repeated bytes rescale_queue_ids = 6

• string test_suite_name = 7

• string test_name = 8

• uint64 param = 9

for test

Used in: StreamingQueueTestInitMsg

• WRITER = 0

• READER = 1