package tmb.internal.net

Get desktop application:
View/edit binary Protocol Buffers messages

TMB service description.

• rpc Connect (EmptyMessage, ConnectResponse)

  tmb_net.proto:118

  message ConnectResponse

  tmb_net.proto:46

  Connect()

  • uint32 client = 1

• rpc CountQueuedMessages (CountQueuedMessagesRequest, CountQueuedMessagesResponse)

  tmb_net.proto:129

  message CountQueuedMessagesRequest

  tmb_net.proto:107

  CountQueuedMessagesForClient()

  • uint32 client = 1

  message CountQueuedMessagesResponse

  tmb_net.proto:111

  • uint64 message_count = 1

• rpc Delete (DeleteOrCancelRequest, EmptyMessage)

  tmb_net.proto:126

• rpc Disconnect (DisconnectRequest, BoolStatus)

  tmb_net.proto:119

  message DisconnectRequest

  tmb_net.proto:51

  Disconnect()

  • uint32 client = 1

• rpc Receive (ReceiveRequest, stream AnnotatedTmbMessage)

  tmb_net.proto:125

  TODO(chasseur): Look into doing server-side blocking version of Receive() to avoid client-side polling.

  message ReceiveRequest

  tmb_net.proto:93

  Various forms of Receive()

  • uint32 receiver = 1

  • uint32 minimum_priority = 2

  • uint64 maximum_messages = 3

  • bool delete_immediately = 4

  message AnnotatedTmbMessage

  tmb_net.proto:30

  • optional TaggedTmbMessage tagged_message = 1

  • uint32 sender = 2

  • uint64 send_time = 3

    Nanoseconds since epoch.

  • int64 message_id = 4

• rpc ReceiverCancel (DeleteOrCancelRequest, EmptyMessage)

  tmb_net.proto:128

• rpc RegisterClientAsReceiver (RegistrationRequest, BoolStatus)

  tmb_net.proto:121

• rpc RegisterClientAsSender (RegistrationRequest, BoolStatus)

  tmb_net.proto:120

• rpc ResetBus (EmptyMessage, EmptyMessage)

  tmb_net.proto:117

• rpc Send (SendRequest, SendResponse)

  tmb_net.proto:122

  message SendRequest

  tmb_net.proto:62

  Send()

  • uint32 sender = 1

  • bool send_to_all = 2

    Address:

  • repeated uint32 explicit_recipient = 3

  • bool broadcast = 4

    Style:

  • uint64 timeout = 5

    Nanoseconds since epoch.

  • optional TaggedTmbMessage msg = 6

  • uint32 priority = 7

  • bool cancellable = 8

  message SendResponse

  tmb_net.proto:79

  • SendResponse.Status status = 1

  • int64 message_id = 2

• rpc SenderCancel (DeleteOrCancelRequest, EmptyMessage)

  tmb_net.proto:127

Used as response type in: MessageBus.Disconnect, MessageBus.RegisterClientAsReceiver, MessageBus.RegisterClientAsSender

• bool status = 1

DeleteMessages()/CancelMessages()

Used as request type in: MessageBus.Delete, MessageBus.ReceiverCancel, MessageBus.SenderCancel

• uint32 client = 1

• repeated int64 message_id = 2

Multipurpose request/response messages:

Used as request type in: MessageBus.Connect, MessageBus.ResetBus

Used as response type in: MessageBus.Delete, MessageBus.ReceiverCancel, MessageBus.ResetBus, MessageBus.SenderCancel

(message has no fields)

RegisterClientAsSender()/RegisterClientAsReceiver()

Used as request type in: MessageBus.RegisterClientAsReceiver, MessageBus.RegisterClientAsSender

• uint32 client = 1

• uint32 message_type = 2

Used in: SendResponse

• OK = 0

• NO_RECEIVERS = 1

• SENDER_NOT_CONNECTED = 2

• SENDER_NOT_REGISTERED_FOR_MESSAGE_TYPE = 3

• RECEIVER_NOT_REGISTERED_FOR_MESSAGE_TYPE = 4

Common TMB message types:

Used in: AnnotatedTmbMessage, SendRequest

• uint32 message_type = 1

• bytes message_body = 2