mock

package
v1.0.8 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2025 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock 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) Close 

func (m *MockClient) Close() error

Close mocks base method.

func (*MockClient) Config 

func (m *MockClient) Config() interfaces.Config

Config mocks base method.

func (*MockClient) Context 

func (m *MockClient) Context() context.Context

Context 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) Logger 

func (m *MockClient) Logger() interfaces.Logger

Logger mocks base method.

func (*MockClient) Meter 

func (m *MockClient) Meter() metric.Meter

Meter mocks base method.

func (*MockClient) QueueSubscribeSync 

func (m *MockClient) QueueSubscribeSync(subject, queue string) (interfaces.Subscription, error)

QueueSubscribeSync mocks base method.

func (*MockClient) WithMeter 

func (m *MockClient) WithMeter(arg0 metric.Meter)

WithMeter mocks base method.

type MockClientMockRecorder 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) Close 

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

Close indicates an expected call of Close.

func (*MockClientMockRecorder) Config 

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

Config indicates an expected call of Config.

func (*MockClientMockRecorder) Context 

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

Context indicates an expected call of Context.

func (*MockClientMockRecorder) Logger 

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

Logger indicates an expected call of Logger.

func (*MockClientMockRecorder) Meter 

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

Meter indicates an expected call of Meter.

func (*MockClientMockRecorder) QueueSubscribeSync 

func (mr *MockClientMockRecorder) QueueSubscribeSync(subject, queue any) *gomock.Call

QueueSubscribeSync indicates an expected call of QueueSubscribeSync.

func (*MockClientMockRecorder) WithMeter 

func (mr *MockClientMockRecorder) WithMeter(arg0 any) *gomock.Call

WithMeter indicates an expected call of WithMeter.

type MockConfig 

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

MockConfig is a mock of Config interface.

func NewMockConfig 

func NewMockConfig(ctrl *gomock.Controller) *MockConfig

NewMockConfig creates a new mock instance.

func (*MockConfig) EXPECT 

func (m *MockConfig) EXPECT() *MockConfigMockRecorder

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

func (*MockConfig) GetConcurrentSize 

func (m *MockConfig) GetConcurrentSize() int

GetConcurrentSize mocks base method.

func (*MockConfig) GetMaxConcurrentSize 

func (m *MockConfig) GetMaxConcurrentSize() uint64

GetMaxConcurrentSize mocks base method.

func (*MockConfig) GetReadTimeout 

func (m *MockConfig) GetReadTimeout() time.Duration

GetReadTimeout mocks base method.

type MockConfigMockRecorder 

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

MockConfigMockRecorder is the mock recorder for MockConfig.

func (*MockConfigMockRecorder) GetConcurrentSize 

func (mr *MockConfigMockRecorder) GetConcurrentSize() *gomock.Call

GetConcurrentSize indicates an expected call of GetConcurrentSize.

func (*MockConfigMockRecorder) GetMaxConcurrentSize 

func (mr *MockConfigMockRecorder) GetMaxConcurrentSize() *gomock.Call

GetMaxConcurrentSize indicates an expected call of GetMaxConcurrentSize.

func (*MockConfigMockRecorder) GetReadTimeout 

func (mr *MockConfigMockRecorder) GetReadTimeout() *gomock.Call

GetReadTimeout indicates an expected call of GetReadTimeout.

type MockLogger 

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

MockLogger is a mock of Logger interface.

func NewMockLogger 

func NewMockLogger(ctrl *gomock.Controller) *MockLogger

NewMockLogger creates a new mock instance.

func (*MockLogger) Debug 

func (m *MockLogger) Debug(msg string, args ...any)

Debug mocks base method.

func (*MockLogger) EXPECT 

func (m *MockLogger) EXPECT() *MockLoggerMockRecorder

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

func (*MockLogger) Error 

func (m *MockLogger) Error(msg string, args ...any)

Error mocks base method.

func (*MockLogger) Info 

func (m *MockLogger) Info(msg string, args ...any)

Info mocks base method.

type MockLoggerMockRecorder 

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

MockLoggerMockRecorder is the mock recorder for MockLogger.

func (*MockLoggerMockRecorder) Debug 

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

Debug indicates an expected call of Debug.

func (*MockLoggerMockRecorder) Error 

func (mr *MockLoggerMockRecorder) Error(msg any, args ...any) *gomock.Call

Error indicates an expected call of Error.

func (*MockLoggerMockRecorder) Info 

func (mr *MockLoggerMockRecorder) Info(msg any, args ...any) *gomock.Call

Info indicates an expected call of Info.

type MockMeter 

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

MockMeter is a mock of Meter interface.

func NewMockMeter 

func NewMockMeter(ctrl *gomock.Controller) *MockMeter

NewMockMeter creates a new mock instance.

func (*MockMeter) EXPECT 

func (m *MockMeter) EXPECT() *MockMeterMockRecorder

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

func (*MockMeter) Meter 

func (m *MockMeter) Meter() metric.Meter

Meter mocks base method.

func (*MockMeter) WithMeter 

func (m *MockMeter) WithMeter(arg0 metric.Meter)

WithMeter mocks base method.

type MockMeterMockRecorder 

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

MockMeterMockRecorder is the mock recorder for MockMeter.

func (*MockMeterMockRecorder) Meter 

func (mr *MockMeterMockRecorder) Meter() *gomock.Call

Meter indicates an expected call of Meter.

func (*MockMeterMockRecorder) WithMeter 

func (mr *MockMeterMockRecorder) WithMeter(arg0 any) *gomock.Call

WithMeter indicates an expected call of WithMeter.

type MockMsg 

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

MockMsg is a mock of Msg interface.

func NewMockMsg 

func NewMockMsg(ctrl *gomock.Controller) *MockMsg

NewMockMsg creates a new mock instance.

func (*MockMsg) Copy 

func (m *MockMsg) Copy(subject string) interfaces.Msg

Copy mocks base method.

func (*MockMsg) EXPECT 

func (m *MockMsg) EXPECT() *MockMsgMockRecorder

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

func (*MockMsg) GetData 

func (m *MockMsg) GetData() []byte

GetData mocks base method.

func (*MockMsg) GetHeader 

func (m *MockMsg) GetHeader() map[string][]string

GetHeader mocks base method.

func (*MockMsg) GetSubject 

func (m *MockMsg) GetSubject() string

GetSubject mocks base method.

func (*MockMsg) IsReply 

func (m *MockMsg) IsReply() bool

IsReply mocks base method.

func (*MockMsg) ReplyTo 

func (m *MockMsg) ReplyTo() string

ReplyTo mocks base method.

func (*MockMsg) Respond 

func (m *MockMsg) Respond(arg0 []byte) error

Respond mocks base method.

func (*MockMsg) RespondMsg 

func (m *MockMsg) RespondMsg(arg0 interfaces.Msg) error

RespondMsg mocks base method.

func (*MockMsg) SetHeader 

func (m *MockMsg) SetHeader(key, value string)

SetHeader mocks base method.

type MockMsgMockRecorder 

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

MockMsgMockRecorder is the mock recorder for MockMsg.

func (*MockMsgMockRecorder) Copy 

func (mr *MockMsgMockRecorder) Copy(subject any) *gomock.Call

Copy indicates an expected call of Copy.

func (*MockMsgMockRecorder) GetData 

func (mr *MockMsgMockRecorder) GetData() *gomock.Call

GetData indicates an expected call of GetData.

func (*MockMsgMockRecorder) GetHeader 

func (mr *MockMsgMockRecorder) GetHeader() *gomock.Call

GetHeader indicates an expected call of GetHeader.

func (*MockMsgMockRecorder) GetSubject 

func (mr *MockMsgMockRecorder) GetSubject() *gomock.Call

GetSubject indicates an expected call of GetSubject.

func (*MockMsgMockRecorder) IsReply 

func (mr *MockMsgMockRecorder) IsReply() *gomock.Call

IsReply indicates an expected call of IsReply.

func (*MockMsgMockRecorder) ReplyTo 

func (mr *MockMsgMockRecorder) ReplyTo() *gomock.Call

ReplyTo indicates an expected call of ReplyTo.

func (*MockMsgMockRecorder) Respond 

func (mr *MockMsgMockRecorder) Respond(arg0 any) *gomock.Call

Respond indicates an expected call of Respond.

func (*MockMsgMockRecorder) RespondMsg 

func (mr *MockMsgMockRecorder) RespondMsg(arg0 any) *gomock.Call

RespondMsg indicates an expected call of RespondMsg.

func (*MockMsgMockRecorder) SetHeader 

func (mr *MockMsgMockRecorder) SetHeader(key, value any) *gomock.Call

SetHeader indicates an expected call of SetHeader.

type MockSubscription 

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

MockSubscription is a mock of Subscription interface.

func NewMockSubscription 

func NewMockSubscription(ctrl *gomock.Controller) *MockSubscription

NewMockSubscription creates a new mock instance.

func (*MockSubscription) Delivered 

func (m *MockSubscription) Delivered() (int64, error)

Delivered mocks base method.

func (*MockSubscription) Drain 

func (m *MockSubscription) Drain() error

Drain mocks base method.

func (*MockSubscription) Dropped 

func (m *MockSubscription) Dropped() (int64, error)

Dropped mocks base method.

func (*MockSubscription) EXPECT 

func (m *MockSubscription) EXPECT() *MockSubscriptionMockRecorder

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

func (*MockSubscription) GetSubject 

func (m *MockSubscription) GetSubject() string

GetSubject mocks base method.

func (*MockSubscription) NextMsg 

func (m *MockSubscription) NextMsg(timeout time.Duration) (interfaces.Msg, error)

NextMsg mocks base method.

func (*MockSubscription) Pending 

func (m *MockSubscription) Pending() (int64, int64, error)

Pending mocks base method.

type MockSubscriptionMockRecorder 

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

MockSubscriptionMockRecorder is the mock recorder for MockSubscription.

func (*MockSubscriptionMockRecorder) Delivered 

func (mr *MockSubscriptionMockRecorder) Delivered() *gomock.Call

Delivered indicates an expected call of Delivered.

func (*MockSubscriptionMockRecorder) Drain 

func (mr *MockSubscriptionMockRecorder) Drain() *gomock.Call

Drain indicates an expected call of Drain.

func (*MockSubscriptionMockRecorder) Dropped 

func (mr *MockSubscriptionMockRecorder) Dropped() *gomock.Call

Dropped indicates an expected call of Dropped.

func (*MockSubscriptionMockRecorder) GetSubject 

func (mr *MockSubscriptionMockRecorder) GetSubject() *gomock.Call

GetSubject indicates an expected call of GetSubject.

func (*MockSubscriptionMockRecorder) NextMsg 

func (mr *MockSubscriptionMockRecorder) NextMsg(timeout any) *gomock.Call

NextMsg indicates an expected call of NextMsg.

func (*MockSubscriptionMockRecorder) Pending 

func (mr *MockSubscriptionMockRecorder) Pending() *gomock.Call

Pending indicates an expected call of Pending.

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.