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 ¶
- type MockCleanupService
- type MockCleanupServiceMockRecorder
- type MockInhooksConfigService
- func (m *MockInhooksConfigService) EXPECT() *MockInhooksConfigServiceMockRecorder
- func (m *MockInhooksConfigService) FindFlowForSource(sourceSlug string) *models.Flow
- func (m *MockInhooksConfigService) GetFlow(flowID string) *models.Flow
- func (m *MockInhooksConfigService) GetFlows() map[string]*models.Flow
- func (m *MockInhooksConfigService) Load(path string) error
- type MockInhooksConfigServiceMockRecorder
- func (mr *MockInhooksConfigServiceMockRecorder) FindFlowForSource(sourceSlug interface{}) *gomock.Call
- func (mr *MockInhooksConfigServiceMockRecorder) GetFlow(flowID interface{}) *gomock.Call
- func (mr *MockInhooksConfigServiceMockRecorder) GetFlows() *gomock.Call
- func (mr *MockInhooksConfigServiceMockRecorder) Load(path interface{}) *gomock.Call
- type MockMessageBuilder
- type MockMessageBuilderMockRecorder
- type MockMessageEnqueuer
- type MockMessageEnqueuerMockRecorder
- type MockMessageFetcher
- type MockMessageFetcherMockRecorder
- type MockMessageProcessor
- type MockMessageProcessorMockRecorder
- type MockMessageVerifier
- type MockMessageVerifierMockRecorder
- type MockProcessingRecoveryService
- func (m *MockProcessingRecoveryService) AddToCache(mID string, ttl time.Duration)
- func (m *MockProcessingRecoveryService) EXPECT() *MockProcessingRecoveryServiceMockRecorder
- func (m *MockProcessingRecoveryService) MoveProcessingToReady(ctx context.Context, flow *models.Flow, sink *models.Sink, ...) ([]string, error)
- type MockProcessingRecoveryServiceMockRecorder
- type MockProcessingResultsService
- func (m *MockProcessingResultsService) EXPECT() *MockProcessingResultsServiceMockRecorder
- func (m_2 *MockProcessingResultsService) HandleFailed(ctx context.Context, sink *models.Sink, m *models.Message, processingErr error) (*models.QueuedInfo, error)
- func (m_2 *MockProcessingResultsService) HandleOK(ctx context.Context, m *models.Message) error
- type MockProcessingResultsServiceMockRecorder
- type MockRedisStore
- func (m *MockRedisStore) BLMove(ctx context.Context, timeout time.Duration, ...) ([]byte, error)
- func (m *MockRedisStore) Dequeue(ctx context.Context, timeout time.Duration, key string) ([]byte, error)
- func (m *MockRedisStore) EXPECT() *MockRedisStoreMockRecorder
- func (m *MockRedisStore) Enqueue(ctx context.Context, key string, value []byte) error
- func (m *MockRedisStore) Get(ctx context.Context, messageKey string) ([]byte, error)
- func (m *MockRedisStore) LRangeAll(ctx context.Context, queueKey string) ([]string, error)
- func (m *MockRedisStore) LRemRPush(ctx context.Context, sourceQueueKey, destQueueKey string, messageIDs []string) error
- func (m *MockRedisStore) SetAndEnqueue(ctx context.Context, messageKey string, value []byte, ...) error
- func (m *MockRedisStore) SetAndMove(ctx context.Context, messageKey string, value []byte, ...) error
- func (m *MockRedisStore) SetAndZAdd(ctx context.Context, messageKey string, value []byte, ...) error
- func (m *MockRedisStore) SetLRemZAdd(ctx context.Context, messageKey string, value []byte, ...) error
- func (m *MockRedisStore) ZRangeBelowScore(ctx context.Context, queueKey string, score float64) ([]string, error)
- func (m *MockRedisStore) ZRemDel(ctx context.Context, queueKey string, messageIDs, messageKeys []string) error
- func (m *MockRedisStore) ZRemRangeBelowScore(ctx context.Context, queueKey string, maxScore int) (int, error)
- func (m *MockRedisStore) ZRemRpush(ctx context.Context, messageIDs []string, sourceQueueKey, destQueueKey string) error
- type MockRedisStoreMockRecorder
- func (mr *MockRedisStoreMockRecorder) BLMove(ctx, timeout, sourceQueueKey, destQueueKey interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) Dequeue(ctx, timeout, key interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) Enqueue(ctx, key, value interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) Get(ctx, messageKey interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) LRangeAll(ctx, queueKey interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) LRemRPush(ctx, sourceQueueKey, destQueueKey, messageIDs interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) SetAndEnqueue(ctx, messageKey, value, queueKey, messageID interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) SetAndMove(ctx, messageKey, value, sourceQueueKey, destQueueKey, messageID interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) SetAndZAdd(ctx, messageKey, value, queueKey, messageID, score interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) SetLRemZAdd(...) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) ZRangeBelowScore(ctx, queueKey, score interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) ZRemDel(ctx, queueKey, messageIDs, messageKeys interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) ZRemRangeBelowScore(ctx, queueKey, maxScore interface{}) *gomock.Call
- func (mr *MockRedisStoreMockRecorder) ZRemRpush(ctx, messageIDs, sourceQueueKey, destQueueKey interface{}) *gomock.Call
- type MockRetryCalculator
- type MockRetryCalculatorMockRecorder
- type MockSchedulerService
- type MockSchedulerServiceMockRecorder
- type MockTimeService
- type MockTimeServiceMockRecorder
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
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) 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) 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.
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.
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.
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
func (m *MockMessageVerifier) EXPECT() *MockMessageVerifierMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
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.
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.
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) 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.
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
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.
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 ¶
- mock_cleanup_service.go
- mock_inhooks_config_service.go
- mock_message_builder.go
- mock_message_enqueuer.go
- mock_message_fetcher.go
- mock_message_processor.go
- mock_message_verifier.go
- mock_processing_recovery_service.go
- mock_processing_results_service.go
- mock_redis_store.go
- mock_retry_calculator.go
- mock_scheduler_service.go
- mock_time_service.go