mocks

Documentation

Index

• type Client
  • func (_m *Client) Close()
  • func (_m *Client) CloseQueue() (*types.Reply, error)
  • 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)

Types

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) Close

func (_m *Client) Close()

Close provides a mock function with given fields:

func (*Client) CloseQueue

func (_m *Client) CloseQueue() (*types.Reply, error)

CloseQueue provides a mock function with given fields:

func (*Client) NewMessage

func (_m *Client) NewMessage(topic string, ty int64, data interface{}) *queue.Message

NewMessage provides a mock function with given fields: topic, ty, data

func (*Client) Recv

func (_m *Client) Recv() chan *queue.Message

Recv provides a mock function with given fields:

func (*Client) Reply

func (_m *Client) Reply(msg *queue.Message)

Reply provides a mock function with given fields: msg

func (*Client) Send

func (_m *Client) Send(msg *queue.Message, waitReply bool) error

Send provides a mock function with given fields: msg, waitReply

func (*Client) SendTimeout

func (_m *Client) SendTimeout(msg *queue.Message, waitReply bool, timeout time.Duration) error

SendTimeout provides a mock function with given fields: msg, waitReply, timeout

func (*Client) Sub

func (_m *Client) Sub(topic string)

Sub provides a mock function with given fields: topic

func (*Client) Wait

func (_m *Client) Wait(msg *queue.Message) (*queue.Message, error)

Wait provides a mock function with given fields: msg

func (*Client) WaitTimeout

func (_m *Client) WaitTimeout(msg *queue.Message, timeout time.Duration) (*queue.Message, error)

WaitTimeout provides a mock function with given fields: msg, timeout