mqttmock

Documentation

Index

• func AddOnHandler(client wb.ClientInterface)
• type MockClient
  • func NewMockClient() *MockClient
  • func (m *MockClient) Disconnect(_ uint)
  • func (m *MockClient) GetClient() mqtt.Client
  • func (m *MockClient) GetPublishedMessages() []mqtt.Message
  • func (m *MockClient) Publish(p wb.PublishPayload) error
  • func (m *MockClient) Subscribe(topic string, handler mqtt.MessageHandler) error
  • func (m *MockClient) Unsubscribe(topics ...string) error
• 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
  • func (m *MockMessage) WasAcked() bool

Functions

func AddOnHandler

func AddOnHandler(client wb.ClientInterface)

Types

type MockClient

type MockClient struct {
	// contains filtered or unexported fields
}

MockClient симулирует работу MQTT клиента

func NewMockClient

func NewMockClient() *MockClient

NewMockClient создаёт новый MockClient

func (*MockClient) Disconnect

func (m *MockClient) Disconnect(_ uint)

Disconnect отключает клиента (сбрасывает подписки и сообщения)

func (*MockClient) GetClient

func (m *MockClient) GetClient() mqtt.Client

GetClient возвращает nil (MockClient не имеет реального клиента)

func (*MockClient) GetPublishedMessages

func (m *MockClient) GetPublishedMessages() []mqtt.Message

func (*MockClient) Publish

func (m *MockClient) Publish(p wb.PublishPayload) error

Publish публикует сообщение в указанную тему

func (*MockClient) Subscribe

func (m *MockClient) Subscribe(topic string, handler mqtt.MessageHandler) error

Subscribe подписывается на тему с обработчиком сообщений

func (*MockClient) Unsubscribe

func (m *MockClient) Unsubscribe(topics ...string) error

Unsubscribe отписывается от указанных тем

type MockMessage

type MockMessage struct {
	// contains filtered or unexported fields
}

MockMessage имитирует сообщение MQTT и реализует интерфейс Message

func (*MockMessage) Ack

func (m *MockMessage) Ack()

Ack симулирует подтверждение сообщения

func (*MockMessage) Duplicate

func (m *MockMessage) Duplicate() bool

Duplicate возвращает флаг дубликата сообщения

func (*MockMessage) MessageID

func (m *MockMessage) MessageID() uint16

MessageID возвращает идентификатор сообщения

func (*MockMessage) Payload

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

Payload возвращает содержимое сообщения

func (*MockMessage) Qos

func (m *MockMessage) Qos() byte

Qos возвращает уровень QoS сообщения

func (*MockMessage) Retained

func (m *MockMessage) Retained() bool

Retained возвращает флаг Retained сообщения

func (*MockMessage) Topic

func (m *MockMessage) Topic() string

Topic возвращает тему сообщения

func (*MockMessage) WasAcked

func (m *MockMessage) WasAcked() bool

WasAcked проверяет, был ли вызван Ack()