mocks

package
v0.1.7 Latest Latest
Warning

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

Go to latest
Published: Aug 29, 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.

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 MockCleanupService added in v0.1.4

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

MockCleanupService is a mock of CleanupService interface.

func NewMockCleanupService added in v0.1.4

func NewMockCleanupService(ctrl *gomock.Controller) *MockCleanupService

NewMockCleanupService creates a new mock instance.

func (*MockCleanupService) CleanupDoneQueue added in v0.1.4

func (m *MockCleanupService) CleanupDoneQueue(ctx context.Context, f *models.Flow, sink *models.Sink, doneQueueCleanupDelay time.Duration) (int, error)

CleanupDoneQueue mocks base method.

func (*MockCleanupService) EXPECT added in v0.1.4

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

type MockCleanupServiceMockRecorder added in v0.1.4

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

MockCleanupServiceMockRecorder is the mock recorder for MockCleanupService.

func (*MockCleanupServiceMockRecorder) CleanupDoneQueue added in v0.1.4

func (mr *MockCleanupServiceMockRecorder) CleanupDoneQueue(ctx, f, sink, doneQueueCleanupDelay interface{}) *gomock.Call

CleanupDoneQueue indicates an expected call of CleanupDoneQueue.

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

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

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

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

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) ([]*models.QueuedInfo, 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

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

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 MockMessageVerifier added in v0.1.6

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

MockMessageVerifier is a mock of MessageVerifier interface.

func NewMockMessageVerifier added in v0.1.6

func NewMockMessageVerifier(ctrl *gomock.Controller) *MockMessageVerifier

NewMockMessageVerifier creates a new mock instance.

func (*MockMessageVerifier) EXPECT added in v0.1.6

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

func (*MockMessageVerifier) Verify added in v0.1.6

func (m_2 *MockMessageVerifier) Verify(flow *models.Flow, m *models.Message) error

Verify mocks base method.

type MockMessageVerifierMockRecorder added in v0.1.6

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

MockMessageVerifierMockRecorder is the mock recorder for MockMessageVerifier.

func (*MockMessageVerifierMockRecorder) Verify added in v0.1.6

func (mr *MockMessageVerifierMockRecorder) Verify(flow, m interface{}) *gomock.Call

Verify indicates an expected call of Verify.

type MockProcessingRecoveryService added in v0.1.3

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

MockProcessingRecoveryService is a mock of ProcessingRecoveryService interface.

func NewMockProcessingRecoveryService added in v0.1.3

func NewMockProcessingRecoveryService(ctrl *gomock.Controller) *MockProcessingRecoveryService

NewMockProcessingRecoveryService creates a new mock instance.

func (*MockProcessingRecoveryService) AddToCache added in v0.1.3

func (m *MockProcessingRecoveryService) AddToCache(mID string, ttl time.Duration)

AddToCache mocks base method.

func (*MockProcessingRecoveryService) EXPECT added in v0.1.3

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

func (*MockProcessingRecoveryService) MoveProcessingToReady added in v0.1.3

func (m *MockProcessingRecoveryService) MoveProcessingToReady(ctx context.Context, flow *models.Flow, sink *models.Sink, processingRecoveryInterval time.Duration) ([]string, error)

MoveProcessingToReady mocks base method.

type MockProcessingRecoveryServiceMockRecorder added in v0.1.3

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

MockProcessingRecoveryServiceMockRecorder is the mock recorder for MockProcessingRecoveryService.

func (*MockProcessingRecoveryServiceMockRecorder) AddToCache added in v0.1.3

func (mr *MockProcessingRecoveryServiceMockRecorder) AddToCache(mID, ttl interface{}) *gomock.Call

AddToCache indicates an expected call of AddToCache.

func (*MockProcessingRecoveryServiceMockRecorder) MoveProcessingToReady added in v0.1.3

func (mr *MockProcessingRecoveryServiceMockRecorder) MoveProcessingToReady(ctx, flow, sink, processingRecoveryInterval interface{}) *gomock.Call

MoveProcessingToReady indicates an expected call of MoveProcessingToReady.

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

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.QueuedInfo, error)

HandleFailed mocks base method.

func (*MockProcessingResultsService) HandleOK

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

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) LRangeAll added in v0.1.3

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

LRangeAll mocks base method.

func (*MockRedisStore) LRemRPush added in v0.1.3

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

LRemRPush 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) ZRemDel added in v0.1.4

func (m *MockRedisStore) ZRemDel(ctx context.Context, queueKey string, messageIDs, messageKeys []string) error

ZRemDel mocks base method.

func (*MockRedisStore) ZRemRangeBelowScore added in v0.1.4

func (m *MockRedisStore) ZRemRangeBelowScore(ctx context.Context, queueKey string, maxScore int) (int, error)

ZRemRangeBelowScore 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) LRangeAll added in v0.1.3

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

LRangeAll indicates an expected call of LRangeAll.

func (*MockRedisStoreMockRecorder) LRemRPush added in v0.1.3

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

LRemRPush indicates an expected call of LRemRPush.

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) ZRemDel added in v0.1.4

func (mr *MockRedisStoreMockRecorder) ZRemDel(ctx, queueKey, messageIDs, messageKeys interface{}) *gomock.Call

ZRemDel indicates an expected call of ZRemDel.

func (*MockRedisStoreMockRecorder) ZRemRangeBelowScore added in v0.1.4

func (mr *MockRedisStoreMockRecorder) ZRemRangeBelowScore(ctx, queueKey, maxScore interface{}) *gomock.Call

ZRemRangeBelowScore indicates an expected call of ZRemRangeBelowScore.

func (*MockRedisStoreMockRecorder) ZRemRpush

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

ZRemRpush indicates an expected call of ZRemRpush.

type MockRetryCalculator added in v0.1.3

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

MockRetryCalculator is a mock of RetryCalculator interface.

func NewMockRetryCalculator added in v0.1.3

func NewMockRetryCalculator(ctrl *gomock.Controller) *MockRetryCalculator

NewMockRetryCalculator creates a new mock instance.

func (*MockRetryCalculator) EXPECT added in v0.1.3

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

func (*MockRetryCalculator) NextAttemptInterval added in v0.1.3

func (m *MockRetryCalculator) NextAttemptInterval(attemptsCount int, retryInterval *time.Duration, retryExpMultiplier *float64) time.Duration

NextAttemptInterval mocks base method.

type MockRetryCalculatorMockRecorder added in v0.1.3

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

MockRetryCalculatorMockRecorder is the mock recorder for MockRetryCalculator.

func (*MockRetryCalculatorMockRecorder) NextAttemptInterval added in v0.1.3

func (mr *MockRetryCalculatorMockRecorder) NextAttemptInterval(attemptsCount, retryInterval, retryExpMultiplier interface{}) *gomock.Call

NextAttemptInterval indicates an expected call of NextAttemptInterval.

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

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

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

Now indicates an expected call of Now.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL