mocks

package
v0.0.0-...-1d8dca5 Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockClient 

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

MockClient is a mock of Client interface.

func NewMockClient 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) AddRoute 

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

AddRoute mocks base method.

func (*MockClient) Connect 

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

Connect mocks base method.

func (*MockClient) Disconnect 

func (m *MockClient) Disconnect(quiesce uint)

Disconnect mocks base method.

func (*MockClient) EXPECT 

func (m *MockClient) EXPECT() *MockClientMockRecorder

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

func (*MockClient) IsConnected 

func (m *MockClient) IsConnected() bool

IsConnected mocks base method.

func (*MockClient) IsConnectionOpen 

func (m *MockClient) IsConnectionOpen() bool

IsConnectionOpen mocks base method.

func (*MockClient) OptionsReader 

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

OptionsReader mocks base method.

func (*MockClient) Publish 

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

Publish mocks base method.

func (*MockClient) Subscribe 

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

Subscribe mocks base method.

func (*MockClient) SubscribeMultiple 

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

SubscribeMultiple mocks base method.

func (*MockClient) Unsubscribe 

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

Unsubscribe mocks base method.

type MockClientMockRecorder 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) AddRoute 

func (mr *MockClientMockRecorder) AddRoute(topic, callback interface{}) *gomock.Call

AddRoute indicates an expected call of AddRoute.

func (*MockClientMockRecorder) Connect 

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

Connect indicates an expected call of Connect.

func (*MockClientMockRecorder) Disconnect 

func (mr *MockClientMockRecorder) Disconnect(quiesce interface{}) *gomock.Call

Disconnect indicates an expected call of Disconnect.

func (*MockClientMockRecorder) IsConnected 

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

IsConnected indicates an expected call of IsConnected.

func (*MockClientMockRecorder) IsConnectionOpen 

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

IsConnectionOpen indicates an expected call of IsConnectionOpen.

func (*MockClientMockRecorder) OptionsReader 

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

OptionsReader indicates an expected call of OptionsReader.

func (*MockClientMockRecorder) Publish 

func (mr *MockClientMockRecorder) Publish(topic, qos, retained, payload interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockClientMockRecorder) Subscribe 

func (mr *MockClientMockRecorder) Subscribe(topic, qos, callback interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockClientMockRecorder) SubscribeMultiple 

func (mr *MockClientMockRecorder) SubscribeMultiple(filters, callback interface{}) *gomock.Call

SubscribeMultiple indicates an expected call of SubscribeMultiple.

func (*MockClientMockRecorder) Unsubscribe 

func (mr *MockClientMockRecorder) Unsubscribe(topics ...interface{}) *gomock.Call

Unsubscribe indicates an expected call of Unsubscribe.

type MockMessage 

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

MockMessage is a mock of Message interface.

func NewMockMessage 

func NewMockMessage(ctrl *gomock.Controller) *MockMessage

NewMockMessage creates a new mock instance.

func (*MockMessage) Ack 

func (m *MockMessage) Ack()

Ack mocks base method.

func (*MockMessage) Duplicate 

func (m *MockMessage) Duplicate() bool

Duplicate mocks base method.

func (*MockMessage) EXPECT 

func (m *MockMessage) EXPECT() *MockMessageMockRecorder

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

func (*MockMessage) MessageID 

func (m *MockMessage) MessageID() uint16

MessageID mocks base method.

func (*MockMessage) Payload 

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

Payload mocks base method.

func (*MockMessage) Qos 

func (m *MockMessage) Qos() byte

Qos mocks base method.

func (*MockMessage) Retained 

func (m *MockMessage) Retained() bool

Retained mocks base method.

func (*MockMessage) Topic 

func (m *MockMessage) Topic() string

Topic mocks base method.

type MockMessageMockRecorder 

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

MockMessageMockRecorder is the mock recorder for MockMessage.

func (*MockMessageMockRecorder) Ack 

func (mr *MockMessageMockRecorder) Ack() *gomock.Call

Ack indicates an expected call of Ack.

func (*MockMessageMockRecorder) Duplicate 

func (mr *MockMessageMockRecorder) Duplicate() *gomock.Call

Duplicate indicates an expected call of Duplicate.

func (*MockMessageMockRecorder) MessageID 

func (mr *MockMessageMockRecorder) MessageID() *gomock.Call

MessageID indicates an expected call of MessageID.

func (*MockMessageMockRecorder) Payload 

func (mr *MockMessageMockRecorder) Payload() *gomock.Call

Payload indicates an expected call of Payload.

func (*MockMessageMockRecorder) Qos 

func (mr *MockMessageMockRecorder) Qos() *gomock.Call

Qos indicates an expected call of Qos.

func (*MockMessageMockRecorder) Retained 

func (mr *MockMessageMockRecorder) Retained() *gomock.Call

Retained indicates an expected call of Retained.

func (*MockMessageMockRecorder) Topic 

func (mr *MockMessageMockRecorder) Topic() *gomock.Call

Topic indicates an expected call of Topic.

type MockToken 

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

MockToken is a mock of Token interface.

func NewMockToken 

func NewMockToken(ctrl *gomock.Controller) *MockToken

NewMockToken creates a new mock instance.

func (*MockToken) Done 

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

Done mocks base method.

func (*MockToken) EXPECT 

func (m *MockToken) EXPECT() *MockTokenMockRecorder

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

func (*MockToken) Error 

func (m *MockToken) Error() error

Error mocks base method.

func (*MockToken) Wait 

func (m *MockToken) Wait() bool

Wait mocks base method.

func (*MockToken) WaitTimeout 

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

WaitTimeout mocks base method.

type MockTokenMockRecorder 

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

MockTokenMockRecorder is the mock recorder for MockToken.

func (*MockTokenMockRecorder) Done 

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

Done indicates an expected call of Done.

func (*MockTokenMockRecorder) Error 

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

Error indicates an expected call of Error.

func (*MockTokenMockRecorder) Wait 

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

Wait indicates an expected call of Wait.

func (*MockTokenMockRecorder) WaitTimeout 

func (mr *MockTokenMockRecorder) WaitTimeout(arg0 interface{}) *gomock.Call

WaitTimeout indicates an expected call of WaitTimeout.

Source Files

View all Source files

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.