mock_mqttadapter

package
v0.0.0-...-4208786 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package mock_mqttadapter is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockMQTTClientAdapter 

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

MockMQTTClientAdapter is a mock of MQTTClientAdapter interface.

func NewMockMQTTClientAdapter 

func NewMockMQTTClientAdapter(ctrl *gomock.Controller) *MockMQTTClientAdapter

NewMockMQTTClientAdapter creates a new mock instance.

func (*MockMQTTClientAdapter) Connect 

func (m *MockMQTTClientAdapter) Connect(ctx context.Context) error

Connect mocks base method.

func (*MockMQTTClientAdapter) ConnectAndWaitForSuccess 

func (m *MockMQTTClientAdapter) ConnectAndWaitForSuccess()

ConnectAndWaitForSuccess mocks base method.

func (*MockMQTTClientAdapter) Disconnect 

func (m *MockMQTTClientAdapter) Disconnect()

Disconnect mocks base method.

func (*MockMQTTClientAdapter) EXPECT 

func (m *MockMQTTClientAdapter) EXPECT() *MockMQTTClientAdapterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMQTTClientAdapter) EnsureConnected 

func (m *MockMQTTClientAdapter) EnsureConnected()

EnsureConnected mocks base method.

func (*MockMQTTClientAdapter) GetClientOptions 

func (m *MockMQTTClientAdapter) GetClientOptions() *mqtt.ClientOptions

GetClientOptions mocks base method.

func (*MockMQTTClientAdapter) GetMqttClient 

func (m *MockMQTTClientAdapter) GetMqttClient() mqtt.Client

GetMqttClient mocks base method.

func (*MockMQTTClientAdapter) IsConnected 

func (m *MockMQTTClientAdapter) IsConnected() bool

IsConnected mocks base method.

func (*MockMQTTClientAdapter) OffConnect 

func (m *MockMQTTClientAdapter) OffConnect(idx int)

OffConnect mocks base method.

func (*MockMQTTClientAdapter) OffConnectLost 

func (m *MockMQTTClientAdapter) OffConnectLost(idx int)

OffConnectLost mocks base method.

func (*MockMQTTClientAdapter) OnConnect 

func (m *MockMQTTClientAdapter) OnConnect(cb mqttadapter.OnConnectCallback) int

OnConnect mocks base method.

func (*MockMQTTClientAdapter) OnConnectLost 

func (m *MockMQTTClientAdapter) OnConnectLost(cb mqttadapter.OnConnectLostCallback) int

OnConnectLost mocks base method.

func (*MockMQTTClientAdapter) OnConnectLostOnce 

func (m *MockMQTTClientAdapter) OnConnectLostOnce(cb mqttadapter.OnConnectLostCallback)

OnConnectLostOnce mocks base method.

func (*MockMQTTClientAdapter) OnConnectOnce 

func (m *MockMQTTClientAdapter) OnConnectOnce(cb mqttadapter.OnConnectCallback)

OnConnectOnce mocks base method.

func (*MockMQTTClientAdapter) PublishBytes 

func (m *MockMQTTClientAdapter) PublishBytes(ctx context.Context, topic string, qos byte, retained bool, data []byte)

PublishBytes mocks base method.

func (*MockMQTTClientAdapter) PublishBytesWait 

func (m *MockMQTTClientAdapter) PublishBytesWait(ctx context.Context, topic string, qos byte, retained bool, data []byte) error

PublishBytesWait mocks base method.

func (*MockMQTTClientAdapter) PublishObject 

func (m *MockMQTTClientAdapter) PublishObject(ctx context.Context, topic string, qos byte, retained bool, payload any) error

PublishObject mocks base method.

func (*MockMQTTClientAdapter) PublishObjectWait 

func (m *MockMQTTClientAdapter) PublishObjectWait(ctx context.Context, topic string, qos byte, retained bool, payload any) error

PublishObjectWait mocks base method.

func (*MockMQTTClientAdapter) Subscribe 

func (m *MockMQTTClientAdapter) Subscribe(ctx context.Context, topic string, qos byte, onMsg mqttadapter.MessageCallback)

Subscribe mocks base method.

func (*MockMQTTClientAdapter) SubscribeMultiple 

func (m *MockMQTTClientAdapter) SubscribeMultiple(ctx context.Context, filters map[string]byte, onMsg mqttadapter.MessageCallback)

SubscribeMultiple mocks base method.

func (*MockMQTTClientAdapter) SubscribeMultipleWait 

func (m *MockMQTTClientAdapter) SubscribeMultipleWait(ctx context.Context, filters map[string]byte, onMsg mqttadapter.MessageCallback) error

SubscribeMultipleWait mocks base method.

func (*MockMQTTClientAdapter) SubscribeWait 

func (m *MockMQTTClientAdapter) SubscribeWait(ctx context.Context, topic string, qos byte, onMsg mqttadapter.MessageCallback) error

SubscribeWait mocks base method.

func (*MockMQTTClientAdapter) Unsubscribe 

func (m *MockMQTTClientAdapter) Unsubscribe(ctx context.Context, topic string)

Unsubscribe mocks base method.

func (*MockMQTTClientAdapter) UnsubscribeAll 

func (m *MockMQTTClientAdapter) UnsubscribeAll(ctx context.Context)

UnsubscribeAll mocks base method.

func (*MockMQTTClientAdapter) UnsubscribeAllWait 

func (m *MockMQTTClientAdapter) UnsubscribeAllWait(ctx context.Context) error

UnsubscribeAllWait mocks base method.

func (*MockMQTTClientAdapter) UnsubscribeWait 

func (m *MockMQTTClientAdapter) UnsubscribeWait(ctx context.Context, topic string) error

UnsubscribeWait mocks base method.

type MockMQTTClientAdapterMockRecorder 

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

MockMQTTClientAdapterMockRecorder is the mock recorder for MockMQTTClientAdapter.

func (*MockMQTTClientAdapterMockRecorder) Connect 

func (mr *MockMQTTClientAdapterMockRecorder) Connect(ctx any) *gomock.Call

Connect indicates an expected call of Connect.

func (*MockMQTTClientAdapterMockRecorder) ConnectAndWaitForSuccess 

func (mr *MockMQTTClientAdapterMockRecorder) ConnectAndWaitForSuccess() *gomock.Call

ConnectAndWaitForSuccess indicates an expected call of ConnectAndWaitForSuccess.

func (*MockMQTTClientAdapterMockRecorder) Disconnect 

func (mr *MockMQTTClientAdapterMockRecorder) Disconnect() *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockMQTTClientAdapterMockRecorder) EnsureConnected 

func (mr *MockMQTTClientAdapterMockRecorder) EnsureConnected() *gomock.Call

EnsureConnected indicates an expected call of EnsureConnected.

func (*MockMQTTClientAdapterMockRecorder) GetClientOptions 

func (mr *MockMQTTClientAdapterMockRecorder) GetClientOptions() *gomock.Call

GetClientOptions indicates an expected call of GetClientOptions.

func (*MockMQTTClientAdapterMockRecorder) GetMqttClient 

func (mr *MockMQTTClientAdapterMockRecorder) GetMqttClient() *gomock.Call

GetMqttClient indicates an expected call of GetMqttClient.

func (*MockMQTTClientAdapterMockRecorder) IsConnected 

func (mr *MockMQTTClientAdapterMockRecorder) IsConnected() *gomock.Call

IsConnected indicates an expected call of IsConnected.

func (*MockMQTTClientAdapterMockRecorder) OffConnect 

func (mr *MockMQTTClientAdapterMockRecorder) OffConnect(idx any) *gomock.Call

OffConnect indicates an expected call of OffConnect.

func (*MockMQTTClientAdapterMockRecorder) OffConnectLost 

func (mr *MockMQTTClientAdapterMockRecorder) OffConnectLost(idx any) *gomock.Call

OffConnectLost indicates an expected call of OffConnectLost.

func (*MockMQTTClientAdapterMockRecorder) OnConnect 

func (mr *MockMQTTClientAdapterMockRecorder) OnConnect(cb any) *gomock.Call

OnConnect indicates an expected call of OnConnect.

func (*MockMQTTClientAdapterMockRecorder) OnConnectLost 

func (mr *MockMQTTClientAdapterMockRecorder) OnConnectLost(cb any) *gomock.Call

OnConnectLost indicates an expected call of OnConnectLost.

func (*MockMQTTClientAdapterMockRecorder) OnConnectLostOnce 

func (mr *MockMQTTClientAdapterMockRecorder) OnConnectLostOnce(cb any) *gomock.Call

OnConnectLostOnce indicates an expected call of OnConnectLostOnce.

func (*MockMQTTClientAdapterMockRecorder) OnConnectOnce 

func (mr *MockMQTTClientAdapterMockRecorder) OnConnectOnce(cb any) *gomock.Call

OnConnectOnce indicates an expected call of OnConnectOnce.

func (*MockMQTTClientAdapterMockRecorder) PublishBytes 

func (mr *MockMQTTClientAdapterMockRecorder) PublishBytes(ctx, topic, qos, retained, data any) *gomock.Call

PublishBytes indicates an expected call of PublishBytes.

func (*MockMQTTClientAdapterMockRecorder) PublishBytesWait 

func (mr *MockMQTTClientAdapterMockRecorder) PublishBytesWait(ctx, topic, qos, retained, data any) *gomock.Call

PublishBytesWait indicates an expected call of PublishBytesWait.

func (*MockMQTTClientAdapterMockRecorder) PublishObject 

func (mr *MockMQTTClientAdapterMockRecorder) PublishObject(ctx, topic, qos, retained, payload any) *gomock.Call

PublishObject indicates an expected call of PublishObject.

func (*MockMQTTClientAdapterMockRecorder) PublishObjectWait 

func (mr *MockMQTTClientAdapterMockRecorder) PublishObjectWait(ctx, topic, qos, retained, payload any) *gomock.Call

PublishObjectWait indicates an expected call of PublishObjectWait.

func (*MockMQTTClientAdapterMockRecorder) Subscribe 

func (mr *MockMQTTClientAdapterMockRecorder) Subscribe(ctx, topic, qos, onMsg any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockMQTTClientAdapterMockRecorder) SubscribeMultiple 

func (mr *MockMQTTClientAdapterMockRecorder) SubscribeMultiple(ctx, filters, onMsg any) *gomock.Call

SubscribeMultiple indicates an expected call of SubscribeMultiple.

func (*MockMQTTClientAdapterMockRecorder) SubscribeMultipleWait 

func (mr *MockMQTTClientAdapterMockRecorder) SubscribeMultipleWait(ctx, filters, onMsg any) *gomock.Call

SubscribeMultipleWait indicates an expected call of SubscribeMultipleWait.

func (*MockMQTTClientAdapterMockRecorder) SubscribeWait 

func (mr *MockMQTTClientAdapterMockRecorder) SubscribeWait(ctx, topic, qos, onMsg any) *gomock.Call

SubscribeWait indicates an expected call of SubscribeWait.

func (*MockMQTTClientAdapterMockRecorder) Unsubscribe 

func (mr *MockMQTTClientAdapterMockRecorder) Unsubscribe(ctx, topic any) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

func (*MockMQTTClientAdapterMockRecorder) UnsubscribeAll 

func (mr *MockMQTTClientAdapterMockRecorder) UnsubscribeAll(ctx any) *gomock.Call

UnsubscribeAll indicates an expected call of UnsubscribeAll.

func (*MockMQTTClientAdapterMockRecorder) UnsubscribeAllWait 

func (mr *MockMQTTClientAdapterMockRecorder) UnsubscribeAllWait(ctx any) *gomock.Call

UnsubscribeAllWait indicates an expected call of UnsubscribeAllWait.

func (*MockMQTTClientAdapterMockRecorder) UnsubscribeWait 

func (mr *MockMQTTClientAdapterMockRecorder) UnsubscribeWait(ctx, topic any) *gomock.Call

UnsubscribeWait indicates an expected call of UnsubscribeWait.

Source Files

View all Source files

Directories

Path Synopsis
Package mock_mqtt is a generated GoMock package.
 Package mock_mqtt is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.