mock_timeline

Dec 16, 2024

Changes in this version

+ type MockKeeper struct

+ func NewMockKeeper(ctrl *gomock.Controller) *MockKeeper

+ func (m *MockKeeper) EXPECT() *MockKeeperMockRecorder

+ func (m *MockKeeper) GetCurrentSubs(ctx context.Context) []string

+ func (m *MockKeeper) GetMetrics() map[string]int64

+ func (m *MockKeeper) GetRemoteSubs() []string

+ func (m *MockKeeper) Start(ctx context.Context)

+ type MockKeeperMockRecorder struct

+ func (mr *MockKeeperMockRecorder) GetCurrentSubs(ctx any) *gomock.Call

+ func (mr *MockKeeperMockRecorder) GetMetrics() *gomock.Call

+ func (mr *MockKeeperMockRecorder) GetRemoteSubs() *gomock.Call

+ func (mr *MockKeeperMockRecorder) Start(ctx any) *gomock.Call

+ type MockRepository struct

+ func NewMockRepository(ctrl *gomock.Controller) *MockRepository

+ func (m *MockRepository) Count(ctx context.Context) (int64, error)

+ func (m *MockRepository) CreateItem(ctx context.Context, item core.TimelineItem) (core.TimelineItem, error)

+ func (m *MockRepository) DeleteItem(ctx context.Context, timelineID, objectID string) error

+ func (m *MockRepository) DeleteItemByResourceID(ctx context.Context, resourceID string) error

+ func (m *MockRepository) DeleteTimeline(ctx context.Context, key string) error

+ func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder

+ func (m *MockRepository) GetImmediateItems(ctx context.Context, timelineID string, since time.Time, limit int) ([]core.TimelineItem, error)

+ func (m *MockRepository) GetItem(ctx context.Context, timelineID, objectID string) (core.TimelineItem, error)

+ func (m *MockRepository) GetMetrics() map[string]int64

+ func (m *MockRepository) GetNormalizationCache(ctx context.Context, timelineID string) (string, error)

+ func (m *MockRepository) GetRecentItems(ctx context.Context, timelineID string, until time.Time, limit int) ([]core.TimelineItem, error)

+ func (m *MockRepository) GetTimeline(ctx context.Context, key string) (core.Timeline, error)

+ func (m *MockRepository) GetTimelineFromRemote(ctx context.Context, host, key string) (core.Timeline, error)

+ func (m *MockRepository) ListRecentlyRemovedItems(ctx context.Context, normalized []string) (map[string][]string, error)

+ func (m *MockRepository) ListRecentlyRemovedItemsLocal(ctx context.Context, timelineIDs []string) (map[string][]string, error)

+ func (m *MockRepository) ListTimelineByAuthor(ctx context.Context, author string) ([]core.Timeline, error)

+ func (m *MockRepository) ListTimelineByAuthorOwned(ctx context.Context, author string) ([]core.Timeline, error)

+ func (m *MockRepository) ListTimelineBySchema(ctx context.Context, schema string) ([]core.Timeline, error)

+ func (m *MockRepository) ListTimelineSubscriptions(ctx context.Context) (map[string]int64, error)

+ func (m *MockRepository) LoadChunkBodies(ctx context.Context, query map[string]string) (map[string]core.Chunk, error)

+ func (m *MockRepository) LookupChunkItrs(ctx context.Context, timelines []string, epoch string) (map[string]string, error)

+ func (m *MockRepository) PublishEvent(ctx context.Context, event core.Event) error

+ func (m *MockRepository) Query(ctx context.Context, timelineID, schema, owner, author string, until time.Time, ...) ([]core.TimelineItem, error)

+ func (m *MockRepository) SetNormalizationCache(ctx context.Context, timelineID, value string) error

+ func (m *MockRepository) Subscribe(ctx context.Context, channels []string, event chan<- core.Event) error

+ func (m *MockRepository) UpsertTimeline(ctx context.Context, timeline core.Timeline) (core.Timeline, error)

+ type MockRepositoryMockRecorder struct

+ func (mr *MockRepositoryMockRecorder) Count(ctx any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) CreateItem(ctx, item any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) DeleteItem(ctx, timelineID, objectID any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) DeleteItemByResourceID(ctx, resourceID any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) DeleteTimeline(ctx, key any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetImmediateItems(ctx, timelineID, since, limit any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetItem(ctx, timelineID, objectID any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetMetrics() *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetNormalizationCache(ctx, timelineID any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetRecentItems(ctx, timelineID, until, limit any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetTimeline(ctx, key any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) GetTimelineFromRemote(ctx, host, key any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListRecentlyRemovedItems(ctx, normalized any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListRecentlyRemovedItemsLocal(ctx, timelineIDs any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListTimelineByAuthor(ctx, author any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListTimelineByAuthorOwned(ctx, author any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListTimelineBySchema(ctx, schema any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) ListTimelineSubscriptions(ctx any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) LoadChunkBodies(ctx, query any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) LookupChunkItrs(ctx, timelines, epoch any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) PublishEvent(ctx, event any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) Query(ctx, timelineID, schema, owner, author, until, limit any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) SetNormalizationCache(ctx, timelineID, value any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) Subscribe(ctx, channels, event any) *gomock.Call

+ func (mr *MockRepositoryMockRecorder) UpsertTimeline(ctx, timeline any) *gomock.Call