mqtt

Aug 5, 2024

Changes in this version

type Config

+ CloseTimeout time.Duration

type MQTT

+ func (m *MQTT) Close() error

Jul 8, 2024

Changes in this version

type Config

+ KeepAlive time.Duration

+ type MockClient struct

+ func NewMockClient(ctrl *gomock.Controller) *MockClient

+ func (m *MockClient) AddRoute(arg0 string, arg1 mqtt.MessageHandler)

+ func (m *MockClient) Connect() mqtt.Token

+ func (m *MockClient) Disconnect(arg0 uint)

+ func (m *MockClient) EXPECT() *MockClientMockRecorder

+ func (m *MockClient) IsConnected() bool

+ func (m *MockClient) IsConnectionOpen() bool

+ func (m *MockClient) OptionsReader() mqtt.ClientOptionsReader

+ func (m *MockClient) Publish(arg0 string, arg1 byte, arg2 bool, arg3 any) mqtt.Token

+ func (m *MockClient) Subscribe(arg0 string, arg1 byte, arg2 mqtt.MessageHandler) mqtt.Token

+ func (m *MockClient) SubscribeMultiple(arg0 map[string]byte, arg1 mqtt.MessageHandler) mqtt.Token

+ func (m *MockClient) Unsubscribe(arg0 ...string) mqtt.Token

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) AddRoute(arg0, arg1 any) *gomock.Call

+ func (mr *MockClientMockRecorder) Connect() *gomock.Call

+ func (mr *MockClientMockRecorder) Disconnect(arg0 any) *gomock.Call

+ func (mr *MockClientMockRecorder) IsConnected() *gomock.Call

+ func (mr *MockClientMockRecorder) IsConnectionOpen() *gomock.Call

+ func (mr *MockClientMockRecorder) OptionsReader() *gomock.Call

+ func (mr *MockClientMockRecorder) Publish(arg0, arg1, arg2, arg3 any) *gomock.Call

+ func (mr *MockClientMockRecorder) Subscribe(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockClientMockRecorder) SubscribeMultiple(arg0, arg1 any) *gomock.Call

+ func (mr *MockClientMockRecorder) Unsubscribe(arg0 ...any) *gomock.Call

+ type MockLogger struct

+ func NewMockLogger(ctrl *gomock.Controller) *MockLogger

+ func (m *MockLogger) Debug(args ...any)

+ func (m *MockLogger) Debugf(format string, args ...any)

+ func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

+ func (m *MockLogger) Errorf(format string, args ...any)

+ func (m *MockLogger) Infof(format string, args ...any)

+ func (m *MockLogger) Warnf(format string, args ...any)

+ type MockLoggerMockRecorder struct

+ func (mr *MockLoggerMockRecorder) Debug(args ...any) *gomock.Call

+ func (mr *MockLoggerMockRecorder) Debugf(format any, args ...any) *gomock.Call

+ func (mr *MockLoggerMockRecorder) Errorf(format any, args ...any) *gomock.Call

+ func (mr *MockLoggerMockRecorder) Infof(format any, args ...any) *gomock.Call

+ func (mr *MockLoggerMockRecorder) Warnf(format any, args ...any) *gomock.Call

+ type MockPubSub struct

+ func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub

+ func (m *MockPubSub) Disconnect(waitTime uint)

+ func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder

+ func (m *MockPubSub) Health() datasource.Health

+ func (m *MockPubSub) Ping() error

+ func (m *MockPubSub) Publish(ctx context.Context, topic string, message []byte) error

+ func (m *MockPubSub) SubscribeWithFunction(topic string, subscribeFunc SubscribeFunc) error

+ func (m *MockPubSub) Unsubscribe(topic string) error

+ type MockPubSubMockRecorder struct

+ func (mr *MockPubSubMockRecorder) Disconnect(waitTime any) *gomock.Call

+ func (mr *MockPubSubMockRecorder) Health() *gomock.Call

+ func (mr *MockPubSubMockRecorder) Ping() *gomock.Call

+ func (mr *MockPubSubMockRecorder) Publish(ctx, topic, message any) *gomock.Call

+ func (mr *MockPubSubMockRecorder) SubscribeWithFunction(topic, subscribeFunc any) *gomock.Call

+ func (mr *MockPubSubMockRecorder) Unsubscribe(topic any) *gomock.Call

+ type MockToken struct

+ func NewMockToken(ctrl *gomock.Controller) *MockToken

+ func (m *MockToken) Done() <-chan struct{}

+ func (m *MockToken) EXPECT() *MockTokenMockRecorder

+ func (m *MockToken) Error() error

+ func (m *MockToken) Wait() bool

+ func (m *MockToken) WaitTimeout(arg0 time.Duration) bool

+ type MockTokenMockRecorder struct

+ func (mr *MockTokenMockRecorder) Done() *gomock.Call

+ func (mr *MockTokenMockRecorder) Error() *gomock.Call

+ func (mr *MockTokenMockRecorder) Wait() *gomock.Call

+ func (mr *MockTokenMockRecorder) WaitTimeout(arg0 any) *gomock.Call

May 2, 2024

Changes in this version

type Logger

+ Infof func(format string, args ...interface{})

Mar 14, 2024

Changes in this version

+ type Config struct

+ ClientID string

+ Hostname string

+ Order bool

+ Password string

+ Port int

+ Protocol string

+ QoS byte

+ RetrieveRetained bool

+ Username string

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Warnf func(format string, args ...interface{})

+ type MQTT struct

+ func New(config *Config, logger Logger, metrics Metrics) *MQTT

+ func (m *MQTT) CreateTopic(_ context.Context, topic string) error

+ func (m *MQTT) DeleteTopic(_ context.Context, _ string) error

+ func (m *MQTT) Disconnect(waitTime uint)

+ func (m *MQTT) Health() datasource.Health

+ func (m *MQTT) Ping() error

+ func (m *MQTT) Publish(ctx context.Context, topic string, message []byte) error

+ func (m *MQTT) Subscribe(ctx context.Context, topic string) (*pubsub.Message, error)

+ func (m *MQTT) SubscribeWithFunction(topic string, subscribeFunc SubscribeFunc) error

+ func (m *MQTT) Unsubscribe(topic string) error

+ type Metrics interface

+ IncrementCounter func(ctx context.Context, name string, labels ...string)

+ type MockMetrics struct

+ func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

+ func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

+ func (m *MockMetrics) IncrementCounter(ctx context.Context, name string, labels ...string)

+ type MockMetricsMockRecorder struct

+ func (mr *MockMetricsMockRecorder) IncrementCounter(ctx, name interface{}, labels ...interface{}) *gomock.Call

+ type PubSub interface

+ Disconnect func(waitTime uint)

+ Health func() datasource.Health

+ Ping func() error

+ Publish func(ctx context.Context, topic string, message []byte) error

+ SubscribeWithFunction func(topic string, subscribeFunc SubscribeFunc) error

+ Unsubscribe func(topic string) error

+ type SubscribeFunc func(*pubsub.Message) error