Directories ¶
Path | Synopsis |
---|---|
Package client defines the api and information which can be exposed to user.
|
Package client defines the api and information which can be exposed to user. |
Package codec defines the encoding and decoding logic between TubeMQ.
|
Package codec defines the encoding and decoding logic between TubeMQ. |
Package config defines the all the TubeMQ configuration options.
|
Package config defines the all the TubeMQ configuration options. |
Package errs defines the TubeMQ error codes and TubeMQ error msg.
|
Package errs defines the TubeMQ error codes and TubeMQ error msg. |
Package flowctrl defines the rule and handle logic of flow control.
|
Package flowctrl defines the rule and handle logic of flow control. |
Package log defines the logger for the sdk.
|
Package log defines the logger for the sdk. |
Package metadata defines all the metadata of the TubeMQ broker and producer.
|
Package metadata defines all the metadata of the TubeMQ broker and producer. |
Package multiplexing defines the multiplex connection pool for sending request and receiving response.
|
Package multiplexing defines the multiplex connection pool for sending request and receiving response. |
Package remote defines the remote data which is returned from TubeMQ.
|
Package remote defines the remote data which is returned from TubeMQ. |
Package rpc encapsulates all the rpc request to TubeMQ.
|
Package rpc encapsulates all the rpc request to TubeMQ. |
Package selector defines the route selector which is responsible for service discovery.
|
Package selector defines the route selector which is responsible for service discovery. |
Package sub defines the subscription information of a client.
|
Package sub defines the subscription information of a client. |
Package transport defines the network communication layer which is responsible for encoding the rpc request and decoding the response from TubeMQ.
|
Package transport defines the network communication layer which is responsible for encoding the rpc request and decoding the response from TubeMQ. |
Package util defines the constants and helper functions.
|
Package util defines the constants and helper functions. |
Click to show internal directories.
Click to hide internal directories.