package pb

Get desktop application:
View/edit binary Protocol Buffers messages

Ack will deliver an ack for a delivered msg.

• string subject = 1

  Subject

• uint64 sequence = 2

  Sequence to acknowledge

Protocol for a client to close a connection

• string client_id = 1

  Client name provided to Connect() requests

Response for CloseRequest

• string error = 1

  err string, empty/omitted if no error

Connection Request

• string client_id = 1

  Client name/identifier.

• string heartbeat_inbox = 2

  Inbox for server initiated heartbeats.

• int32 protocol = 3

  Protocol the client is at.

• bytes conn_id = 4

  Connection ID, a way to uniquely identify a connection (no connection should ever have the same)

• int32 ping_interval = 5

  Interval at which client wishes to send PINGs (expressed in seconds).

• int32 ping_max_out = 6

  Maximum number of PINGs without a response after which the connection can be considered lost.

Response to a client connect

• string pub_prefix = 1

  Prefix to use when publishing to this STAN cluster

• string sub_requests = 2

  Subject to use for subscription requests

• string unsub_requests = 3

  Subject to use for unsubscribe requests

• string close_requests = 4

  Subject for closing the stan connection

• string error = 5

  err string, empty/omitted if no error

• string sub_close_requests = 6

  Subject to use for subscription close requests

• string ping_requests = 7

  Subject to use for PING requests

• int32 ping_interval = 8

  Interval at which client should send PINGs (expressed in seconds).

• int32 ping_max_out = 9

  Maximum number of PINGs without a response after which the connection can be considered lost

• int32 protocol = 10

  Protocol version the server is at

• string public_key = 100

  Possibly used to sign acks, etc.

Msg struct. Sequence is assigned for global ordering by the cluster after the publisher has been acknowledged.

• uint64 sequence = 1

  globally ordered sequence number for the subject's channel

• string subject = 2

  subject

• string reply = 3

  optional reply

• bytes data = 4

  payload

• int64 timestamp = 5

  received timestamp

• bool redelivered = 6

  Flag specifying if the message is being redelivered

• uint32 redelivery_count = 7

  Number of times the message has been redelivered (count currently not persisted)

• uint32 CRC32 = 10

  optional IEEE CRC32

PING from client to server

• bytes conn_id = 1

  Connection ID

PING response from the server

• string error = 1

  Error string, empty/omitted if no error

Used to ACK to publishers

• string guid = 1

  guid

• string error = 2

  err string, empty/omitted if no error

How messages are delivered to the STAN cluster

• string client_id = 1

  ClientID

• string guid = 2

  guid

• string subject = 3

  subject

• string reply = 4

  optional reply

• bytes data = 5

  payload

• bytes conn_id = 6

  Connection ID. For servers that know about this field, clientID can be omitted

• bytes sha256 = 10

  optional sha256 of data

Enum for start position type.

Used in: SubscriptionRequest

• new_only = 0

• last_received = 1

• time_delta_start = 2

• sequence_start = 3

• first = 4

Protocol for a client to subscribe

• string client_id = 1

  ClientID

• string subject = 2

  Formal subject to subscribe to, e.g. foo.bar

• string q_group = 3

  Optional queue group

• string inbox = 4

  Inbox subject to deliver messages on

• int32 max_in_flight = 5

  Maximum inflight messages without an ack allowed

• int32 ack_wait_in_secs = 6

  Timeout for receiving an ack from the client

• string durable_name = 7

  Optional durable name which survives client restarts

• StartPosition start_position = 10

  Start position

• uint64 start_sequence = 11

  Optional start sequence number

• int64 start_time_delta = 12

  Optional start time

Response for SubscriptionRequest and UnsubscribeRequests

• string ack_inbox = 2

  ackInbox for sending acks

• string error = 3

  err string, empty/omitted if no error

Protocol for a clients to unsubscribe. Will return a SubscriptionResponse

• string client_id = 1

  ClientID

• string subject = 2

  subject for the subscription

• string inbox = 3

  Inbox subject to identify subscription

• string durable_name = 4

  Optional durable name which survives client restarts