mocks

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: May 14, 2023 License: LGPL-3.0 Imports: 6 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.

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.

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 MockInhooksConfigService 

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

MockInhooksConfigService is a mock of InhooksConfigService interface.

func NewMockInhooksConfigService 

func NewMockInhooksConfigService(ctrl *gomock.Controller) *MockInhooksConfigService

NewMockInhooksConfigService creates a new mock instance.

func (*MockInhooksConfigService) EXPECT 

func (m *MockInhooksConfigService) EXPECT() *MockInhooksConfigServiceMockRecorder

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

func (*MockInhooksConfigService) FindFlowForSource 

func (m *MockInhooksConfigService) FindFlowForSource(sourceSlug string) *models.Flow

FindFlowForSource mocks base method.

func (*MockInhooksConfigService) GetFlow 

func (m *MockInhooksConfigService) GetFlow(flowID string) *models.Flow

GetFlow mocks base method.

func (*MockInhooksConfigService) GetFlows 

func (m *MockInhooksConfigService) GetFlows() map[string]*models.Flow

GetFlows mocks base method.

func (*MockInhooksConfigService) Load 

func (m *MockInhooksConfigService) Load(path string) error

Load mocks base method.

type MockInhooksConfigServiceMockRecorder 

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

MockInhooksConfigServiceMockRecorder is the mock recorder for MockInhooksConfigService.

func (*MockInhooksConfigServiceMockRecorder) FindFlowForSource 

func (mr *MockInhooksConfigServiceMockRecorder) FindFlowForSource(sourceSlug interface{}) *gomock.Call

FindFlowForSource indicates an expected call of FindFlowForSource.

func (*MockInhooksConfigServiceMockRecorder) GetFlow 

func (mr *MockInhooksConfigServiceMockRecorder) GetFlow(flowID interface{}) *gomock.Call

GetFlow indicates an expected call of GetFlow.

func (*MockInhooksConfigServiceMockRecorder) GetFlows 

func (mr *MockInhooksConfigServiceMockRecorder) GetFlows() *gomock.Call

GetFlows indicates an expected call of GetFlows.

func (*MockInhooksConfigServiceMockRecorder) Load 

func (mr *MockInhooksConfigServiceMockRecorder) Load(path interface{}) *gomock.Call

Load indicates an expected call of Load.

type MockMessageBuilder 

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

MockMessageBuilder is a mock of MessageBuilder interface.

func NewMockMessageBuilder 

func NewMockMessageBuilder(ctrl *gomock.Controller) *MockMessageBuilder

NewMockMessageBuilder creates a new mock instance.

func (*MockMessageBuilder) EXPECT 

func (m *MockMessageBuilder) EXPECT() *MockMessageBuilderMockRecorder

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

func (*MockMessageBuilder) FromHttp 

func (m *MockMessageBuilder) FromHttp(flow *models.Flow, r *http.Request, reqID string) ([]*models.Message, error)

FromHttp mocks base method.

type MockMessageBuilderMockRecorder 

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

MockMessageBuilderMockRecorder is the mock recorder for MockMessageBuilder.

func (*MockMessageBuilderMockRecorder) FromHttp 

func (mr *MockMessageBuilderMockRecorder) FromHttp(flow, r, reqID interface{}) *gomock.Call

FromHttp indicates an expected call of FromHttp.

type MockMessageEnqueuer 

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

MockMessageEnqueuer is a mock of MessageEnqueuer interface.

func NewMockMessageEnqueuer 

func NewMockMessageEnqueuer(ctrl *gomock.Controller) *MockMessageEnqueuer

NewMockMessageEnqueuer creates a new mock instance.

func (*MockMessageEnqueuer) EXPECT 

func (m *MockMessageEnqueuer) EXPECT() *MockMessageEnqueuerMockRecorder

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

func (*MockMessageEnqueuer) Enqueue 

func (m *MockMessageEnqueuer) Enqueue(ctx context.Context, messages []*models.Message) error

Enqueue mocks base method.

type MockMessageEnqueuerMockRecorder 

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

MockMessageEnqueuerMockRecorder is the mock recorder for MockMessageEnqueuer.

func (*MockMessageEnqueuerMockRecorder) Enqueue 

func (mr *MockMessageEnqueuerMockRecorder) Enqueue(ctx, messages interface{}) *gomock.Call

Enqueue indicates an expected call of Enqueue.

type MockMessageFetcher 

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

MockMessageFetcher is a mock of MessageFetcher interface.

func NewMockMessageFetcher 

func NewMockMessageFetcher(ctrl *gomock.Controller) *MockMessageFetcher

NewMockMessageFetcher creates a new mock instance.

func (*MockMessageFetcher) EXPECT 

func (m *MockMessageFetcher) EXPECT() *MockMessageFetcherMockRecorder

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

func (*MockMessageFetcher) GetMessageForProcessing 

func (m *MockMessageFetcher) GetMessageForProcessing(ctx context.Context, timeout time.Duration, flowID, sinkID string) (*models.Message, error)

GetMessageForProcessing mocks base method.

type MockMessageFetcherMockRecorder 

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

MockMessageFetcherMockRecorder is the mock recorder for MockMessageFetcher.

func (*MockMessageFetcherMockRecorder) GetMessageForProcessing 

func (mr *MockMessageFetcherMockRecorder) GetMessageForProcessing(ctx, timeout, flowID, sinkID interface{}) *gomock.Call

GetMessageForProcessing indicates an expected call of GetMessageForProcessing.

type MockMessageProcessor 

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

MockMessageProcessor is a mock of MessageProcessor interface.

func NewMockMessageProcessor 

func NewMockMessageProcessor(ctrl *gomock.Controller) *MockMessageProcessor

NewMockMessageProcessor creates a new mock instance.

func (*MockMessageProcessor) EXPECT 

func (m *MockMessageProcessor) EXPECT() *MockMessageProcessorMockRecorder

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

func (*MockMessageProcessor) Process 

func (m_2 *MockMessageProcessor) Process(ctx context.Context, sink *models.Sink, m *models.Message) error

Process mocks base method.

type MockMessageProcessorMockRecorder 

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

MockMessageProcessorMockRecorder is the mock recorder for MockMessageProcessor.

func (*MockMessageProcessorMockRecorder) Process 

func (mr *MockMessageProcessorMockRecorder) Process(ctx, sink, m interface{}) *gomock.Call

Process indicates an expected call of Process.

type MockProcessingResultsService 

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

MockProcessingResultsService is a mock of ProcessingResultsService interface.

func NewMockProcessingResultsService 

func NewMockProcessingResultsService(ctrl *gomock.Controller) *MockProcessingResultsService

NewMockProcessingResultsService creates a new mock instance.

func (*MockProcessingResultsService) EXPECT 

func (m *MockProcessingResultsService) EXPECT() *MockProcessingResultsServiceMockRecorder

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

func (*MockProcessingResultsService) HandleFailed 

func (m_2 *MockProcessingResultsService) HandleFailed(ctx context.Context, sink *models.Sink, m *models.Message, processingErr error) (*models.RequeuedInfo, error)

HandleFailed mocks base method.

func (*MockProcessingResultsService) HandleOK 

func (m_2 *MockProcessingResultsService) HandleOK(ctx context.Context, m *models.Message) error

HandleOK mocks base method.

type MockProcessingResultsServiceMockRecorder 

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

MockProcessingResultsServiceMockRecorder is the mock recorder for MockProcessingResultsService.

func (*MockProcessingResultsServiceMockRecorder) HandleFailed 

func (mr *MockProcessingResultsServiceMockRecorder) HandleFailed(ctx, sink, m, processingErr interface{}) *gomock.Call

HandleFailed indicates an expected call of HandleFailed.

func (*MockProcessingResultsServiceMockRecorder) HandleOK 

func (mr *MockProcessingResultsServiceMockRecorder) HandleOK(ctx, m interface{}) *gomock.Call

HandleOK indicates an expected call of HandleOK.

type MockRedisStore 

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

MockRedisStore is a mock of RedisStore interface.

func NewMockRedisStore 

func NewMockRedisStore(ctrl *gomock.Controller) *MockRedisStore

NewMockRedisStore creates a new mock instance.

func (*MockRedisStore) BLMove 

func (m *MockRedisStore) BLMove(ctx context.Context, timeout time.Duration, sourceQueueKey, destQueueKey string) ([]byte, error)

BLMove mocks base method.

func (*MockRedisStore) Dequeue 

func (m *MockRedisStore) Dequeue(ctx context.Context, timeout time.Duration, key string) ([]byte, error)

Dequeue mocks base method.

func (*MockRedisStore) EXPECT 

func (m *MockRedisStore) EXPECT() *MockRedisStoreMockRecorder

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

func (*MockRedisStore) Enqueue 

func (m *MockRedisStore) Enqueue(ctx context.Context, key string, value []byte) error

Enqueue mocks base method.

func (*MockRedisStore) Get 

func (m *MockRedisStore) Get(ctx context.Context, messageKey string) ([]byte, error)

Get mocks base method.

func (*MockRedisStore) SetAndEnqueue 

func (m *MockRedisStore) SetAndEnqueue(ctx context.Context, messageKey string, value []byte, queueKey, messageID string) error

SetAndEnqueue mocks base method.

func (*MockRedisStore) SetAndMove 

func (m *MockRedisStore) SetAndMove(ctx context.Context, messageKey string, value []byte, sourceQueueKey, destQueueKey, messageID string) error

SetAndMove mocks base method.

func (*MockRedisStore) SetAndZAdd 

func (m *MockRedisStore) SetAndZAdd(ctx context.Context, messageKey string, value []byte, queueKey, messageID string, score float64) error

SetAndZAdd mocks base method.

func (*MockRedisStore) SetLRemZAdd 

func (m *MockRedisStore) SetLRemZAdd(ctx context.Context, messageKey string, value []byte, sourceQueueKey, destQueueKey, messageID string, score float64) error

SetLRemZAdd mocks base method.

func (*MockRedisStore) ZRangeBelowScore 

func (m *MockRedisStore) ZRangeBelowScore(ctx context.Context, queueKey string, score float64) ([]string, error)

ZRangeBelowScore mocks base method.

func (*MockRedisStore) ZRemRpush 

func (m *MockRedisStore) ZRemRpush(ctx context.Context, messageIDs []string, sourceQueueKey, destQueueKey string) error

ZRemRpush mocks base method.

type MockRedisStoreMockRecorder 

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

MockRedisStoreMockRecorder is the mock recorder for MockRedisStore.

func (*MockRedisStoreMockRecorder) BLMove 

func (mr *MockRedisStoreMockRecorder) BLMove(ctx, timeout, sourceQueueKey, destQueueKey interface{}) *gomock.Call

BLMove indicates an expected call of BLMove.

func (*MockRedisStoreMockRecorder) Dequeue 

func (mr *MockRedisStoreMockRecorder) Dequeue(ctx, timeout, key interface{}) *gomock.Call

Dequeue indicates an expected call of Dequeue.

func (*MockRedisStoreMockRecorder) Enqueue 

func (mr *MockRedisStoreMockRecorder) Enqueue(ctx, key, value interface{}) *gomock.Call

Enqueue indicates an expected call of Enqueue.

func (*MockRedisStoreMockRecorder) Get 

func (mr *MockRedisStoreMockRecorder) Get(ctx, messageKey interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockRedisStoreMockRecorder) SetAndEnqueue 

func (mr *MockRedisStoreMockRecorder) SetAndEnqueue(ctx, messageKey, value, queueKey, messageID interface{}) *gomock.Call

SetAndEnqueue indicates an expected call of SetAndEnqueue.

func (*MockRedisStoreMockRecorder) SetAndMove 

func (mr *MockRedisStoreMockRecorder) SetAndMove(ctx, messageKey, value, sourceQueueKey, destQueueKey, messageID interface{}) *gomock.Call

SetAndMove indicates an expected call of SetAndMove.

func (*MockRedisStoreMockRecorder) SetAndZAdd 

func (mr *MockRedisStoreMockRecorder) SetAndZAdd(ctx, messageKey, value, queueKey, messageID, score interface{}) *gomock.Call

SetAndZAdd indicates an expected call of SetAndZAdd.

func (*MockRedisStoreMockRecorder) SetLRemZAdd 

func (mr *MockRedisStoreMockRecorder) SetLRemZAdd(ctx, messageKey, value, sourceQueueKey, destQueueKey, messageID, score interface{}) *gomock.Call

SetLRemZAdd indicates an expected call of SetLRemZAdd.

func (*MockRedisStoreMockRecorder) ZRangeBelowScore 

func (mr *MockRedisStoreMockRecorder) ZRangeBelowScore(ctx, queueKey, score interface{}) *gomock.Call

ZRangeBelowScore indicates an expected call of ZRangeBelowScore.

func (*MockRedisStoreMockRecorder) ZRemRpush 

func (mr *MockRedisStoreMockRecorder) ZRemRpush(ctx, messageIDs, sourceQueueKey, destQueueKey interface{}) *gomock.Call

ZRemRpush indicates an expected call of ZRemRpush.

type MockSchedulerService 

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

MockSchedulerService is a mock of SchedulerService interface.

func NewMockSchedulerService 

func NewMockSchedulerService(ctrl *gomock.Controller) *MockSchedulerService

NewMockSchedulerService creates a new mock instance.

func (*MockSchedulerService) EXPECT 

func (m *MockSchedulerService) EXPECT() *MockSchedulerServiceMockRecorder

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

func (*MockSchedulerService) MoveDueScheduled 

func (m *MockSchedulerService) MoveDueScheduled(ctx context.Context, f *models.Flow, sink *models.Sink) error

MoveDueScheduled mocks base method.

type MockSchedulerServiceMockRecorder 

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

MockSchedulerServiceMockRecorder is the mock recorder for MockSchedulerService.

func (*MockSchedulerServiceMockRecorder) MoveDueScheduled 

func (mr *MockSchedulerServiceMockRecorder) MoveDueScheduled(ctx, f, sink interface{}) *gomock.Call

MoveDueScheduled indicates an expected call of MoveDueScheduled.

type MockTimeService 

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

MockTimeService is a mock of TimeService interface.

func NewMockTimeService 

func NewMockTimeService(ctrl *gomock.Controller) *MockTimeService

NewMockTimeService creates a new mock instance.

func (*MockTimeService) EXPECT 

func (m *MockTimeService) EXPECT() *MockTimeServiceMockRecorder

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

func (*MockTimeService) Now 

func (m *MockTimeService) Now() time.Time

Now mocks base method.

type MockTimeServiceMockRecorder 

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

MockTimeServiceMockRecorder is the mock recorder for MockTimeService.

func (*MockTimeServiceMockRecorder) Now 

func (mr *MockTimeServiceMockRecorder) Now() *gomock.Call

Now indicates an expected call of Now.

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.