mocks

Documentation

Index

• type Client
  • func (_m *Client) AddRoute(topic string, callback mqtt.MessageHandler)
  • func (_m *Client) Connect() mqtt.Token
  • func (_m *Client) Disconnect(quiesce uint)
  • func (_m *Client) IsConnected() bool
  • func (_m *Client) IsConnectionOpen() bool
  • func (_m *Client) OptionsReader() mqtt.ClientOptionsReader
  • func (_m *Client) Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
  • func (_m *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
  • func (_m *Client) SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token
  • func (_m *Client) Unsubscribe(topics ...string) mqtt.Token
• type Message
  • func (_m *Message) Ack()
  • func (_m *Message) Duplicate() bool
  • func (_m *Message) MessageID() uint16
  • func (_m *Message) Payload() []byte
  • func (_m *Message) Qos() byte
  • func (_m *Message) Retained() bool
  • func (_m *Message) Topic() string
• type Token
  • func (_m *Token) Done() <-chan struct{}
  • func (_m *Token) Error() error
  • func (_m *Token) Wait() bool
  • func (_m *Token) WaitTimeout(_a0 time.Duration) bool

Types

type Client

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func (*Client) AddRoute

func (_m *Client) AddRoute(topic string, callback mqtt.MessageHandler)

AddRoute provides a mock function with given fields: topic, callback

func (*Client) Connect

func (_m *Client) Connect() mqtt.Token

Connect provides a mock function with given fields:

func (*Client) Disconnect

func (_m *Client) Disconnect(quiesce uint)

Disconnect provides a mock function with given fields: quiesce

func (*Client) IsConnected

func (_m *Client) IsConnected() bool

IsConnected provides a mock function with given fields:

func (*Client) IsConnectionOpen

func (_m *Client) IsConnectionOpen() bool

IsConnectionOpen provides a mock function with given fields:

func (*Client) OptionsReader

func (_m *Client) OptionsReader() mqtt.ClientOptionsReader

OptionsReader provides a mock function with given fields:

func (*Client) Publish

func (_m *Client) Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token

Publish provides a mock function with given fields: topic, qos, retained, payload

func (*Client) Subscribe

func (_m *Client) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token

Subscribe provides a mock function with given fields: topic, qos, callback

func (*Client) SubscribeMultiple

func (_m *Client) SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token

SubscribeMultiple provides a mock function with given fields: filters, callback

func (*Client) Unsubscribe

func (_m *Client) Unsubscribe(topics ...string) mqtt.Token

Unsubscribe provides a mock function with given fields: topics

type Message

type Message struct {
	mock.Mock
}

Message is an autogenerated mock type for the Message type

func (*Message) Ack

func (_m *Message) Ack()

Ack provides a mock function with given fields:

func (*Message) Duplicate

func (_m *Message) Duplicate() bool

Duplicate provides a mock function with given fields:

func (*Message) MessageID

func (_m *Message) MessageID() uint16

MessageID provides a mock function with given fields:

func (*Message) Payload

func (_m *Message) Payload() []byte

Payload provides a mock function with given fields:

func (*Message) Qos

func (_m *Message) Qos() byte

Qos provides a mock function with given fields:

func (*Message) Retained

func (_m *Message) Retained() bool

Retained provides a mock function with given fields:

func (*Message) Topic

func (_m *Message) Topic() string

Topic provides a mock function with given fields:

type Token

type Token struct {
	mock.Mock
}

Token is an autogenerated mock type for the Token type

func (*Token) Done

func (_m *Token) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*Token) Error

func (_m *Token) Error() error

Error provides a mock function with given fields:

func (*Token) Wait

func (_m *Token) Wait() bool

Wait provides a mock function with given fields:

func (*Token) WaitTimeout

func (_m *Token) WaitTimeout(_a0 time.Duration) bool

WaitTimeout provides a mock function with given fields: _a0