mock_gomessagestore

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Package mock_gomessagestore is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockMessage added in v0.2.3 

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

MockMessage is a mock of Message interface

func NewMockMessage added in v0.2.3 

func NewMockMessage(ctrl *gomock.Controller) *MockMessage

NewMockMessage creates a new mock instance

func (*MockMessage) EXPECT added in v0.2.3 

func (m *MockMessage) EXPECT() *MockMessageMockRecorder

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

func (*MockMessage) Position added in v0.2.3 

func (m *MockMessage) Position() int64

Position mocks base method

func (*MockMessage) ToEnvelope added in v0.2.3 

func (m *MockMessage) ToEnvelope() (*repository.MessageEnvelope, error)

ToEnvelope mocks base method

func (*MockMessage) Type added in v0.2.3 

func (m *MockMessage) Type() string

Type mocks base method

func (*MockMessage) Version added in v0.2.3 

func (m *MockMessage) Version() int64

Version mocks base method

type MockMessageHandler added in v0.2.3 

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

MockMessageHandler is a mock of MessageHandler interface

func NewMockMessageHandler added in v0.2.3 

func NewMockMessageHandler(ctrl *gomock.Controller) *MockMessageHandler

NewMockMessageHandler creates a new mock instance

func (*MockMessageHandler) EXPECT added in v0.2.3 

func (m *MockMessageHandler) EXPECT() *MockMessageHandlerMockRecorder

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

func (*MockMessageHandler) Process added in v0.2.3 

func (m *MockMessageHandler) Process(arg0 context.Context, arg1 gomessagestore.Message) error

Process mocks base method

func (*MockMessageHandler) Type added in v0.2.3 

func (m *MockMessageHandler) Type() string

Type mocks base method

type MockMessageHandlerMockRecorder added in v0.2.3 

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

MockMessageHandlerMockRecorder is the mock recorder for MockMessageHandler

func (*MockMessageHandlerMockRecorder) Process added in v0.2.3 

func (mr *MockMessageHandlerMockRecorder) Process(arg0, arg1 interface{}) *gomock.Call

Process indicates an expected call of Process

func (*MockMessageHandlerMockRecorder) Type added in v0.2.3 

func (mr *MockMessageHandlerMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type

type MockMessageMockRecorder added in v0.2.3 

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

MockMessageMockRecorder is the mock recorder for MockMessage

func (*MockMessageMockRecorder) Position added in v0.2.3 

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

Position indicates an expected call of Position

func (*MockMessageMockRecorder) ToEnvelope added in v0.2.3 

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

ToEnvelope indicates an expected call of ToEnvelope

func (*MockMessageMockRecorder) Type added in v0.2.3 

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

Type indicates an expected call of Type

func (*MockMessageMockRecorder) Version added in v0.2.3 

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

Version indicates an expected call of Version

type MockMessageReducer added in v0.2.3 

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

MockMessageReducer is a mock of MessageReducer interface

func NewMockMessageReducer added in v0.2.3 

func NewMockMessageReducer(ctrl *gomock.Controller) *MockMessageReducer

NewMockMessageReducer creates a new mock instance

func (*MockMessageReducer) EXPECT added in v0.2.3 

func (m *MockMessageReducer) EXPECT() *MockMessageReducerMockRecorder

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

func (*MockMessageReducer) Reduce added in v0.2.3 

func (m *MockMessageReducer) Reduce(arg0 gomessagestore.Message, arg1 interface{}) interface{}

Reduce mocks base method

func (*MockMessageReducer) Type added in v0.2.3 

func (m *MockMessageReducer) Type() string

Type mocks base method

type MockMessageReducerMockRecorder added in v0.2.3 

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

MockMessageReducerMockRecorder is the mock recorder for MockMessageReducer

func (*MockMessageReducerMockRecorder) Reduce added in v0.2.3 

func (mr *MockMessageReducerMockRecorder) Reduce(arg0, arg1 interface{}) *gomock.Call

Reduce indicates an expected call of Reduce

func (*MockMessageReducerMockRecorder) Type added in v0.2.3 

func (mr *MockMessageReducerMockRecorder) Type() *gomock.Call

Type indicates an expected call of Type

type MockMessageStore 

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

MockMessageStore is a mock of MessageStore interface

func NewMockMessageStore 

func NewMockMessageStore(ctrl *gomock.Controller) *MockMessageStore

NewMockMessageStore creates a new mock instance

func (*MockMessageStore) CreateProjector 

func (m *MockMessageStore) CreateProjector(arg0 ...gomessagestore.ProjectorOption) (gomessagestore.Projector, error)

CreateProjector mocks base method

func (*MockMessageStore) CreateSubscriber 

func (m *MockMessageStore) CreateSubscriber(arg0 string, arg1 []gomessagestore.MessageHandler, arg2 ...gomessagestore.SubscriberOption) (gomessagestore.Subscriber, error)

CreateSubscriber mocks base method

func (*MockMessageStore) EXPECT 

func (m *MockMessageStore) EXPECT() *MockMessageStoreMockRecorder

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

func (*MockMessageStore) Get 

func (m *MockMessageStore) Get(arg0 context.Context, arg1 ...gomessagestore.GetOption) ([]gomessagestore.Message, error)

Get mocks base method

func (*MockMessageStore) GetLogger added in v0.6.0 

func (m *MockMessageStore) GetLogger() logrus.FieldLogger

GetLogger mocks base method

func (*MockMessageStore) Write 

func (m *MockMessageStore) Write(arg0 context.Context, arg1 gomessagestore.Message, arg2 ...gomessagestore.WriteOption) error

Write mocks base method

type MockMessageStoreMockRecorder 

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

MockMessageStoreMockRecorder is the mock recorder for MockMessageStore

func (*MockMessageStoreMockRecorder) CreateProjector 

func (mr *MockMessageStoreMockRecorder) CreateProjector(arg0 ...interface{}) *gomock.Call

CreateProjector indicates an expected call of CreateProjector

func (*MockMessageStoreMockRecorder) CreateSubscriber 

func (mr *MockMessageStoreMockRecorder) CreateSubscriber(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CreateSubscriber indicates an expected call of CreateSubscriber

func (*MockMessageStoreMockRecorder) Get 

func (mr *MockMessageStoreMockRecorder) Get(arg0 interface{}, arg1 ...interface{}) *gomock.Call

Get indicates an expected call of Get

func (*MockMessageStoreMockRecorder) GetLogger added in v0.6.0 

func (mr *MockMessageStoreMockRecorder) GetLogger() *gomock.Call

GetLogger indicates an expected call of GetLogger

func (*MockMessageStoreMockRecorder) Write 

func (mr *MockMessageStoreMockRecorder) Write(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

Write indicates an expected call of Write

type MockPoller 

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

MockPoller is a mock of Poller interface

func NewMockPoller 

func NewMockPoller(ctrl *gomock.Controller) *MockPoller

NewMockPoller creates a new mock instance

func (*MockPoller) EXPECT 

func (m *MockPoller) EXPECT() *MockPollerMockRecorder

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

func (*MockPoller) Poll 

func (m *MockPoller) Poll(arg0 context.Context) error

Poll mocks base method

type MockPollerMockRecorder 

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

MockPollerMockRecorder is the mock recorder for MockPoller

func (*MockPollerMockRecorder) Poll 

func (mr *MockPollerMockRecorder) Poll(arg0 interface{}) *gomock.Call

Poll indicates an expected call of Poll

type MockProjector added in v0.2.3 

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

MockProjector is a mock of Projector interface

func NewMockProjector added in v0.2.3 

func NewMockProjector(ctrl *gomock.Controller) *MockProjector

NewMockProjector creates a new mock instance

func (*MockProjector) EXPECT added in v0.2.3 

func (m *MockProjector) EXPECT() *MockProjectorMockRecorder

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

func (*MockProjector) Run added in v0.2.3 

func (m *MockProjector) Run(arg0 context.Context, arg1 string, arg2 uuid.UUID) (interface{}, error)

Run mocks base method

func (*MockProjector) RunOnStream added in v0.7.0 

func (m *MockProjector) RunOnStream(arg0 context.Context, arg1 string) (interface{}, error)

RunOnStream mocks base method

func (*MockProjector) Step added in v0.4.3 

func (m *MockProjector) Step(arg0 gomessagestore.Message, arg1 interface{}) (interface{}, bool)

Step mocks base method

type MockProjectorMockRecorder added in v0.2.3 

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

MockProjectorMockRecorder is the mock recorder for MockProjector

func (*MockProjectorMockRecorder) Run added in v0.2.3 

func (mr *MockProjectorMockRecorder) Run(arg0, arg1, arg2 interface{}) *gomock.Call

Run indicates an expected call of Run

func (*MockProjectorMockRecorder) RunOnStream added in v0.7.0 

func (mr *MockProjectorMockRecorder) RunOnStream(arg0, arg1 interface{}) *gomock.Call

RunOnStream indicates an expected call of RunOnStream

func (*MockProjectorMockRecorder) Step added in v0.4.3 

func (mr *MockProjectorMockRecorder) Step(arg0, arg1 interface{}) *gomock.Call

Step indicates an expected call of Step

type MockSubscriber added in v0.2.3 

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

MockSubscriber is a mock of Subscriber interface

func NewMockSubscriber added in v0.2.3 

func NewMockSubscriber(ctrl *gomock.Controller) *MockSubscriber

NewMockSubscriber creates a new mock instance

func (*MockSubscriber) EXPECT added in v0.2.3 

func (m *MockSubscriber) EXPECT() *MockSubscriberMockRecorder

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

func (*MockSubscriber) Start added in v0.2.3 

func (m *MockSubscriber) Start(arg0 context.Context) error

Start mocks base method

type MockSubscriberMockRecorder added in v0.2.3 

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

MockSubscriberMockRecorder is the mock recorder for MockSubscriber

func (*MockSubscriberMockRecorder) Start added in v0.2.3 

func (mr *MockSubscriberMockRecorder) Start(arg0 interface{}) *gomock.Call

Start indicates an expected call of Start

type MockSubscriptionWorker 

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

MockSubscriptionWorker is a mock of SubscriptionWorker interface

func NewMockSubscriptionWorker 

func NewMockSubscriptionWorker(ctrl *gomock.Controller) *MockSubscriptionWorker

NewMockSubscriptionWorker creates a new mock instance

func (*MockSubscriptionWorker) EXPECT 

func (m *MockSubscriptionWorker) EXPECT() *MockSubscriptionWorkerMockRecorder

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

func (*MockSubscriptionWorker) GetMessages 

func (m *MockSubscriptionWorker) GetMessages(arg0 context.Context, arg1 int64) ([]gomessagestore.Message, error)

GetMessages mocks base method

func (*MockSubscriptionWorker) GetPosition 

func (m *MockSubscriptionWorker) GetPosition(arg0 context.Context) (int64, error)

GetPosition mocks base method

func (*MockSubscriptionWorker) ProcessMessages 

func (m *MockSubscriptionWorker) ProcessMessages(arg0 context.Context, arg1 []gomessagestore.Message) (int, int64, error)

ProcessMessages mocks base method

func (*MockSubscriptionWorker) SetPosition 

func (m *MockSubscriptionWorker) SetPosition(arg0 context.Context, arg1 int64) error

SetPosition mocks base method

type MockSubscriptionWorkerMockRecorder 

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

MockSubscriptionWorkerMockRecorder is the mock recorder for MockSubscriptionWorker

func (*MockSubscriptionWorkerMockRecorder) GetMessages 

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

GetMessages indicates an expected call of GetMessages

func (*MockSubscriptionWorkerMockRecorder) GetPosition 

func (mr *MockSubscriptionWorkerMockRecorder) GetPosition(arg0 interface{}) *gomock.Call

GetPosition indicates an expected call of GetPosition

func (*MockSubscriptionWorkerMockRecorder) ProcessMessages 

func (mr *MockSubscriptionWorkerMockRecorder) ProcessMessages(arg0, arg1 interface{}) *gomock.Call

ProcessMessages indicates an expected call of ProcessMessages

func (*MockSubscriptionWorkerMockRecorder) SetPosition 

func (mr *MockSubscriptionWorkerMockRecorder) SetPosition(arg0, arg1 interface{}) *gomock.Call

SetPosition indicates an expected call of SetPosition

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.