Documentation ¶
Index ¶
- type Client
- func (_m *Client) Close()
- func (_m *Client) CloseQueue() (*types.Reply, error)
- func (_m *Client) GetConfig() *types.Chain33Config
- func (_m *Client) NewMessage(topic string, ty int64, data interface{}) *queue.Message
- func (_m *Client) Recv() chan *queue.Message
- func (_m *Client) Reply(msg *queue.Message)
- func (_m *Client) Send(msg *queue.Message, waitReply bool) error
- func (_m *Client) SendTimeout(msg *queue.Message, waitReply bool, timeout time.Duration) error
- func (_m *Client) Sub(topic string)
- func (_m *Client) Wait(msg *queue.Message) (*queue.Message, error)
- func (_m *Client) WaitTimeout(msg *queue.Message, timeout time.Duration) (*queue.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func (*Client) CloseQueue ¶
CloseQueue provides a mock function with given fields:
func (*Client) GetConfig ¶
func (_m *Client) GetConfig() *types.Chain33Config
GetConfig provides a mock function with given fields:
func (*Client) NewMessage ¶
NewMessage provides a mock function with given fields: topic, ty, data
func (*Client) SendTimeout ¶
SendTimeout provides a mock function with given fields: msg, waitReply, timeout
Click to show internal directories.
Click to hide internal directories.