mock

package

Go to main page

Versions in this module

v0

v0.1.6

Jun 10, 2026

v0.1.5

Jun 4, 2026

v0.1.4

Mar 3, 2026

v0.1.3

Feb 27, 2026

v0.1.2

Feb 20, 2026

v0.1.1

Feb 20, 2026

v0.1.0

Feb 19, 2026

Changes in this version

type MockService

+ func (m *MockService) DeleteAllConfigOverrides(ctx context.Context) error

+ func (m *MockService) DeleteConfigOverride(ctx context.Context, modelID string) error

+ func (m *MockService) DeleteExternalBounds(ctx context.Context, modelID string) error

+ func (m *MockService) DeletePeriod(ctx context.Context, modelID string, startPos, endPos uint64) (uint64, error)

+ func (m *MockService) GetAllConfigOverrides(ctx context.Context) ([]admin.ConfigOverride, error)

+ func (m *MockService) GetCacheManager() *admin.CacheManager

+ func (m *MockService) GetConfigOverride(ctx context.Context, modelID string) (*admin.ConfigOverride, error)

+ func (m *MockService) GetConfigOverrideVersion(ctx context.Context) (int64, error)

+ func (m *MockService) SetConfigOverride(ctx context.Context, override *admin.ConfigOverride) error

type MockServiceMockRecorder

+ func (mr *MockServiceMockRecorder) DeleteAllConfigOverrides(ctx any) *gomock.Call

+ func (mr *MockServiceMockRecorder) DeleteConfigOverride(ctx, modelID any) *gomock.Call

+ func (mr *MockServiceMockRecorder) DeleteExternalBounds(ctx, modelID any) *gomock.Call

+ func (mr *MockServiceMockRecorder) DeletePeriod(ctx, modelID, startPos, endPos any) *gomock.Call

+ func (mr *MockServiceMockRecorder) GetAllConfigOverrides(ctx any) *gomock.Call

+ func (mr *MockServiceMockRecorder) GetCacheManager() *gomock.Call

+ func (mr *MockServiceMockRecorder) GetConfigOverride(ctx, modelID any) *gomock.Call

+ func (mr *MockServiceMockRecorder) GetConfigOverrideVersion(ctx any) *gomock.Call

+ func (mr *MockServiceMockRecorder) SetConfigOverride(ctx, override any) *gomock.Call

v0.0.58

Feb 10, 2026

Changes in this version

type MockService

+ 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)

type MockServiceMockRecorder

+ func (mr *MockServiceMockRecorder) GetAllLastScheduledExecutions(ctx, modelIDs any) *gomock.Call

+ func (mr *MockServiceMockRecorder) GetAllProcessedRanges(ctx, modelIDs any) *gomock.Call

v0.0.57

Jan 30, 2026

v0.0.56

Jan 23, 2026

v0.0.55

Jan 21, 2026

v0.0.54

Jan 21, 2026

Changes in this version

type MockService

+ func (m *MockService) AcquireBoundsLock(ctx context.Context, modelID string) (admin.BoundsLock, error)

type MockServiceMockRecorder

+ func (mr *MockServiceMockRecorder) AcquireBoundsLock(ctx, modelID any) *gomock.Call

v0.0.53

Dec 11, 2025

v0.0.52

Dec 11, 2025

v0.0.51

Dec 4, 2025

Changes in this version

+ type MockService struct

+ func NewMockService(ctrl *gomock.Controller) *MockService

+ func (m *MockService) ConsolidateHistoricalData(ctx context.Context, modelID string) (int, 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) 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 struct

+ func (mr *MockServiceMockRecorder) ConsolidateHistoricalData(ctx, modelID any) *gomock.Call

+ func (mr *MockServiceMockRecorder) FindGaps(ctx, modelID, minPos, maxPos, interval 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

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