Documentation ¶
Overview ¶
Package mock_timeline is a generated GoMock package.
Package mock_timeline is a generated GoMock package.
Index ¶
- type MockKeeper
- type MockKeeperMockRecorder
- type 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockKeeper ¶
type MockKeeper struct {
// contains filtered or unexported fields
}
MockKeeper is a mock of Keeper interface.
func NewMockKeeper ¶
func NewMockKeeper(ctrl *gomock.Controller) *MockKeeper
NewMockKeeper creates a new mock instance.
func (*MockKeeper) EXPECT ¶
func (m *MockKeeper) EXPECT() *MockKeeperMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKeeper) GetCurrentSubs ¶
func (m *MockKeeper) GetCurrentSubs(ctx context.Context) []string
GetCurrentSubs mocks base method.
func (*MockKeeper) GetMetrics ¶
func (m *MockKeeper) GetMetrics() map[string]int64
GetMetrics mocks base method.
func (*MockKeeper) GetRemoteSubs ¶
func (m *MockKeeper) GetRemoteSubs() []string
GetRemoteSubs mocks base method.
type MockKeeperMockRecorder ¶
type MockKeeperMockRecorder struct {
// contains filtered or unexported fields
}
MockKeeperMockRecorder is the mock recorder for MockKeeper.
func (*MockKeeperMockRecorder) GetCurrentSubs ¶
func (mr *MockKeeperMockRecorder) GetCurrentSubs(ctx any) *gomock.Call
GetCurrentSubs indicates an expected call of GetCurrentSubs.
func (*MockKeeperMockRecorder) GetMetrics ¶
func (mr *MockKeeperMockRecorder) GetMetrics() *gomock.Call
GetMetrics indicates an expected call of GetMetrics.
func (*MockKeeperMockRecorder) GetRemoteSubs ¶
func (mr *MockKeeperMockRecorder) GetRemoteSubs() *gomock.Call
GetRemoteSubs indicates an expected call of GetRemoteSubs.
type MockRepository ¶
type MockRepository struct {
// contains filtered or unexported fields
}
MockRepository is a mock of Repository interface.
func NewMockRepository ¶
func NewMockRepository(ctrl *gomock.Controller) *MockRepository
NewMockRepository creates a new mock instance.
func (*MockRepository) Count ¶
func (m *MockRepository) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockRepository) CreateItem ¶
func (m *MockRepository) CreateItem(ctx context.Context, item core.TimelineItem) (core.TimelineItem, error)
CreateItem mocks base method.
func (*MockRepository) DeleteItem ¶
func (m *MockRepository) DeleteItem(ctx context.Context, timelineID, objectID string) error
DeleteItem mocks base method.
func (*MockRepository) DeleteItemByResourceID ¶
func (m *MockRepository) DeleteItemByResourceID(ctx context.Context, resourceID string) error
DeleteItemByResourceID mocks base method.
func (*MockRepository) DeleteTimeline ¶
func (m *MockRepository) DeleteTimeline(ctx context.Context, key string) error
DeleteTimeline mocks base method.
func (*MockRepository) EXPECT ¶
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRepository) GetImmediateItems ¶
func (m *MockRepository) GetImmediateItems(ctx context.Context, timelineID string, since time.Time, limit int) ([]core.TimelineItem, error)
GetImmediateItems mocks base method.
func (*MockRepository) GetItem ¶
func (m *MockRepository) GetItem(ctx context.Context, timelineID, objectID string) (core.TimelineItem, error)
GetItem mocks base method.
func (*MockRepository) GetMetrics ¶
func (m *MockRepository) GetMetrics() map[string]int64
GetMetrics mocks base method.
func (*MockRepository) GetNormalizationCache ¶
func (m *MockRepository) GetNormalizationCache(ctx context.Context, timelineID string) (string, error)
GetNormalizationCache mocks base method.
func (*MockRepository) GetRecentItems ¶
func (m *MockRepository) GetRecentItems(ctx context.Context, timelineID string, until time.Time, limit int) ([]core.TimelineItem, error)
GetRecentItems mocks base method.
func (*MockRepository) GetTimeline ¶
GetTimeline mocks base method.
func (*MockRepository) GetTimelineFromRemote ¶
func (m *MockRepository) GetTimelineFromRemote(ctx context.Context, host, key string) (core.Timeline, error)
GetTimelineFromRemote mocks base method.
func (*MockRepository) ListRecentlyRemovedItems ¶
func (m *MockRepository) ListRecentlyRemovedItems(ctx context.Context, normalized []string) (map[string][]string, error)
ListRecentlyRemovedItems mocks base method.
func (*MockRepository) ListRecentlyRemovedItemsLocal ¶
func (m *MockRepository) ListRecentlyRemovedItemsLocal(ctx context.Context, timelineIDs []string) (map[string][]string, error)
ListRecentlyRemovedItemsLocal mocks base method.
func (*MockRepository) ListTimelineByAuthor ¶
func (m *MockRepository) ListTimelineByAuthor(ctx context.Context, author string) ([]core.Timeline, error)
ListTimelineByAuthor mocks base method.
func (*MockRepository) ListTimelineByAuthorOwned ¶
func (m *MockRepository) ListTimelineByAuthorOwned(ctx context.Context, author string) ([]core.Timeline, error)
ListTimelineByAuthorOwned mocks base method.
func (*MockRepository) ListTimelineBySchema ¶
func (m *MockRepository) ListTimelineBySchema(ctx context.Context, schema string) ([]core.Timeline, error)
ListTimelineBySchema mocks base method.
func (*MockRepository) ListTimelineSubscriptions ¶
ListTimelineSubscriptions mocks base method.
func (*MockRepository) LoadChunkBodies ¶
func (m *MockRepository) LoadChunkBodies(ctx context.Context, query map[string]string) (map[string]core.Chunk, error)
LoadChunkBodies mocks base method.
func (*MockRepository) LookupChunkItrs ¶
func (m *MockRepository) LookupChunkItrs(ctx context.Context, timelines []string, epoch string) (map[string]string, error)
LookupChunkItrs mocks base method.
func (*MockRepository) PublishEvent ¶
PublishEvent mocks base method.
func (*MockRepository) Query ¶
func (m *MockRepository) Query(ctx context.Context, timelineID, schema, owner, author string, until time.Time, limit int) ([]core.TimelineItem, error)
Query mocks base method.
func (*MockRepository) SetNormalizationCache ¶
func (m *MockRepository) SetNormalizationCache(ctx context.Context, timelineID, value string) error
SetNormalizationCache mocks base method.
func (*MockRepository) Subscribe ¶
func (m *MockRepository) Subscribe(ctx context.Context, channels []string, event chan<- core.Event) error
Subscribe mocks base method.
func (*MockRepository) UpsertTimeline ¶
func (m *MockRepository) UpsertTimeline(ctx context.Context, timeline core.Timeline) (core.Timeline, error)
UpsertTimeline mocks base method.
type MockRepositoryMockRecorder ¶
type MockRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockRepositoryMockRecorder is the mock recorder for MockRepository.
func (*MockRepositoryMockRecorder) Count ¶
func (mr *MockRepositoryMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockRepositoryMockRecorder) CreateItem ¶
func (mr *MockRepositoryMockRecorder) CreateItem(ctx, item any) *gomock.Call
CreateItem indicates an expected call of CreateItem.
func (*MockRepositoryMockRecorder) DeleteItem ¶
func (mr *MockRepositoryMockRecorder) DeleteItem(ctx, timelineID, objectID any) *gomock.Call
DeleteItem indicates an expected call of DeleteItem.
func (*MockRepositoryMockRecorder) DeleteItemByResourceID ¶
func (mr *MockRepositoryMockRecorder) DeleteItemByResourceID(ctx, resourceID any) *gomock.Call
DeleteItemByResourceID indicates an expected call of DeleteItemByResourceID.
func (*MockRepositoryMockRecorder) DeleteTimeline ¶
func (mr *MockRepositoryMockRecorder) DeleteTimeline(ctx, key any) *gomock.Call
DeleteTimeline indicates an expected call of DeleteTimeline.
func (*MockRepositoryMockRecorder) GetImmediateItems ¶
func (mr *MockRepositoryMockRecorder) GetImmediateItems(ctx, timelineID, since, limit any) *gomock.Call
GetImmediateItems indicates an expected call of GetImmediateItems.
func (*MockRepositoryMockRecorder) GetItem ¶
func (mr *MockRepositoryMockRecorder) GetItem(ctx, timelineID, objectID any) *gomock.Call
GetItem indicates an expected call of GetItem.
func (*MockRepositoryMockRecorder) GetMetrics ¶
func (mr *MockRepositoryMockRecorder) GetMetrics() *gomock.Call
GetMetrics indicates an expected call of GetMetrics.
func (*MockRepositoryMockRecorder) GetNormalizationCache ¶
func (mr *MockRepositoryMockRecorder) GetNormalizationCache(ctx, timelineID any) *gomock.Call
GetNormalizationCache indicates an expected call of GetNormalizationCache.
func (*MockRepositoryMockRecorder) GetRecentItems ¶
func (mr *MockRepositoryMockRecorder) GetRecentItems(ctx, timelineID, until, limit any) *gomock.Call
GetRecentItems indicates an expected call of GetRecentItems.
func (*MockRepositoryMockRecorder) GetTimeline ¶
func (mr *MockRepositoryMockRecorder) GetTimeline(ctx, key any) *gomock.Call
GetTimeline indicates an expected call of GetTimeline.
func (*MockRepositoryMockRecorder) GetTimelineFromRemote ¶
func (mr *MockRepositoryMockRecorder) GetTimelineFromRemote(ctx, host, key any) *gomock.Call
GetTimelineFromRemote indicates an expected call of GetTimelineFromRemote.
func (*MockRepositoryMockRecorder) ListRecentlyRemovedItems ¶
func (mr *MockRepositoryMockRecorder) ListRecentlyRemovedItems(ctx, normalized any) *gomock.Call
ListRecentlyRemovedItems indicates an expected call of ListRecentlyRemovedItems.
func (*MockRepositoryMockRecorder) ListRecentlyRemovedItemsLocal ¶
func (mr *MockRepositoryMockRecorder) ListRecentlyRemovedItemsLocal(ctx, timelineIDs any) *gomock.Call
ListRecentlyRemovedItemsLocal indicates an expected call of ListRecentlyRemovedItemsLocal.
func (*MockRepositoryMockRecorder) ListTimelineByAuthor ¶
func (mr *MockRepositoryMockRecorder) ListTimelineByAuthor(ctx, author any) *gomock.Call
ListTimelineByAuthor indicates an expected call of ListTimelineByAuthor.
func (*MockRepositoryMockRecorder) ListTimelineByAuthorOwned ¶
func (mr *MockRepositoryMockRecorder) ListTimelineByAuthorOwned(ctx, author any) *gomock.Call
ListTimelineByAuthorOwned indicates an expected call of ListTimelineByAuthorOwned.
func (*MockRepositoryMockRecorder) ListTimelineBySchema ¶
func (mr *MockRepositoryMockRecorder) ListTimelineBySchema(ctx, schema any) *gomock.Call
ListTimelineBySchema indicates an expected call of ListTimelineBySchema.
func (*MockRepositoryMockRecorder) ListTimelineSubscriptions ¶
func (mr *MockRepositoryMockRecorder) ListTimelineSubscriptions(ctx any) *gomock.Call
ListTimelineSubscriptions indicates an expected call of ListTimelineSubscriptions.
func (*MockRepositoryMockRecorder) LoadChunkBodies ¶
func (mr *MockRepositoryMockRecorder) LoadChunkBodies(ctx, query any) *gomock.Call
LoadChunkBodies indicates an expected call of LoadChunkBodies.
func (*MockRepositoryMockRecorder) LookupChunkItrs ¶
func (mr *MockRepositoryMockRecorder) LookupChunkItrs(ctx, timelines, epoch any) *gomock.Call
LookupChunkItrs indicates an expected call of LookupChunkItrs.
func (*MockRepositoryMockRecorder) PublishEvent ¶
func (mr *MockRepositoryMockRecorder) PublishEvent(ctx, event any) *gomock.Call
PublishEvent indicates an expected call of PublishEvent.
func (*MockRepositoryMockRecorder) Query ¶
func (mr *MockRepositoryMockRecorder) Query(ctx, timelineID, schema, owner, author, until, limit any) *gomock.Call
Query indicates an expected call of Query.
func (*MockRepositoryMockRecorder) SetNormalizationCache ¶
func (mr *MockRepositoryMockRecorder) SetNormalizationCache(ctx, timelineID, value any) *gomock.Call
SetNormalizationCache indicates an expected call of SetNormalizationCache.
func (*MockRepositoryMockRecorder) Subscribe ¶
func (mr *MockRepositoryMockRecorder) Subscribe(ctx, channels, event any) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockRepositoryMockRecorder) UpsertTimeline ¶
func (mr *MockRepositoryMockRecorder) UpsertTimeline(ctx, timeline any) *gomock.Call
UpsertTimeline indicates an expected call of UpsertTimeline.