mocks

package
v0.1.14 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2026 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.

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) CleanupDeadQueue added in v0.1.14 

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

CleanupDeadQueue mocks base method.

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 

func (m *MockCleanupService) EXPECT() *MockCleanupServiceMockRecorder

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) CleanupDeadQueue added in v0.1.14 

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

CleanupDeadQueue indicates an expected call of CleanupDeadQueue.

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 

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) GetTransformDefinition added in v0.1.9 

func (m *MockInhooksConfigService) GetTransformDefinition(transformID string) *models.TransformDefinition

GetTransformDefinition 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) GetTransformDefinition added in v0.1.9 

func (mr *MockInhooksConfigServiceMockRecorder) GetTransformDefinition(transformID interface{}) *gomock.Call

GetTransformDefinition indicates an expected call of GetTransformDefinition.

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) ([]*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 

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 MockMessageTransformer added in v0.1.9 

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

MockMessageTransformer is a mock of MessageTransformer interface.

func NewMockMessageTransformer added in v0.1.9 

func NewMockMessageTransformer(ctrl *gomock.Controller) *MockMessageTransformer

NewMockMessageTransformer creates a new mock instance.

func (*MockMessageTransformer) EXPECT added in v0.1.9 

func (m *MockMessageTransformer) EXPECT() *MockMessageTransformerMockRecorder

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

func (*MockMessageTransformer) Transform added in v0.1.9 

func (m_2 *MockMessageTransformer) Transform(ctx context.Context, transformDefinition *models.TransformDefinition, m *models.Message) error

Transform mocks base method.

type MockMessageTransformerMockRecorder added in v0.1.9 

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

MockMessageTransformerMockRecorder is the mock recorder for MockMessageTransformer.

func (*MockMessageTransformerMockRecorder) Transform added in v0.1.9 

func (mr *MockMessageTransformerMockRecorder) Transform(ctx, transformDefinition, m interface{}) *gomock.Call

Transform indicates an expected call of Transform.

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 

func (m *MockMessageVerifier) EXPECT() *MockMessageVerifierMockRecorder

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 

func (m *MockProcessingRecoveryService) EXPECT() *MockProcessingRecoveryServiceMockRecorder

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 

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

HandleFailed mocks base method.

func (*MockProcessingResultsService) HandleOK 

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

HandleOK mocks base method.

func (*MockProcessingResultsService) RescheduleForRateLimit added in v0.1.14 

func (m_2 *MockProcessingResultsService) RescheduleForRateLimit(ctx context.Context, sink *models.Sink, m *models.Message, delay time.Duration) (*models.QueuedInfo, error)

RescheduleForRateLimit 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.

func (*MockProcessingResultsServiceMockRecorder) RescheduleForRateLimit added in v0.1.14 

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

RescheduleForRateLimit indicates an expected call of RescheduleForRateLimit.

type MockQueueMetricsService added in v0.1.14 

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

MockQueueMetricsService is a mock of QueueMetricsService interface.

func NewMockQueueMetricsService added in v0.1.14 

func NewMockQueueMetricsService(ctrl *gomock.Controller) *MockQueueMetricsService

NewMockQueueMetricsService creates a new mock instance.

func (*MockQueueMetricsService) EXPECT added in v0.1.14 

func (m *MockQueueMetricsService) EXPECT() *MockQueueMetricsServiceMockRecorder

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

func (*MockQueueMetricsService) UpdateMetrics added in v0.1.14 

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

UpdateMetrics mocks base method.

type MockQueueMetricsServiceMockRecorder added in v0.1.14 

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

MockQueueMetricsServiceMockRecorder is the mock recorder for MockQueueMetricsService.

func (*MockQueueMetricsServiceMockRecorder) UpdateMetrics added in v0.1.14 

func (mr *MockQueueMetricsServiceMockRecorder) UpdateMetrics(ctx, f, sink interface{}) *gomock.Call

UpdateMetrics indicates an expected call of UpdateMetrics.

type MockRateLimiter added in v0.1.14 

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

MockRateLimiter is a mock of RateLimiter interface.

func NewMockRateLimiter added in v0.1.14 

func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

NewMockRateLimiter creates a new mock instance.

func (*MockRateLimiter) Allow added in v0.1.14 

func (m *MockRateLimiter) Allow(ctx context.Context, key string, cfg *models.RateLimitConfig) models.RateLimitDecision

Allow mocks base method.

func (*MockRateLimiter) EXPECT added in v0.1.14 

func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

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

func (*MockRateLimiter) Peek added in v0.1.14 

func (m *MockRateLimiter) Peek(ctx context.Context, key string, cfg *models.RateLimitConfig) (float64, error)

Peek mocks base method.

type MockRateLimiterMockRecorder added in v0.1.14 

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

MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.

func (*MockRateLimiterMockRecorder) Allow added in v0.1.14 

func (mr *MockRateLimiterMockRecorder) Allow(ctx, key, cfg interface{}) *gomock.Call

Allow indicates an expected call of Allow.

func (*MockRateLimiterMockRecorder) Peek added in v0.1.14 

func (mr *MockRateLimiterMockRecorder) Peek(ctx, key, cfg interface{}) *gomock.Call

Peek indicates an expected call of Peek.

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) Eval added in v0.1.14 

func (m *MockRedisStore) Eval(ctx context.Context, script string, keys []string, args ...interface{}) ([]interface{}, error)

Eval mocks base method.

func (*MockRedisStore) Get 

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

Get mocks base method.

func (*MockRedisStore) LLen added in v0.1.14 

func (m *MockRedisStore) LLen(ctx context.Context, queueKey string) (int64, error)

LLen 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) LRemDel added in v0.1.14 

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

LRemDel 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) MultiGet added in v0.1.14 

func (m *MockRedisStore) MultiGet(ctx context.Context, keys []string) (map[string][]byte, error)

MultiGet 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) ZCard added in v0.1.14 

func (m *MockRedisStore) ZCard(ctx context.Context, queueKey string) (int64, error)

ZCard 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) Eval added in v0.1.14 

func (mr *MockRedisStoreMockRecorder) Eval(ctx, script, keys interface{}, args ...interface{}) *gomock.Call

Eval indicates an expected call of Eval.

func (*MockRedisStoreMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockRedisStoreMockRecorder) LLen added in v0.1.14 

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

LLen indicates an expected call of LLen.

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) LRemDel added in v0.1.14 

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

LRemDel indicates an expected call of LRemDel.

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) MultiGet added in v0.1.14 

func (mr *MockRedisStoreMockRecorder) MultiGet(ctx, keys interface{}) *gomock.Call

MultiGet indicates an expected call of MultiGet.

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) ZCard added in v0.1.14 

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

ZCard indicates an expected call of ZCard.

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 

func (m *MockRetryCalculator) EXPECT() *MockRetryCalculatorMockRecorder

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 

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.