mock

Documentation

Overview

Package mock is a generated GoMock package.

Index

• type MockClient
  • func (c *MockClient) AddRoute(topic string, callback mqtt.MessageHandler)
  • func (c *MockClient) Connect() mqtt.Token
  • func (c *MockClient) Disconnect(quiesce uint)
  • func (c *MockClient) IsConnected() bool
  • func (c *MockClient) IsConnectionOpen() bool
  • func (c *MockClient) OptionsReader() mqtt.ClientOptionsReader
  • func (c *MockClient) Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
  • func (c *MockClient) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
  • func (c *MockClient) SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token
  • func (c *MockClient) Unsubscribe(topics ...string) mqtt.Token
• type MockMessage
  • func (m *MockMessage) Ack()
  • func (m *MockMessage) Duplicate() bool
  • func (m *MockMessage) MessageID() uint16
  • func (m *MockMessage) Payload() []byte
  • func (m *MockMessage) Qos() byte
  • func (m *MockMessage) Retained() bool
  • func (m *MockMessage) Topic() string
• type MockToken
  • func (t *MockToken) Error() error
  • func (t *MockToken) Wait() bool
  • func (t *MockToken) WaitTimeout(d time.Duration) bool

Types

type MockClient

type MockClient struct {
	MockIsConnected       func() bool
	MockIsConnectionOpen  func() bool
	MockConnect           func() mqtt.Token
	MockDisconnect        func(quiesce uint)
	MockPublish           func(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
	MockSubscribe         func(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
	MockSubscribeMultiple func(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token
	MockUnsubscribe       func(topics ...string) mqtt.Token
	MockAddRoute          func(topic string, callback mqtt.MessageHandler)
	MockOptionsReader     func() mqtt.ClientOptionsReader
}

func (*MockClient) AddRoute

func (c *MockClient) AddRoute(topic string, callback mqtt.MessageHandler)

func (*MockClient) Connect

func (c *MockClient) Connect() mqtt.Token

func (*MockClient) Disconnect

func (c *MockClient) Disconnect(quiesce uint)

func (*MockClient) IsConnected

func (c *MockClient) IsConnected() bool

func (*MockClient) IsConnectionOpen

func (c *MockClient) IsConnectionOpen() bool

func (*MockClient) OptionsReader

func (c *MockClient) OptionsReader() mqtt.ClientOptionsReader

func (*MockClient) Publish

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

func (*MockClient) Subscribe

func (c *MockClient) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token

func (*MockClient) SubscribeMultiple

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

func (*MockClient) Unsubscribe

func (c *MockClient) Unsubscribe(topics ...string) mqtt.Token

type MockMessage

type MockMessage struct {
	MockDuplicate func() bool
	MockQos       func() byte
	MockRetained  func() bool
	MockTopic     func() string
	MockMessageID func() uint16
	MockPayload   func() []byte
	MockAck       func()
}

func (*MockMessage) Ack

func (m *MockMessage) Ack()

func (*MockMessage) Duplicate

func (m *MockMessage) Duplicate() bool

func (*MockMessage) MessageID

func (m *MockMessage) MessageID() uint16

func (*MockMessage) Payload

func (m *MockMessage) Payload() []byte

func (*MockMessage) Qos

func (m *MockMessage) Qos() byte

func (*MockMessage) Retained

func (m *MockMessage) Retained() bool

func (*MockMessage) Topic

func (m *MockMessage) Topic() string

type MockToken

type MockToken struct {
	MockWait        func() bool
	MockWaitTimeout func(time.Duration) bool
	MockError       func() error
}

func (*MockToken) Error

func (t *MockToken) Error() error

func (*MockToken) Wait

func (t *MockToken) Wait() bool

func (*MockToken) WaitTimeout

func (t *MockToken) WaitTimeout(d time.Duration) bool