mocks

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2025 License: MIT Imports: 5 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.

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 MockGenerator 

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

MockGenerator is a mock of Generator interface.

func NewMockGenerator 

func NewMockGenerator(ctrl *gomock.Controller) *MockGenerator

NewMockGenerator creates a new mock instance.

func (*MockGenerator) EXPECT 

func (m *MockGenerator) EXPECT() *MockGeneratorMockRecorder

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

func (*MockGenerator) GetCurrentTimestamp 

func (m *MockGenerator) GetCurrentTimestamp() int64

GetCurrentTimestamp mocks base method.

func (*MockGenerator) GetUniqueMessageID 

func (m *MockGenerator) GetUniqueMessageID() string

GetUniqueMessageID mocks base method.

func (*MockGenerator) GetUniqueSubscriberID 

func (m *MockGenerator) GetUniqueSubscriberID() string

GetUniqueSubscriberID mocks base method.

type MockGeneratorMockRecorder 

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

MockGeneratorMockRecorder is the mock recorder for MockGenerator.

func (*MockGeneratorMockRecorder) GetCurrentTimestamp 

func (mr *MockGeneratorMockRecorder) GetCurrentTimestamp() *gomock.Call

GetCurrentTimestamp indicates an expected call of GetCurrentTimestamp.

func (*MockGeneratorMockRecorder) GetUniqueMessageID 

func (mr *MockGeneratorMockRecorder) GetUniqueMessageID() *gomock.Call

GetUniqueMessageID indicates an expected call of GetUniqueMessageID.

func (*MockGeneratorMockRecorder) GetUniqueSubscriberID 

func (mr *MockGeneratorMockRecorder) GetUniqueSubscriberID() *gomock.Call

GetUniqueSubscriberID indicates an expected call of GetUniqueSubscriberID.

type MockMQ 

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

MockMQ is a mock of MQ interface.

func NewMockMQ 

func NewMockMQ(ctrl *gomock.Controller) *MockMQ

NewMockMQ creates a new mock instance.

func (*MockMQ) CreateChannel 

func (m *MockMQ) CreateChannel(arg0 context.Context, arg1 string) error

CreateChannel mocks base method.

func (*MockMQ) EXPECT 

func (m *MockMQ) EXPECT() *MockMQMockRecorder

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

func (*MockMQ) Publish 

func (m *MockMQ) Publish(arg0 context.Context, arg1 string, arg2 *mq.Message) error

Publish mocks base method.

func (*MockMQ) Subscribe 

func (m *MockMQ) Subscribe(arg0 context.Context, arg1 *mq.Subscriber, arg2 mq.Offset, arg3 uint64, arg4 string, arg5 chan<- *mq.Message) error

Subscribe mocks base method.

func (*MockMQ) UnSubscribe 

func (m *MockMQ) UnSubscribe(arg0 context.Context, arg1 *mq.Subscriber, arg2 string) error

UnSubscribe mocks base method.

type MockMQMockRecorder 

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

MockMQMockRecorder is the mock recorder for MockMQ.

func (*MockMQMockRecorder) CreateChannel 

func (mr *MockMQMockRecorder) CreateChannel(arg0, arg1 interface{}) *gomock.Call

CreateChannel indicates an expected call of CreateChannel.

func (*MockMQMockRecorder) Publish 

func (mr *MockMQMockRecorder) Publish(arg0, arg1, arg2 interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockMQMockRecorder) Subscribe 

func (mr *MockMQMockRecorder) Subscribe(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

func (*MockMQMockRecorder) UnSubscribe 

func (mr *MockMQMockRecorder) UnSubscribe(arg0, arg1, arg2 interface{}) *gomock.Call

UnSubscribe indicates an expected call of UnSubscribe.

type MockStorage 

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

MockStorage is a mock of Storage interface.

func NewMockStorage 

func NewMockStorage(ctrl *gomock.Controller) *MockStorage

NewMockStorage creates a new mock instance.

func (*MockStorage) ChannelExists 

func (m *MockStorage) ChannelExists(arg0 string) bool

ChannelExists mocks base method.

func (*MockStorage) CreateChannel 

func (m *MockStorage) CreateChannel(arg0 string) error

CreateChannel mocks base method.

func (*MockStorage) EXPECT 

func (m *MockStorage) EXPECT() *MockStorageMockRecorder

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

func (*MockStorage) GetMessages 

func (m *MockStorage) GetMessages(arg0, arg1 string, arg2 uint64) ([]*mq.Message, uint64, error)

GetMessages mocks base method.

func (*MockStorage) RemoveChannelFromSubscriberMap 

func (m *MockStorage) RemoveChannelFromSubscriberMap(arg0, arg1 string)

RemoveChannelFromSubscriberMap mocks base method.

func (*MockStorage) SaveMessage 

func (m *MockStorage) SaveMessage(arg0 string, arg1 *mq.Message) (uint64, error)

SaveMessage mocks base method.

type MockStorageMockRecorder 

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

MockStorageMockRecorder is the mock recorder for MockStorage.

func (*MockStorageMockRecorder) ChannelExists 

func (mr *MockStorageMockRecorder) ChannelExists(arg0 interface{}) *gomock.Call

ChannelExists indicates an expected call of ChannelExists.

func (*MockStorageMockRecorder) CreateChannel 

func (mr *MockStorageMockRecorder) CreateChannel(arg0 interface{}) *gomock.Call

CreateChannel indicates an expected call of CreateChannel.

func (*MockStorageMockRecorder) GetMessages 

func (mr *MockStorageMockRecorder) GetMessages(arg0, arg1, arg2 interface{}) *gomock.Call

GetMessages indicates an expected call of GetMessages.

func (*MockStorageMockRecorder) RemoveChannelFromSubscriberMap 

func (mr *MockStorageMockRecorder) RemoveChannelFromSubscriberMap(arg0, arg1 interface{}) *gomock.Call

RemoveChannelFromSubscriberMap indicates an expected call of RemoveChannelFromSubscriberMap.

func (*MockStorageMockRecorder) SaveMessage 

func (mr *MockStorageMockRecorder) SaveMessage(arg0, arg1 interface{}) *gomock.Call

SaveMessage indicates an expected call of SaveMessage.

type MockValidator 

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

MockValidator is a mock of Validator interface.

func NewMockValidator 

func NewMockValidator(ctrl *gomock.Controller) *MockValidator

NewMockValidator creates a new mock instance.

func (*MockValidator) EXPECT 

func (m *MockValidator) EXPECT() *MockValidatorMockRecorder

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

func (*MockValidator) ValidateStruct 

func (m *MockValidator) ValidateStruct(arg0 interface{}) error

ValidateStruct mocks base method.

type MockValidatorMockRecorder 

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

MockValidatorMockRecorder is the mock recorder for MockValidator.

func (*MockValidatorMockRecorder) ValidateStruct 

func (mr *MockValidatorMockRecorder) ValidateStruct(arg0 interface{}) *gomock.Call

ValidateStruct indicates an expected call of ValidateStruct.

type ServerStreamMock 

type ServerStreamMock struct {
	grpc.ServerStream
	// contains filtered or unexported fields
}

func NewServerStreamMock 

func NewServerStreamMock(ctx context.Context, len int) *ServerStreamMock

func (*ServerStreamMock) Context 

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

func (*ServerStreamMock) Send 

func (m *ServerStreamMock) Send(msg *pb.Message) error

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.