Documentation
¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockService
- func (m *MockService) AcquireBoundsLock(ctx context.Context, modelID string) (admin.BoundsLock, error)
- func (m *MockService) ConsolidateHistoricalData(ctx context.Context, modelID string) (uint64, error)
- func (m *MockService) EXPECT() *MockServiceMockRecorder
- func (m *MockService) FindGaps(ctx context.Context, modelID string, minPos, maxPos, interval uint64) ([]admin.GapInfo, error)
- func (m *MockService) GetAllLastScheduledExecutions(ctx context.Context, modelIDs []string) (map[string]*time.Time, error)
- func (m *MockService) GetAllProcessedRanges(ctx context.Context, modelIDs []string) (map[string][]admin.ProcessedRange, error)
- func (m *MockService) GetCoverage(ctx context.Context, modelID string, startPos, endPos uint64) (bool, error)
- func (m *MockService) GetExternalBounds(ctx context.Context, modelID string) (*admin.BoundsCache, error)
- func (m *MockService) GetFirstPosition(ctx context.Context, modelID string) (uint64, error)
- func (m *MockService) GetIncrementalAdminDatabase() string
- func (m *MockService) GetIncrementalAdminTable() string
- func (m *MockService) GetLastProcessedPosition(ctx context.Context, modelID string) (uint64, error)
- func (m *MockService) GetLastScheduledExecution(ctx context.Context, modelID string) (*time.Time, error)
- func (m *MockService) GetNextUnprocessedPosition(ctx context.Context, modelID string) (uint64, error)
- func (m *MockService) GetProcessedRanges(ctx context.Context, modelID string) ([]admin.ProcessedRange, error)
- func (m *MockService) GetScheduledAdminDatabase() string
- func (m *MockService) GetScheduledAdminTable() string
- func (m *MockService) RecordCompletion(ctx context.Context, modelID string, position, interval uint64) error
- func (m *MockService) RecordScheduledCompletion(ctx context.Context, modelID string, startDateTime time.Time) error
- func (m *MockService) SetExternalBounds(ctx context.Context, cache *admin.BoundsCache) error
- type MockServiceMockRecorder
- func (mr *MockServiceMockRecorder) AcquireBoundsLock(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) ConsolidateHistoricalData(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) FindGaps(ctx, modelID, minPos, maxPos, interval any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetAllLastScheduledExecutions(ctx, modelIDs any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetAllProcessedRanges(ctx, modelIDs any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetCoverage(ctx, modelID, startPos, endPos any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetExternalBounds(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetFirstPosition(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetIncrementalAdminDatabase() *gomock.Call
- func (mr *MockServiceMockRecorder) GetIncrementalAdminTable() *gomock.Call
- func (mr *MockServiceMockRecorder) GetLastProcessedPosition(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetLastScheduledExecution(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetNextUnprocessedPosition(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetProcessedRanges(ctx, modelID any) *gomock.Call
- func (mr *MockServiceMockRecorder) GetScheduledAdminDatabase() *gomock.Call
- func (mr *MockServiceMockRecorder) GetScheduledAdminTable() *gomock.Call
- func (mr *MockServiceMockRecorder) RecordCompletion(ctx, modelID, position, interval any) *gomock.Call
- func (mr *MockServiceMockRecorder) RecordScheduledCompletion(ctx, modelID, startDateTime any) *gomock.Call
- func (mr *MockServiceMockRecorder) SetExternalBounds(ctx, cache any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockService ¶
type MockService struct {
// contains filtered or unexported fields
}
MockService is a mock of Service interface.
func NewMockService ¶
func NewMockService(ctrl *gomock.Controller) *MockService
NewMockService creates a new mock instance.
func (*MockService) AcquireBoundsLock ¶ added in v0.0.54
func (m *MockService) AcquireBoundsLock(ctx context.Context, modelID string) (admin.BoundsLock, error)
AcquireBoundsLock mocks base method.
func (*MockService) ConsolidateHistoricalData ¶
func (m *MockService) ConsolidateHistoricalData(ctx context.Context, modelID string) (uint64, error)
ConsolidateHistoricalData mocks base method.
func (*MockService) EXPECT ¶
func (m *MockService) EXPECT() *MockServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockService) FindGaps ¶
func (m *MockService) FindGaps(ctx context.Context, modelID string, minPos, maxPos, interval uint64) ([]admin.GapInfo, error)
FindGaps mocks base method.
func (*MockService) GetAllLastScheduledExecutions ¶ added in v0.0.58
func (m *MockService) GetAllLastScheduledExecutions(ctx context.Context, modelIDs []string) (map[string]*time.Time, error)
GetAllLastScheduledExecutions mocks base method.
func (*MockService) GetAllProcessedRanges ¶ added in v0.0.58
func (m *MockService) GetAllProcessedRanges(ctx context.Context, modelIDs []string) (map[string][]admin.ProcessedRange, error)
GetAllProcessedRanges mocks base method.
func (*MockService) GetCoverage ¶
func (m *MockService) GetCoverage(ctx context.Context, modelID string, startPos, endPos uint64) (bool, error)
GetCoverage mocks base method.
func (*MockService) GetExternalBounds ¶
func (m *MockService) GetExternalBounds(ctx context.Context, modelID string) (*admin.BoundsCache, error)
GetExternalBounds mocks base method.
func (*MockService) GetFirstPosition ¶
GetFirstPosition mocks base method.
func (*MockService) GetIncrementalAdminDatabase ¶
func (m *MockService) GetIncrementalAdminDatabase() string
GetIncrementalAdminDatabase mocks base method.
func (*MockService) GetIncrementalAdminTable ¶
func (m *MockService) GetIncrementalAdminTable() string
GetIncrementalAdminTable mocks base method.
func (*MockService) GetLastProcessedPosition ¶
GetLastProcessedPosition mocks base method.
func (*MockService) GetLastScheduledExecution ¶
func (m *MockService) GetLastScheduledExecution(ctx context.Context, modelID string) (*time.Time, error)
GetLastScheduledExecution mocks base method.
func (*MockService) GetNextUnprocessedPosition ¶
func (m *MockService) GetNextUnprocessedPosition(ctx context.Context, modelID string) (uint64, error)
GetNextUnprocessedPosition mocks base method.
func (*MockService) GetProcessedRanges ¶
func (m *MockService) GetProcessedRanges(ctx context.Context, modelID string) ([]admin.ProcessedRange, error)
GetProcessedRanges mocks base method.
func (*MockService) GetScheduledAdminDatabase ¶
func (m *MockService) GetScheduledAdminDatabase() string
GetScheduledAdminDatabase mocks base method.
func (*MockService) GetScheduledAdminTable ¶
func (m *MockService) GetScheduledAdminTable() string
GetScheduledAdminTable mocks base method.
func (*MockService) RecordCompletion ¶
func (m *MockService) RecordCompletion(ctx context.Context, modelID string, position, interval uint64) error
RecordCompletion mocks base method.
func (*MockService) RecordScheduledCompletion ¶
func (m *MockService) RecordScheduledCompletion(ctx context.Context, modelID string, startDateTime time.Time) error
RecordScheduledCompletion mocks base method.
func (*MockService) SetExternalBounds ¶
func (m *MockService) SetExternalBounds(ctx context.Context, cache *admin.BoundsCache) error
SetExternalBounds mocks base method.
type MockServiceMockRecorder ¶
type MockServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockServiceMockRecorder is the mock recorder for MockService.
func (*MockServiceMockRecorder) AcquireBoundsLock ¶ added in v0.0.54
func (mr *MockServiceMockRecorder) AcquireBoundsLock(ctx, modelID any) *gomock.Call
AcquireBoundsLock indicates an expected call of AcquireBoundsLock.
func (*MockServiceMockRecorder) ConsolidateHistoricalData ¶
func (mr *MockServiceMockRecorder) ConsolidateHistoricalData(ctx, modelID any) *gomock.Call
ConsolidateHistoricalData indicates an expected call of ConsolidateHistoricalData.
func (*MockServiceMockRecorder) FindGaps ¶
func (mr *MockServiceMockRecorder) FindGaps(ctx, modelID, minPos, maxPos, interval any) *gomock.Call
FindGaps indicates an expected call of FindGaps.
func (*MockServiceMockRecorder) GetAllLastScheduledExecutions ¶ added in v0.0.58
func (mr *MockServiceMockRecorder) GetAllLastScheduledExecutions(ctx, modelIDs any) *gomock.Call
GetAllLastScheduledExecutions indicates an expected call of GetAllLastScheduledExecutions.
func (*MockServiceMockRecorder) GetAllProcessedRanges ¶ added in v0.0.58
func (mr *MockServiceMockRecorder) GetAllProcessedRanges(ctx, modelIDs any) *gomock.Call
GetAllProcessedRanges indicates an expected call of GetAllProcessedRanges.
func (*MockServiceMockRecorder) GetCoverage ¶
func (mr *MockServiceMockRecorder) GetCoverage(ctx, modelID, startPos, endPos any) *gomock.Call
GetCoverage indicates an expected call of GetCoverage.
func (*MockServiceMockRecorder) GetExternalBounds ¶
func (mr *MockServiceMockRecorder) GetExternalBounds(ctx, modelID any) *gomock.Call
GetExternalBounds indicates an expected call of GetExternalBounds.
func (*MockServiceMockRecorder) GetFirstPosition ¶
func (mr *MockServiceMockRecorder) GetFirstPosition(ctx, modelID any) *gomock.Call
GetFirstPosition indicates an expected call of GetFirstPosition.
func (*MockServiceMockRecorder) GetIncrementalAdminDatabase ¶
func (mr *MockServiceMockRecorder) GetIncrementalAdminDatabase() *gomock.Call
GetIncrementalAdminDatabase indicates an expected call of GetIncrementalAdminDatabase.
func (*MockServiceMockRecorder) GetIncrementalAdminTable ¶
func (mr *MockServiceMockRecorder) GetIncrementalAdminTable() *gomock.Call
GetIncrementalAdminTable indicates an expected call of GetIncrementalAdminTable.
func (*MockServiceMockRecorder) GetLastProcessedPosition ¶
func (mr *MockServiceMockRecorder) GetLastProcessedPosition(ctx, modelID any) *gomock.Call
GetLastProcessedPosition indicates an expected call of GetLastProcessedPosition.
func (*MockServiceMockRecorder) GetLastScheduledExecution ¶
func (mr *MockServiceMockRecorder) GetLastScheduledExecution(ctx, modelID any) *gomock.Call
GetLastScheduledExecution indicates an expected call of GetLastScheduledExecution.
func (*MockServiceMockRecorder) GetNextUnprocessedPosition ¶
func (mr *MockServiceMockRecorder) GetNextUnprocessedPosition(ctx, modelID any) *gomock.Call
GetNextUnprocessedPosition indicates an expected call of GetNextUnprocessedPosition.
func (*MockServiceMockRecorder) GetProcessedRanges ¶
func (mr *MockServiceMockRecorder) GetProcessedRanges(ctx, modelID any) *gomock.Call
GetProcessedRanges indicates an expected call of GetProcessedRanges.
func (*MockServiceMockRecorder) GetScheduledAdminDatabase ¶
func (mr *MockServiceMockRecorder) GetScheduledAdminDatabase() *gomock.Call
GetScheduledAdminDatabase indicates an expected call of GetScheduledAdminDatabase.
func (*MockServiceMockRecorder) GetScheduledAdminTable ¶
func (mr *MockServiceMockRecorder) GetScheduledAdminTable() *gomock.Call
GetScheduledAdminTable indicates an expected call of GetScheduledAdminTable.
func (*MockServiceMockRecorder) RecordCompletion ¶
func (mr *MockServiceMockRecorder) RecordCompletion(ctx, modelID, position, interval any) *gomock.Call
RecordCompletion indicates an expected call of RecordCompletion.
func (*MockServiceMockRecorder) RecordScheduledCompletion ¶
func (mr *MockServiceMockRecorder) RecordScheduledCompletion(ctx, modelID, startDateTime any) *gomock.Call
RecordScheduledCompletion indicates an expected call of RecordScheduledCompletion.
func (*MockServiceMockRecorder) SetExternalBounds ¶
func (mr *MockServiceMockRecorder) SetExternalBounds(ctx, cache any) *gomock.Call
SetExternalBounds indicates an expected call of SetExternalBounds.