Documentation
¶
Overview ¶
Package mock_core is a generated GoMock package.
Index ¶
- type MockAckService
- func (m *MockAckService) Ack(ctx context.Context, mode core.CommitMode, document, signature string) (core.Ack, error)
- func (m *MockAckService) EXPECT() *MockAckServiceMockRecorder
- func (m *MockAckService) GetAcker(ctx context.Context, key string) ([]core.Ack, error)
- func (m *MockAckService) GetAcking(ctx context.Context, key string) ([]core.Ack, error)
- type MockAckServiceMockRecorder
- type MockAgentService
- type MockAgentServiceMockRecorder
- type MockAssociationService
- func (m *MockAssociationService) Clean(ctx context.Context, ccid string) error
- func (m *MockAssociationService) Count(ctx context.Context) (int64, error)
- func (m *MockAssociationService) Create(ctx context.Context, mode core.CommitMode, document, signature string) (core.Association, []string, error)
- func (m *MockAssociationService) Delete(ctx context.Context, mode core.CommitMode, document, signature string) (core.Association, []string, error)
- func (m *MockAssociationService) EXPECT() *MockAssociationServiceMockRecorder
- func (m *MockAssociationService) Get(ctx context.Context, id string) (core.Association, error)
- func (m *MockAssociationService) GetBySchema(ctx context.Context, messageID, schema string) ([]core.Association, error)
- func (m *MockAssociationService) GetBySchemaAndVariant(ctx context.Context, messageID, schema, variant string) ([]core.Association, error)
- func (m *MockAssociationService) GetByTarget(ctx context.Context, targetID string) ([]core.Association, error)
- func (m *MockAssociationService) GetCountsBySchema(ctx context.Context, messageID string) (map[string]int64, error)
- func (m *MockAssociationService) GetCountsBySchemaAndVariant(ctx context.Context, messageID, schema string) (map[string]int64, error)
- func (m *MockAssociationService) GetOwn(ctx context.Context, author string) ([]core.Association, error)
- func (m *MockAssociationService) GetOwnByTarget(ctx context.Context, targetID, author string) ([]core.Association, error)
- type MockAssociationServiceMockRecorder
- func (mr *MockAssociationServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) Count(ctx any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) Create(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) Delete(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) Get(ctx, id any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetBySchema(ctx, messageID, schema any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetBySchemaAndVariant(ctx, messageID, schema, variant any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetByTarget(ctx, targetID any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetCountsBySchema(ctx, messageID any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetCountsBySchemaAndVariant(ctx, messageID, schema any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetOwn(ctx, author any) *gomock.Call
- func (mr *MockAssociationServiceMockRecorder) GetOwnByTarget(ctx, targetID, author any) *gomock.Call
- type MockAuthService
- func (m *MockAuthService) EXPECT() *MockAuthServiceMockRecorder
- func (m *MockAuthService) IdentifyIdentity(next echo.HandlerFunc) echo.HandlerFunc
- func (m *MockAuthService) IssuePassport(ctx context.Context, requester string, key []core.Key) (string, error)
- func (m *MockAuthService) RateLimiter(configMap core.RateLimitConfigMap) echo.MiddlewareFunc
- type MockAuthServiceMockRecorder
- type MockDomainService
- func (m *MockDomainService) Delete(ctx context.Context, id string) error
- func (m *MockDomainService) EXPECT() *MockDomainServiceMockRecorder
- func (m *MockDomainService) ForceFetch(ctx context.Context, fqdn string) (core.Domain, error)
- func (m *MockDomainService) Get(ctx context.Context, key string) (core.Domain, error)
- func (m *MockDomainService) GetByCCID(ctx context.Context, key string) (core.Domain, error)
- func (m *MockDomainService) GetByFQDN(ctx context.Context, key string) (core.Domain, error)
- func (m *MockDomainService) List(ctx context.Context) ([]core.Domain, error)
- func (m *MockDomainService) Update(ctx context.Context, host core.Domain) error
- func (m *MockDomainService) UpdateScrapeTime(ctx context.Context, id string, scrapeTime time.Time) error
- func (m *MockDomainService) Upsert(ctx context.Context, host core.Domain) (core.Domain, error)
- type MockDomainServiceMockRecorder
- func (mr *MockDomainServiceMockRecorder) Delete(ctx, id any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) ForceFetch(ctx, fqdn any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) Get(ctx, key any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) GetByCCID(ctx, key any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) GetByFQDN(ctx, key any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) List(ctx any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) Update(ctx, host any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) UpdateScrapeTime(ctx, id, scrapeTime any) *gomock.Call
- func (mr *MockDomainServiceMockRecorder) Upsert(ctx, host any) *gomock.Call
- type MockEntityService
- func (m *MockEntityService) Affiliation(ctx context.Context, mode core.CommitMode, document, signature, meta string) (core.Entity, error)
- func (m *MockEntityService) Clean(ctx context.Context, ccid string) error
- func (m *MockEntityService) Count(ctx context.Context) (int64, error)
- func (m *MockEntityService) Delete(ctx context.Context, id string) error
- func (m *MockEntityService) EXPECT() *MockEntityServiceMockRecorder
- func (m *MockEntityService) Get(ctx context.Context, ccid string) (core.Entity, error)
- func (m *MockEntityService) GetByAlias(ctx context.Context, alias string) (core.Entity, error)
- func (m *MockEntityService) GetMeta(ctx context.Context, ccid string) (core.EntityMeta, error)
- func (m *MockEntityService) GetWithHint(ctx context.Context, ccid, hint string) (core.Entity, error)
- func (m *MockEntityService) IsUserExists(ctx context.Context, user string) bool
- func (m *MockEntityService) List(ctx context.Context) ([]core.Entity, error)
- func (m *MockEntityService) PullEntityFromRemote(ctx context.Context, id, domain string) (core.Entity, error)
- func (m *MockEntityService) Tombstone(ctx context.Context, mode core.CommitMode, document, signature string) (core.Entity, error)
- func (m *MockEntityService) UpdateScore(ctx context.Context, id string, score int) error
- func (m *MockEntityService) UpdateTag(ctx context.Context, id, tag string) error
- type MockEntityServiceMockRecorder
- func (mr *MockEntityServiceMockRecorder) Affiliation(ctx, mode, document, signature, meta any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) Count(ctx any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) Delete(ctx, id any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) Get(ctx, ccid any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) GetByAlias(ctx, alias any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) GetMeta(ctx, ccid any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) GetWithHint(ctx, ccid, hint any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) IsUserExists(ctx, user any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) List(ctx any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) PullEntityFromRemote(ctx, id, domain any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) Tombstone(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) UpdateScore(ctx, id, score any) *gomock.Call
- func (mr *MockEntityServiceMockRecorder) UpdateTag(ctx, id, tag any) *gomock.Call
- type MockJobService
- func (m *MockJobService) Cancel(ctx context.Context, id string) (core.Job, error)
- func (m *MockJobService) Complete(ctx context.Context, id, status, result string) (core.Job, error)
- func (m *MockJobService) Create(ctx context.Context, requester, typ, payload string, scheduled time.Time) (core.Job, error)
- func (m *MockJobService) Dequeue(ctx context.Context) (*core.Job, error)
- func (m *MockJobService) EXPECT() *MockJobServiceMockRecorder
- func (m *MockJobService) List(ctx context.Context, requester string) ([]core.Job, error)
- type MockJobServiceMockRecorder
- func (mr *MockJobServiceMockRecorder) Cancel(ctx, id any) *gomock.Call
- func (mr *MockJobServiceMockRecorder) Complete(ctx, id, status, result any) *gomock.Call
- func (mr *MockJobServiceMockRecorder) Create(ctx, requester, typ, payload, scheduled any) *gomock.Call
- func (mr *MockJobServiceMockRecorder) Dequeue(ctx any) *gomock.Call
- func (mr *MockJobServiceMockRecorder) List(ctx, requester any) *gomock.Call
- type MockKeyService
- func (m *MockKeyService) Clean(ctx context.Context, ccid string) error
- func (m *MockKeyService) EXPECT() *MockKeyServiceMockRecorder
- func (m *MockKeyService) Enact(ctx context.Context, mode core.CommitMode, payload, signature string) (core.Key, error)
- func (m *MockKeyService) GetAllKeys(ctx context.Context, owner string) ([]core.Key, error)
- func (m *MockKeyService) GetKeyResolution(ctx context.Context, keyID string) ([]core.Key, error)
- func (m *MockKeyService) GetRemoteKeyResolution(ctx context.Context, remote, keyID string) ([]core.Key, error)
- func (m *MockKeyService) ResolveSubkey(ctx context.Context, keyID string) (string, error)
- func (m *MockKeyService) Revoke(ctx context.Context, mode core.CommitMode, payload, signature string) (core.Key, error)
- type MockKeyServiceMockRecorder
- func (mr *MockKeyServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) Enact(ctx, mode, payload, signature any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) GetAllKeys(ctx, owner any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) GetKeyResolution(ctx, keyID any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) GetRemoteKeyResolution(ctx, remote, keyID any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) ResolveSubkey(ctx, keyID any) *gomock.Call
- func (mr *MockKeyServiceMockRecorder) Revoke(ctx, mode, payload, signature any) *gomock.Call
- type MockMessageService
- func (m *MockMessageService) Clean(ctx context.Context, ccid string) error
- func (m *MockMessageService) Count(ctx context.Context) (int64, error)
- func (m *MockMessageService) Create(ctx context.Context, mode core.CommitMode, document, signature string) (core.Message, []string, error)
- func (m *MockMessageService) Delete(ctx context.Context, mode core.CommitMode, document, signature string) (core.Message, []string, error)
- func (m *MockMessageService) EXPECT() *MockMessageServiceMockRecorder
- func (m *MockMessageService) GetAsGuest(ctx context.Context, id string) (core.Message, error)
- func (m *MockMessageService) GetAsUser(ctx context.Context, id string, requester core.Entity) (core.Message, error)
- func (m *MockMessageService) GetWithOwnAssociations(ctx context.Context, id, requester string) (core.Message, error)
- type MockMessageServiceMockRecorder
- func (mr *MockMessageServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) Count(ctx any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) Create(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) Delete(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) GetAsGuest(ctx, id any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) GetAsUser(ctx, id, requester any) *gomock.Call
- func (mr *MockMessageServiceMockRecorder) GetWithOwnAssociations(ctx, id, requester any) *gomock.Call
- type MockNotificationService
- func (m *MockNotificationService) EXPECT() *MockNotificationServiceMockRecorder
- func (m *MockNotificationService) GetAllSubscriptions(ctx context.Context) ([]core.NotificationSubscription, error)
- func (m *MockNotificationService) Subscribe(ctx context.Context, notification core.NotificationSubscription) (core.NotificationSubscription, error)
- type MockNotificationServiceMockRecorder
- type MockPolicyService
- func (m *MockPolicyService) AccumulateOr(results []core.PolicyEvalResult, action string, override *map[string]bool) core.PolicyEvalResult
- func (m *MockPolicyService) EXPECT() *MockPolicyServiceMockRecorder
- func (m *MockPolicyService) Summerize(results []core.PolicyEvalResult, action string, overrides *map[string]bool) bool
- func (m *MockPolicyService) Test(ctx context.Context, policy core.Policy, context core.RequestContext, ...) (core.PolicyEvalResult, error)
- func (m *MockPolicyService) TestWithGlobalPolicy(ctx context.Context, context core.RequestContext, action string) (core.PolicyEvalResult, error)
- func (m *MockPolicyService) TestWithPolicyURL(ctx context.Context, url string, context core.RequestContext, action string) (core.PolicyEvalResult, error)
- type MockPolicyServiceMockRecorder
- func (mr *MockPolicyServiceMockRecorder) AccumulateOr(results, action, override any) *gomock.Call
- func (mr *MockPolicyServiceMockRecorder) Summerize(results, action, overrides any) *gomock.Call
- func (mr *MockPolicyServiceMockRecorder) Test(ctx, policy, context, action any) *gomock.Call
- func (mr *MockPolicyServiceMockRecorder) TestWithGlobalPolicy(ctx, context, action any) *gomock.Call
- func (mr *MockPolicyServiceMockRecorder) TestWithPolicyURL(ctx, url, context, action any) *gomock.Call
- type MockProfileService
- func (m *MockProfileService) Clean(ctx context.Context, ccid string) error
- func (m *MockProfileService) Count(ctx context.Context) (int64, error)
- func (m *MockProfileService) Delete(ctx context.Context, mode core.CommitMode, document string) (core.Profile, error)
- func (m *MockProfileService) EXPECT() *MockProfileServiceMockRecorder
- func (m *MockProfileService) Get(ctx context.Context, id string) (core.Profile, error)
- func (m *MockProfileService) GetByAuthor(ctx context.Context, owner string) ([]core.Profile, error)
- func (m *MockProfileService) GetByAuthorAndSchema(ctx context.Context, owner, schema string) ([]core.Profile, error)
- func (m *MockProfileService) GetBySchema(ctx context.Context, schema string) ([]core.Profile, error)
- func (m *MockProfileService) GetBySemanticID(ctx context.Context, semanticID, owner string) (core.Profile, error)
- func (m *MockProfileService) Upsert(ctx context.Context, mode core.CommitMode, document, signature string) (core.Profile, error)
- type MockProfileServiceMockRecorder
- func (mr *MockProfileServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) Count(ctx any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) Delete(ctx, mode, document any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) Get(ctx, id any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) GetByAuthor(ctx, owner any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) GetByAuthorAndSchema(ctx, owner, schema any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) GetBySchema(ctx, schema any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) GetBySemanticID(ctx, semanticID, owner any) *gomock.Call
- func (mr *MockProfileServiceMockRecorder) Upsert(ctx, mode, document, signature any) *gomock.Call
- type MockSchemaService
- type MockSchemaServiceMockRecorder
- type MockSemanticIDService
- func (m *MockSemanticIDService) Clean(ctx context.Context, ccid string) error
- func (m *MockSemanticIDService) Delete(ctx context.Context, id, owner string) error
- func (m *MockSemanticIDService) EXPECT() *MockSemanticIDServiceMockRecorder
- func (m *MockSemanticIDService) Lookup(ctx context.Context, id, owner string) (string, error)
- func (m *MockSemanticIDService) Name(ctx context.Context, id, owner, target, document, signature string) (core.SemanticID, error)
- type MockSemanticIDServiceMockRecorder
- func (mr *MockSemanticIDServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockSemanticIDServiceMockRecorder) Delete(ctx, id, owner any) *gomock.Call
- func (mr *MockSemanticIDServiceMockRecorder) Lookup(ctx, id, owner any) *gomock.Call
- func (mr *MockSemanticIDServiceMockRecorder) Name(ctx, id, owner, target, document, signature any) *gomock.Call
- type MockSocketManager
- type MockSocketManagerMockRecorder
- type MockStoreService
- func (m *MockStoreService) CleanUserAllData(ctx context.Context, target string) error
- func (m *MockStoreService) Commit(ctx context.Context, mode core.CommitMode, document, signature, option string, ...) (any, error)
- func (m *MockStoreService) EXPECT() *MockStoreServiceMockRecorder
- func (m *MockStoreService) Restore(ctx context.Context, archive io.Reader, from, IP string) ([]core.BatchResult, error)
- func (m *MockStoreService) SyncCommitFile(ctx context.Context, owner string) (core.SyncStatus, error)
- func (m *MockStoreService) SyncStatus(ctx context.Context, owner string) (core.SyncStatus, error)
- func (m *MockStoreService) ValidateDocument(ctx context.Context, document, signature string, keys []core.Key) error
- type MockStoreServiceMockRecorder
- func (mr *MockStoreServiceMockRecorder) CleanUserAllData(ctx, target any) *gomock.Call
- func (mr *MockStoreServiceMockRecorder) Commit(ctx, mode, document, signature, option, keys, IP any) *gomock.Call
- func (mr *MockStoreServiceMockRecorder) Restore(ctx, archive, from, IP any) *gomock.Call
- func (mr *MockStoreServiceMockRecorder) SyncCommitFile(ctx, owner any) *gomock.Call
- func (mr *MockStoreServiceMockRecorder) SyncStatus(ctx, owner any) *gomock.Call
- func (mr *MockStoreServiceMockRecorder) ValidateDocument(ctx, document, signature, keys any) *gomock.Call
- type MockSubscriptionService
- func (m *MockSubscriptionService) Clean(ctx context.Context, ccid string) error
- func (m *MockSubscriptionService) DeleteSubscription(ctx context.Context, mode core.CommitMode, document string) (core.Subscription, error)
- func (m *MockSubscriptionService) EXPECT() *MockSubscriptionServiceMockRecorder
- func (m *MockSubscriptionService) GetOwnSubscriptions(ctx context.Context, owner string) ([]core.Subscription, error)
- func (m *MockSubscriptionService) GetSubscription(ctx context.Context, id string) (core.Subscription, error)
- func (m *MockSubscriptionService) Subscribe(ctx context.Context, mode core.CommitMode, document, signature string) (core.SubscriptionItem, error)
- func (m *MockSubscriptionService) Unsubscribe(ctx context.Context, mode core.CommitMode, document string) (core.SubscriptionItem, error)
- func (m *MockSubscriptionService) UpsertSubscription(ctx context.Context, mode core.CommitMode, document, signature string) (core.Subscription, error)
- type MockSubscriptionServiceMockRecorder
- func (mr *MockSubscriptionServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) DeleteSubscription(ctx, mode, document any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) GetOwnSubscriptions(ctx, owner any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) GetSubscription(ctx, id any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) Subscribe(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) Unsubscribe(ctx, mode, document any) *gomock.Call
- func (mr *MockSubscriptionServiceMockRecorder) UpsertSubscription(ctx, mode, document, signature any) *gomock.Call
- type MockTimelineService
- func (m *MockTimelineService) Clean(ctx context.Context, ccid string) error
- func (m *MockTimelineService) Count(ctx context.Context) (int64, error)
- func (m *MockTimelineService) DeleteTimeline(ctx context.Context, mode core.CommitMode, document string) (core.Timeline, error)
- func (m *MockTimelineService) EXPECT() *MockTimelineServiceMockRecorder
- func (m *MockTimelineService) Event(ctx context.Context, mode core.CommitMode, document, signature string) (core.Event, error)
- func (m *MockTimelineService) GetChunks(ctx context.Context, timelines []string, epoch string) (map[string]core.Chunk, error)
- func (m *MockTimelineService) GetImmediateItems(ctx context.Context, timelines []string, since time.Time, limit int) ([]core.TimelineItem, error)
- func (m *MockTimelineService) GetImmediateItemsFromSubscription(ctx context.Context, subscription string, since time.Time, limit int) ([]core.TimelineItem, error)
- func (m *MockTimelineService) GetItem(ctx context.Context, timeline, id string) (core.TimelineItem, error)
- func (m *MockTimelineService) GetOwners(ctx context.Context, timelines []string) ([]string, error)
- func (m *MockTimelineService) GetRecentItems(ctx context.Context, timelines []string, until time.Time, limit int) ([]core.TimelineItem, error)
- func (m *MockTimelineService) GetRecentItemsFromSubscription(ctx context.Context, subscription string, until time.Time, limit int) ([]core.TimelineItem, error)
- func (m *MockTimelineService) GetTimeline(ctx context.Context, key string) (core.Timeline, error)
- func (m *MockTimelineService) GetTimelineAutoDomain(ctx context.Context, timelineID string) (core.Timeline, error)
- func (m *MockTimelineService) ListLocalRecentlyRemovedItems(ctx context.Context, timelines []string) (map[string][]string, error)
- func (m *MockTimelineService) ListTimelineByAuthor(ctx context.Context, author string) ([]core.Timeline, error)
- func (m *MockTimelineService) ListTimelineBySchema(ctx context.Context, schema string) ([]core.Timeline, error)
- func (m *MockTimelineService) ListTimelineSubscriptions(ctx context.Context) (map[string]int64, error)
- func (m *MockTimelineService) LoadChunkBody(ctx context.Context, query map[string]string) (map[string]core.Chunk, error)
- func (m *MockTimelineService) LookupChunkItr(ctx context.Context, timeliens []string, epoch string) (map[string]string, error)
- func (m *MockTimelineService) NormalizeTimelineID(ctx context.Context, timeline string) (string, error)
- func (m *MockTimelineService) PostItem(ctx context.Context, timeline string, item core.TimelineItem, ...) (core.TimelineItem, error)
- func (m *MockTimelineService) PublishEvent(ctx context.Context, event core.Event) error
- func (m *MockTimelineService) Query(ctx context.Context, timelineID, schema, owner, author string, until time.Time, ...) ([]core.TimelineItem, error)
- func (m *MockTimelineService) Realtime(ctx context.Context, request <-chan []string, response chan<- core.Event)
- func (m *MockTimelineService) RemoveItemsByResourceID(ctx context.Context, resourceID string) error
- func (m *MockTimelineService) Retract(ctx context.Context, mode core.CommitMode, document, signature string) (core.TimelineItem, []string, error)
- func (m *MockTimelineService) UpdateMetrics()
- func (m *MockTimelineService) UpsertTimeline(ctx context.Context, mode core.CommitMode, document, signature string) (core.Timeline, error)
- type MockTimelineServiceMockRecorder
- func (mr *MockTimelineServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) Count(ctx any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) DeleteTimeline(ctx, mode, document any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) Event(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetChunks(ctx, timelines, epoch any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetImmediateItems(ctx, timelines, since, limit any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetImmediateItemsFromSubscription(ctx, subscription, since, limit any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetItem(ctx, timeline, id any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetOwners(ctx, timelines any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetRecentItems(ctx, timelines, until, limit any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetRecentItemsFromSubscription(ctx, subscription, until, limit any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetTimeline(ctx, key any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) GetTimelineAutoDomain(ctx, timelineID any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) ListLocalRecentlyRemovedItems(ctx, timelines any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) ListTimelineByAuthor(ctx, author any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) ListTimelineBySchema(ctx, schema any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) ListTimelineSubscriptions(ctx any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) LoadChunkBody(ctx, query any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) LookupChunkItr(ctx, timeliens, epoch any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) NormalizeTimelineID(ctx, timeline any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) PostItem(ctx, timeline, item, document, signature any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) PublishEvent(ctx, event any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) Query(ctx, timelineID, schema, owner, author, until, limit any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) Realtime(ctx, request, response any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) RemoveItemsByResourceID(ctx, resourceID any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) Retract(ctx, mode, document, signature any) *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) UpdateMetrics() *gomock.Call
- func (mr *MockTimelineServiceMockRecorder) UpsertTimeline(ctx, mode, document, signature any) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAckService ¶
type MockAckService struct {
// contains filtered or unexported fields
}
MockAckService is a mock of AckService interface.
func NewMockAckService ¶
func NewMockAckService(ctrl *gomock.Controller) *MockAckService
NewMockAckService creates a new mock instance.
func (*MockAckService) Ack ¶
func (m *MockAckService) Ack(ctx context.Context, mode core.CommitMode, document, signature string) (core.Ack, error)
Ack mocks base method.
func (*MockAckService) EXPECT ¶
func (m *MockAckService) EXPECT() *MockAckServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockAckServiceMockRecorder ¶
type MockAckServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAckServiceMockRecorder is the mock recorder for MockAckService.
func (*MockAckServiceMockRecorder) Ack ¶
func (mr *MockAckServiceMockRecorder) Ack(ctx, mode, document, signature any) *gomock.Call
Ack indicates an expected call of Ack.
type MockAgentService ¶
type MockAgentService struct {
// contains filtered or unexported fields
}
MockAgentService is a mock of AgentService interface.
func NewMockAgentService ¶
func NewMockAgentService(ctrl *gomock.Controller) *MockAgentService
NewMockAgentService creates a new mock instance.
func (*MockAgentService) EXPECT ¶
func (m *MockAgentService) EXPECT() *MockAgentServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockAgentServiceMockRecorder ¶
type MockAgentServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentServiceMockRecorder is the mock recorder for MockAgentService.
func (*MockAgentServiceMockRecorder) Boot ¶
func (mr *MockAgentServiceMockRecorder) Boot() *gomock.Call
Boot indicates an expected call of Boot.
type MockAssociationService ¶
type MockAssociationService struct {
// contains filtered or unexported fields
}
MockAssociationService is a mock of AssociationService interface.
func NewMockAssociationService ¶
func NewMockAssociationService(ctrl *gomock.Controller) *MockAssociationService
NewMockAssociationService creates a new mock instance.
func (*MockAssociationService) Clean ¶
func (m *MockAssociationService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockAssociationService) Count ¶
func (m *MockAssociationService) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockAssociationService) Create ¶
func (m *MockAssociationService) Create(ctx context.Context, mode core.CommitMode, document, signature string) (core.Association, []string, error)
Create mocks base method.
func (*MockAssociationService) Delete ¶
func (m *MockAssociationService) Delete(ctx context.Context, mode core.CommitMode, document, signature string) (core.Association, []string, error)
Delete mocks base method.
func (*MockAssociationService) EXPECT ¶
func (m *MockAssociationService) EXPECT() *MockAssociationServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAssociationService) Get ¶
func (m *MockAssociationService) Get(ctx context.Context, id string) (core.Association, error)
Get mocks base method.
func (*MockAssociationService) GetBySchema ¶
func (m *MockAssociationService) GetBySchema(ctx context.Context, messageID, schema string) ([]core.Association, error)
GetBySchema mocks base method.
func (*MockAssociationService) GetBySchemaAndVariant ¶
func (m *MockAssociationService) GetBySchemaAndVariant(ctx context.Context, messageID, schema, variant string) ([]core.Association, error)
GetBySchemaAndVariant mocks base method.
func (*MockAssociationService) GetByTarget ¶
func (m *MockAssociationService) GetByTarget(ctx context.Context, targetID string) ([]core.Association, error)
GetByTarget mocks base method.
func (*MockAssociationService) GetCountsBySchema ¶
func (m *MockAssociationService) GetCountsBySchema(ctx context.Context, messageID string) (map[string]int64, error)
GetCountsBySchema mocks base method.
func (*MockAssociationService) GetCountsBySchemaAndVariant ¶
func (m *MockAssociationService) GetCountsBySchemaAndVariant(ctx context.Context, messageID, schema string) (map[string]int64, error)
GetCountsBySchemaAndVariant mocks base method.
func (*MockAssociationService) GetOwn ¶
func (m *MockAssociationService) GetOwn(ctx context.Context, author string) ([]core.Association, error)
GetOwn mocks base method.
func (*MockAssociationService) GetOwnByTarget ¶
func (m *MockAssociationService) GetOwnByTarget(ctx context.Context, targetID, author string) ([]core.Association, error)
GetOwnByTarget mocks base method.
type MockAssociationServiceMockRecorder ¶
type MockAssociationServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAssociationServiceMockRecorder is the mock recorder for MockAssociationService.
func (*MockAssociationServiceMockRecorder) Clean ¶
func (mr *MockAssociationServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockAssociationServiceMockRecorder) Count ¶
func (mr *MockAssociationServiceMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockAssociationServiceMockRecorder) Create ¶
func (mr *MockAssociationServiceMockRecorder) Create(ctx, mode, document, signature any) *gomock.Call
Create indicates an expected call of Create.
func (*MockAssociationServiceMockRecorder) Delete ¶
func (mr *MockAssociationServiceMockRecorder) Delete(ctx, mode, document, signature any) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockAssociationServiceMockRecorder) Get ¶
func (mr *MockAssociationServiceMockRecorder) Get(ctx, id any) *gomock.Call
Get indicates an expected call of Get.
func (*MockAssociationServiceMockRecorder) GetBySchema ¶
func (mr *MockAssociationServiceMockRecorder) GetBySchema(ctx, messageID, schema any) *gomock.Call
GetBySchema indicates an expected call of GetBySchema.
func (*MockAssociationServiceMockRecorder) GetBySchemaAndVariant ¶
func (mr *MockAssociationServiceMockRecorder) GetBySchemaAndVariant(ctx, messageID, schema, variant any) *gomock.Call
GetBySchemaAndVariant indicates an expected call of GetBySchemaAndVariant.
func (*MockAssociationServiceMockRecorder) GetByTarget ¶
func (mr *MockAssociationServiceMockRecorder) GetByTarget(ctx, targetID any) *gomock.Call
GetByTarget indicates an expected call of GetByTarget.
func (*MockAssociationServiceMockRecorder) GetCountsBySchema ¶
func (mr *MockAssociationServiceMockRecorder) GetCountsBySchema(ctx, messageID any) *gomock.Call
GetCountsBySchema indicates an expected call of GetCountsBySchema.
func (*MockAssociationServiceMockRecorder) GetCountsBySchemaAndVariant ¶
func (mr *MockAssociationServiceMockRecorder) GetCountsBySchemaAndVariant(ctx, messageID, schema any) *gomock.Call
GetCountsBySchemaAndVariant indicates an expected call of GetCountsBySchemaAndVariant.
func (*MockAssociationServiceMockRecorder) GetOwn ¶
func (mr *MockAssociationServiceMockRecorder) GetOwn(ctx, author any) *gomock.Call
GetOwn indicates an expected call of GetOwn.
func (*MockAssociationServiceMockRecorder) GetOwnByTarget ¶
func (mr *MockAssociationServiceMockRecorder) GetOwnByTarget(ctx, targetID, author any) *gomock.Call
GetOwnByTarget indicates an expected call of GetOwnByTarget.
type MockAuthService ¶
type MockAuthService struct {
// contains filtered or unexported fields
}
MockAuthService is a mock of AuthService interface.
func NewMockAuthService ¶
func NewMockAuthService(ctrl *gomock.Controller) *MockAuthService
NewMockAuthService creates a new mock instance.
func (*MockAuthService) EXPECT ¶
func (m *MockAuthService) EXPECT() *MockAuthServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAuthService) IdentifyIdentity ¶
func (m *MockAuthService) IdentifyIdentity(next echo.HandlerFunc) echo.HandlerFunc
IdentifyIdentity mocks base method.
func (*MockAuthService) IssuePassport ¶
func (m *MockAuthService) IssuePassport(ctx context.Context, requester string, key []core.Key) (string, error)
IssuePassport mocks base method.
func (*MockAuthService) RateLimiter ¶
func (m *MockAuthService) RateLimiter(configMap core.RateLimitConfigMap) echo.MiddlewareFunc
RateLimiter mocks base method.
type MockAuthServiceMockRecorder ¶
type MockAuthServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockAuthServiceMockRecorder is the mock recorder for MockAuthService.
func (*MockAuthServiceMockRecorder) IdentifyIdentity ¶
func (mr *MockAuthServiceMockRecorder) IdentifyIdentity(next any) *gomock.Call
IdentifyIdentity indicates an expected call of IdentifyIdentity.
func (*MockAuthServiceMockRecorder) IssuePassport ¶
func (mr *MockAuthServiceMockRecorder) IssuePassport(ctx, requester, key any) *gomock.Call
IssuePassport indicates an expected call of IssuePassport.
func (*MockAuthServiceMockRecorder) RateLimiter ¶
func (mr *MockAuthServiceMockRecorder) RateLimiter(configMap any) *gomock.Call
RateLimiter indicates an expected call of RateLimiter.
type MockDomainService ¶
type MockDomainService struct {
// contains filtered or unexported fields
}
MockDomainService is a mock of DomainService interface.
func NewMockDomainService ¶
func NewMockDomainService(ctrl *gomock.Controller) *MockDomainService
NewMockDomainService creates a new mock instance.
func (*MockDomainService) Delete ¶
func (m *MockDomainService) Delete(ctx context.Context, id string) error
Delete mocks base method.
func (*MockDomainService) EXPECT ¶
func (m *MockDomainService) EXPECT() *MockDomainServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDomainService) ForceFetch ¶
ForceFetch mocks base method.
func (*MockDomainService) UpdateScrapeTime ¶
func (m *MockDomainService) UpdateScrapeTime(ctx context.Context, id string, scrapeTime time.Time) error
UpdateScrapeTime mocks base method.
type MockDomainServiceMockRecorder ¶
type MockDomainServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockDomainServiceMockRecorder is the mock recorder for MockDomainService.
func (*MockDomainServiceMockRecorder) Delete ¶
func (mr *MockDomainServiceMockRecorder) Delete(ctx, id any) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockDomainServiceMockRecorder) ForceFetch ¶
func (mr *MockDomainServiceMockRecorder) ForceFetch(ctx, fqdn any) *gomock.Call
ForceFetch indicates an expected call of ForceFetch.
func (*MockDomainServiceMockRecorder) Get ¶
func (mr *MockDomainServiceMockRecorder) Get(ctx, key any) *gomock.Call
Get indicates an expected call of Get.
func (*MockDomainServiceMockRecorder) GetByCCID ¶
func (mr *MockDomainServiceMockRecorder) GetByCCID(ctx, key any) *gomock.Call
GetByCCID indicates an expected call of GetByCCID.
func (*MockDomainServiceMockRecorder) GetByFQDN ¶
func (mr *MockDomainServiceMockRecorder) GetByFQDN(ctx, key any) *gomock.Call
GetByFQDN indicates an expected call of GetByFQDN.
func (*MockDomainServiceMockRecorder) List ¶
func (mr *MockDomainServiceMockRecorder) List(ctx any) *gomock.Call
List indicates an expected call of List.
func (*MockDomainServiceMockRecorder) Update ¶
func (mr *MockDomainServiceMockRecorder) Update(ctx, host any) *gomock.Call
Update indicates an expected call of Update.
func (*MockDomainServiceMockRecorder) UpdateScrapeTime ¶
func (mr *MockDomainServiceMockRecorder) UpdateScrapeTime(ctx, id, scrapeTime any) *gomock.Call
UpdateScrapeTime indicates an expected call of UpdateScrapeTime.
type MockEntityService ¶
type MockEntityService struct {
// contains filtered or unexported fields
}
MockEntityService is a mock of EntityService interface.
func NewMockEntityService ¶
func NewMockEntityService(ctrl *gomock.Controller) *MockEntityService
NewMockEntityService creates a new mock instance.
func (*MockEntityService) Affiliation ¶
func (m *MockEntityService) Affiliation(ctx context.Context, mode core.CommitMode, document, signature, meta string) (core.Entity, error)
Affiliation mocks base method.
func (*MockEntityService) Clean ¶
func (m *MockEntityService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockEntityService) Count ¶
func (m *MockEntityService) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockEntityService) Delete ¶
func (m *MockEntityService) Delete(ctx context.Context, id string) error
Delete mocks base method.
func (*MockEntityService) EXPECT ¶
func (m *MockEntityService) EXPECT() *MockEntityServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEntityService) GetByAlias ¶
GetByAlias mocks base method.
func (*MockEntityService) GetMeta ¶
func (m *MockEntityService) GetMeta(ctx context.Context, ccid string) (core.EntityMeta, error)
GetMeta mocks base method.
func (*MockEntityService) GetWithHint ¶
func (m *MockEntityService) GetWithHint(ctx context.Context, ccid, hint string) (core.Entity, error)
GetWithHint mocks base method.
func (*MockEntityService) IsUserExists ¶
func (m *MockEntityService) IsUserExists(ctx context.Context, user string) bool
IsUserExists mocks base method.
func (*MockEntityService) PullEntityFromRemote ¶
func (m *MockEntityService) PullEntityFromRemote(ctx context.Context, id, domain string) (core.Entity, error)
PullEntityFromRemote mocks base method.
func (*MockEntityService) Tombstone ¶
func (m *MockEntityService) Tombstone(ctx context.Context, mode core.CommitMode, document, signature string) (core.Entity, error)
Tombstone mocks base method.
func (*MockEntityService) UpdateScore ¶
UpdateScore mocks base method.
type MockEntityServiceMockRecorder ¶
type MockEntityServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockEntityServiceMockRecorder is the mock recorder for MockEntityService.
func (*MockEntityServiceMockRecorder) Affiliation ¶
func (mr *MockEntityServiceMockRecorder) Affiliation(ctx, mode, document, signature, meta any) *gomock.Call
Affiliation indicates an expected call of Affiliation.
func (*MockEntityServiceMockRecorder) Clean ¶
func (mr *MockEntityServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockEntityServiceMockRecorder) Count ¶
func (mr *MockEntityServiceMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockEntityServiceMockRecorder) Delete ¶
func (mr *MockEntityServiceMockRecorder) Delete(ctx, id any) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockEntityServiceMockRecorder) Get ¶
func (mr *MockEntityServiceMockRecorder) Get(ctx, ccid any) *gomock.Call
Get indicates an expected call of Get.
func (*MockEntityServiceMockRecorder) GetByAlias ¶
func (mr *MockEntityServiceMockRecorder) GetByAlias(ctx, alias any) *gomock.Call
GetByAlias indicates an expected call of GetByAlias.
func (*MockEntityServiceMockRecorder) GetMeta ¶
func (mr *MockEntityServiceMockRecorder) GetMeta(ctx, ccid any) *gomock.Call
GetMeta indicates an expected call of GetMeta.
func (*MockEntityServiceMockRecorder) GetWithHint ¶
func (mr *MockEntityServiceMockRecorder) GetWithHint(ctx, ccid, hint any) *gomock.Call
GetWithHint indicates an expected call of GetWithHint.
func (*MockEntityServiceMockRecorder) IsUserExists ¶
func (mr *MockEntityServiceMockRecorder) IsUserExists(ctx, user any) *gomock.Call
IsUserExists indicates an expected call of IsUserExists.
func (*MockEntityServiceMockRecorder) List ¶
func (mr *MockEntityServiceMockRecorder) List(ctx any) *gomock.Call
List indicates an expected call of List.
func (*MockEntityServiceMockRecorder) PullEntityFromRemote ¶
func (mr *MockEntityServiceMockRecorder) PullEntityFromRemote(ctx, id, domain any) *gomock.Call
PullEntityFromRemote indicates an expected call of PullEntityFromRemote.
func (*MockEntityServiceMockRecorder) Tombstone ¶
func (mr *MockEntityServiceMockRecorder) Tombstone(ctx, mode, document, signature any) *gomock.Call
Tombstone indicates an expected call of Tombstone.
func (*MockEntityServiceMockRecorder) UpdateScore ¶
func (mr *MockEntityServiceMockRecorder) UpdateScore(ctx, id, score any) *gomock.Call
UpdateScore indicates an expected call of UpdateScore.
type MockJobService ¶
type MockJobService struct {
// contains filtered or unexported fields
}
MockJobService is a mock of JobService interface.
func NewMockJobService ¶
func NewMockJobService(ctrl *gomock.Controller) *MockJobService
NewMockJobService creates a new mock instance.
func (*MockJobService) Create ¶
func (m *MockJobService) Create(ctx context.Context, requester, typ, payload string, scheduled time.Time) (core.Job, error)
Create mocks base method.
func (*MockJobService) EXPECT ¶
func (m *MockJobService) EXPECT() *MockJobServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockJobServiceMockRecorder ¶
type MockJobServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockJobServiceMockRecorder is the mock recorder for MockJobService.
func (*MockJobServiceMockRecorder) Cancel ¶
func (mr *MockJobServiceMockRecorder) Cancel(ctx, id any) *gomock.Call
Cancel indicates an expected call of Cancel.
func (*MockJobServiceMockRecorder) Complete ¶
func (mr *MockJobServiceMockRecorder) Complete(ctx, id, status, result any) *gomock.Call
Complete indicates an expected call of Complete.
func (*MockJobServiceMockRecorder) Create ¶
func (mr *MockJobServiceMockRecorder) Create(ctx, requester, typ, payload, scheduled any) *gomock.Call
Create indicates an expected call of Create.
type MockKeyService ¶
type MockKeyService struct {
// contains filtered or unexported fields
}
MockKeyService is a mock of KeyService interface.
func NewMockKeyService ¶
func NewMockKeyService(ctrl *gomock.Controller) *MockKeyService
NewMockKeyService creates a new mock instance.
func (*MockKeyService) Clean ¶
func (m *MockKeyService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockKeyService) EXPECT ¶
func (m *MockKeyService) EXPECT() *MockKeyServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockKeyService) Enact ¶
func (m *MockKeyService) Enact(ctx context.Context, mode core.CommitMode, payload, signature string) (core.Key, error)
Enact mocks base method.
func (*MockKeyService) GetAllKeys ¶
GetAllKeys mocks base method.
func (*MockKeyService) GetKeyResolution ¶
GetKeyResolution mocks base method.
func (*MockKeyService) GetRemoteKeyResolution ¶
func (m *MockKeyService) GetRemoteKeyResolution(ctx context.Context, remote, keyID string) ([]core.Key, error)
GetRemoteKeyResolution mocks base method.
func (*MockKeyService) ResolveSubkey ¶
ResolveSubkey mocks base method.
type MockKeyServiceMockRecorder ¶
type MockKeyServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockKeyServiceMockRecorder is the mock recorder for MockKeyService.
func (*MockKeyServiceMockRecorder) Clean ¶
func (mr *MockKeyServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockKeyServiceMockRecorder) Enact ¶
func (mr *MockKeyServiceMockRecorder) Enact(ctx, mode, payload, signature any) *gomock.Call
Enact indicates an expected call of Enact.
func (*MockKeyServiceMockRecorder) GetAllKeys ¶
func (mr *MockKeyServiceMockRecorder) GetAllKeys(ctx, owner any) *gomock.Call
GetAllKeys indicates an expected call of GetAllKeys.
func (*MockKeyServiceMockRecorder) GetKeyResolution ¶
func (mr *MockKeyServiceMockRecorder) GetKeyResolution(ctx, keyID any) *gomock.Call
GetKeyResolution indicates an expected call of GetKeyResolution.
func (*MockKeyServiceMockRecorder) GetRemoteKeyResolution ¶
func (mr *MockKeyServiceMockRecorder) GetRemoteKeyResolution(ctx, remote, keyID any) *gomock.Call
GetRemoteKeyResolution indicates an expected call of GetRemoteKeyResolution.
func (*MockKeyServiceMockRecorder) ResolveSubkey ¶
func (mr *MockKeyServiceMockRecorder) ResolveSubkey(ctx, keyID any) *gomock.Call
ResolveSubkey indicates an expected call of ResolveSubkey.
type MockMessageService ¶
type MockMessageService struct {
// contains filtered or unexported fields
}
MockMessageService is a mock of MessageService interface.
func NewMockMessageService ¶
func NewMockMessageService(ctrl *gomock.Controller) *MockMessageService
NewMockMessageService creates a new mock instance.
func (*MockMessageService) Clean ¶
func (m *MockMessageService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockMessageService) Count ¶
func (m *MockMessageService) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockMessageService) Create ¶
func (m *MockMessageService) Create(ctx context.Context, mode core.CommitMode, document, signature string) (core.Message, []string, error)
Create mocks base method.
func (*MockMessageService) Delete ¶
func (m *MockMessageService) Delete(ctx context.Context, mode core.CommitMode, document, signature string) (core.Message, []string, error)
Delete mocks base method.
func (*MockMessageService) EXPECT ¶
func (m *MockMessageService) EXPECT() *MockMessageServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMessageService) GetAsGuest ¶
GetAsGuest mocks base method.
func (*MockMessageService) GetAsUser ¶
func (m *MockMessageService) GetAsUser(ctx context.Context, id string, requester core.Entity) (core.Message, error)
GetAsUser mocks base method.
func (*MockMessageService) GetWithOwnAssociations ¶
func (m *MockMessageService) GetWithOwnAssociations(ctx context.Context, id, requester string) (core.Message, error)
GetWithOwnAssociations mocks base method.
type MockMessageServiceMockRecorder ¶
type MockMessageServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageServiceMockRecorder is the mock recorder for MockMessageService.
func (*MockMessageServiceMockRecorder) Clean ¶
func (mr *MockMessageServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockMessageServiceMockRecorder) Count ¶
func (mr *MockMessageServiceMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockMessageServiceMockRecorder) Create ¶
func (mr *MockMessageServiceMockRecorder) Create(ctx, mode, document, signature any) *gomock.Call
Create indicates an expected call of Create.
func (*MockMessageServiceMockRecorder) Delete ¶
func (mr *MockMessageServiceMockRecorder) Delete(ctx, mode, document, signature any) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockMessageServiceMockRecorder) GetAsGuest ¶
func (mr *MockMessageServiceMockRecorder) GetAsGuest(ctx, id any) *gomock.Call
GetAsGuest indicates an expected call of GetAsGuest.
func (*MockMessageServiceMockRecorder) GetAsUser ¶
func (mr *MockMessageServiceMockRecorder) GetAsUser(ctx, id, requester any) *gomock.Call
GetAsUser indicates an expected call of GetAsUser.
func (*MockMessageServiceMockRecorder) GetWithOwnAssociations ¶
func (mr *MockMessageServiceMockRecorder) GetWithOwnAssociations(ctx, id, requester any) *gomock.Call
GetWithOwnAssociations indicates an expected call of GetWithOwnAssociations.
type MockNotificationService ¶
type MockNotificationService struct {
// contains filtered or unexported fields
}
MockNotificationService is a mock of NotificationService interface.
func NewMockNotificationService ¶
func NewMockNotificationService(ctrl *gomock.Controller) *MockNotificationService
NewMockNotificationService creates a new mock instance.
func (*MockNotificationService) EXPECT ¶
func (m *MockNotificationService) EXPECT() *MockNotificationServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockNotificationService) GetAllSubscriptions ¶
func (m *MockNotificationService) GetAllSubscriptions(ctx context.Context) ([]core.NotificationSubscription, error)
GetAllSubscriptions mocks base method.
func (*MockNotificationService) Subscribe ¶
func (m *MockNotificationService) Subscribe(ctx context.Context, notification core.NotificationSubscription) (core.NotificationSubscription, error)
Subscribe mocks base method.
type MockNotificationServiceMockRecorder ¶
type MockNotificationServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockNotificationServiceMockRecorder is the mock recorder for MockNotificationService.
func (*MockNotificationServiceMockRecorder) GetAllSubscriptions ¶
func (mr *MockNotificationServiceMockRecorder) GetAllSubscriptions(ctx any) *gomock.Call
GetAllSubscriptions indicates an expected call of GetAllSubscriptions.
type MockPolicyService ¶
type MockPolicyService struct {
// contains filtered or unexported fields
}
MockPolicyService is a mock of PolicyService interface.
func NewMockPolicyService ¶
func NewMockPolicyService(ctrl *gomock.Controller) *MockPolicyService
NewMockPolicyService creates a new mock instance.
func (*MockPolicyService) AccumulateOr ¶
func (m *MockPolicyService) AccumulateOr(results []core.PolicyEvalResult, action string, override *map[string]bool) core.PolicyEvalResult
AccumulateOr mocks base method.
func (*MockPolicyService) EXPECT ¶
func (m *MockPolicyService) EXPECT() *MockPolicyServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPolicyService) Summerize ¶
func (m *MockPolicyService) Summerize(results []core.PolicyEvalResult, action string, overrides *map[string]bool) bool
Summerize mocks base method.
func (*MockPolicyService) Test ¶
func (m *MockPolicyService) Test(ctx context.Context, policy core.Policy, context core.RequestContext, action string) (core.PolicyEvalResult, error)
Test mocks base method.
func (*MockPolicyService) TestWithGlobalPolicy ¶
func (m *MockPolicyService) TestWithGlobalPolicy(ctx context.Context, context core.RequestContext, action string) (core.PolicyEvalResult, error)
TestWithGlobalPolicy mocks base method.
func (*MockPolicyService) TestWithPolicyURL ¶
func (m *MockPolicyService) TestWithPolicyURL(ctx context.Context, url string, context core.RequestContext, action string) (core.PolicyEvalResult, error)
TestWithPolicyURL mocks base method.
type MockPolicyServiceMockRecorder ¶
type MockPolicyServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockPolicyServiceMockRecorder is the mock recorder for MockPolicyService.
func (*MockPolicyServiceMockRecorder) AccumulateOr ¶
func (mr *MockPolicyServiceMockRecorder) AccumulateOr(results, action, override any) *gomock.Call
AccumulateOr indicates an expected call of AccumulateOr.
func (*MockPolicyServiceMockRecorder) Summerize ¶
func (mr *MockPolicyServiceMockRecorder) Summerize(results, action, overrides any) *gomock.Call
Summerize indicates an expected call of Summerize.
func (*MockPolicyServiceMockRecorder) Test ¶
func (mr *MockPolicyServiceMockRecorder) Test(ctx, policy, context, action any) *gomock.Call
Test indicates an expected call of Test.
func (*MockPolicyServiceMockRecorder) TestWithGlobalPolicy ¶
func (mr *MockPolicyServiceMockRecorder) TestWithGlobalPolicy(ctx, context, action any) *gomock.Call
TestWithGlobalPolicy indicates an expected call of TestWithGlobalPolicy.
func (*MockPolicyServiceMockRecorder) TestWithPolicyURL ¶
func (mr *MockPolicyServiceMockRecorder) TestWithPolicyURL(ctx, url, context, action any) *gomock.Call
TestWithPolicyURL indicates an expected call of TestWithPolicyURL.
type MockProfileService ¶
type MockProfileService struct {
// contains filtered or unexported fields
}
MockProfileService is a mock of ProfileService interface.
func NewMockProfileService ¶
func NewMockProfileService(ctrl *gomock.Controller) *MockProfileService
NewMockProfileService creates a new mock instance.
func (*MockProfileService) Clean ¶
func (m *MockProfileService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockProfileService) Count ¶
func (m *MockProfileService) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockProfileService) Delete ¶
func (m *MockProfileService) Delete(ctx context.Context, mode core.CommitMode, document string) (core.Profile, error)
Delete mocks base method.
func (*MockProfileService) EXPECT ¶
func (m *MockProfileService) EXPECT() *MockProfileServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProfileService) GetByAuthor ¶
GetByAuthor mocks base method.
func (*MockProfileService) GetByAuthorAndSchema ¶
func (m *MockProfileService) GetByAuthorAndSchema(ctx context.Context, owner, schema string) ([]core.Profile, error)
GetByAuthorAndSchema mocks base method.
func (*MockProfileService) GetBySchema ¶
func (m *MockProfileService) GetBySchema(ctx context.Context, schema string) ([]core.Profile, error)
GetBySchema mocks base method.
func (*MockProfileService) GetBySemanticID ¶
func (m *MockProfileService) GetBySemanticID(ctx context.Context, semanticID, owner string) (core.Profile, error)
GetBySemanticID mocks base method.
type MockProfileServiceMockRecorder ¶
type MockProfileServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockProfileServiceMockRecorder is the mock recorder for MockProfileService.
func (*MockProfileServiceMockRecorder) Clean ¶
func (mr *MockProfileServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockProfileServiceMockRecorder) Count ¶
func (mr *MockProfileServiceMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockProfileServiceMockRecorder) Delete ¶
func (mr *MockProfileServiceMockRecorder) Delete(ctx, mode, document any) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockProfileServiceMockRecorder) Get ¶
func (mr *MockProfileServiceMockRecorder) Get(ctx, id any) *gomock.Call
Get indicates an expected call of Get.
func (*MockProfileServiceMockRecorder) GetByAuthor ¶
func (mr *MockProfileServiceMockRecorder) GetByAuthor(ctx, owner any) *gomock.Call
GetByAuthor indicates an expected call of GetByAuthor.
func (*MockProfileServiceMockRecorder) GetByAuthorAndSchema ¶
func (mr *MockProfileServiceMockRecorder) GetByAuthorAndSchema(ctx, owner, schema any) *gomock.Call
GetByAuthorAndSchema indicates an expected call of GetByAuthorAndSchema.
func (*MockProfileServiceMockRecorder) GetBySchema ¶
func (mr *MockProfileServiceMockRecorder) GetBySchema(ctx, schema any) *gomock.Call
GetBySchema indicates an expected call of GetBySchema.
func (*MockProfileServiceMockRecorder) GetBySemanticID ¶
func (mr *MockProfileServiceMockRecorder) GetBySemanticID(ctx, semanticID, owner any) *gomock.Call
GetBySemanticID indicates an expected call of GetBySemanticID.
type MockSchemaService ¶
type MockSchemaService struct {
// contains filtered or unexported fields
}
MockSchemaService is a mock of SchemaService interface.
func NewMockSchemaService ¶
func NewMockSchemaService(ctrl *gomock.Controller) *MockSchemaService
NewMockSchemaService creates a new mock instance.
func (*MockSchemaService) EXPECT ¶
func (m *MockSchemaService) EXPECT() *MockSchemaServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockSchemaServiceMockRecorder ¶
type MockSchemaServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockSchemaServiceMockRecorder is the mock recorder for MockSchemaService.
type MockSemanticIDService ¶
type MockSemanticIDService struct {
// contains filtered or unexported fields
}
MockSemanticIDService is a mock of SemanticIDService interface.
func NewMockSemanticIDService ¶
func NewMockSemanticIDService(ctrl *gomock.Controller) *MockSemanticIDService
NewMockSemanticIDService creates a new mock instance.
func (*MockSemanticIDService) Clean ¶
func (m *MockSemanticIDService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockSemanticIDService) Delete ¶
func (m *MockSemanticIDService) Delete(ctx context.Context, id, owner string) error
Delete mocks base method.
func (*MockSemanticIDService) EXPECT ¶
func (m *MockSemanticIDService) EXPECT() *MockSemanticIDServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSemanticIDService) Name ¶
func (m *MockSemanticIDService) Name(ctx context.Context, id, owner, target, document, signature string) (core.SemanticID, error)
Name mocks base method.
type MockSemanticIDServiceMockRecorder ¶
type MockSemanticIDServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockSemanticIDServiceMockRecorder is the mock recorder for MockSemanticIDService.
func (*MockSemanticIDServiceMockRecorder) Clean ¶
func (mr *MockSemanticIDServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockSemanticIDServiceMockRecorder) Delete ¶
func (mr *MockSemanticIDServiceMockRecorder) Delete(ctx, id, owner any) *gomock.Call
Delete indicates an expected call of Delete.
type MockSocketManager ¶
type MockSocketManager struct {
// contains filtered or unexported fields
}
MockSocketManager is a mock of SocketManager interface.
func NewMockSocketManager ¶
func NewMockSocketManager(ctrl *gomock.Controller) *MockSocketManager
NewMockSocketManager creates a new mock instance.
func (*MockSocketManager) EXPECT ¶
func (m *MockSocketManager) EXPECT() *MockSocketManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSocketManager) GetAllRemoteSubs ¶
func (m *MockSocketManager) GetAllRemoteSubs() []string
GetAllRemoteSubs mocks base method.
func (*MockSocketManager) Subscribe ¶
func (m *MockSocketManager) Subscribe(conn *websocket.Conn, timelines []string)
Subscribe mocks base method.
func (*MockSocketManager) Unsubscribe ¶
func (m *MockSocketManager) Unsubscribe(conn *websocket.Conn)
Unsubscribe mocks base method.
type MockSocketManagerMockRecorder ¶
type MockSocketManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockSocketManagerMockRecorder is the mock recorder for MockSocketManager.
func (*MockSocketManagerMockRecorder) GetAllRemoteSubs ¶
func (mr *MockSocketManagerMockRecorder) GetAllRemoteSubs() *gomock.Call
GetAllRemoteSubs indicates an expected call of GetAllRemoteSubs.
func (*MockSocketManagerMockRecorder) Subscribe ¶
func (mr *MockSocketManagerMockRecorder) Subscribe(conn, timelines any) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockSocketManagerMockRecorder) Unsubscribe ¶
func (mr *MockSocketManagerMockRecorder) Unsubscribe(conn any) *gomock.Call
Unsubscribe indicates an expected call of Unsubscribe.
type MockStoreService ¶
type MockStoreService struct {
// contains filtered or unexported fields
}
MockStoreService is a mock of StoreService interface.
func NewMockStoreService ¶
func NewMockStoreService(ctrl *gomock.Controller) *MockStoreService
NewMockStoreService creates a new mock instance.
func (*MockStoreService) CleanUserAllData ¶
func (m *MockStoreService) CleanUserAllData(ctx context.Context, target string) error
CleanUserAllData mocks base method.
func (*MockStoreService) Commit ¶
func (m *MockStoreService) Commit(ctx context.Context, mode core.CommitMode, document, signature, option string, keys []core.Key, IP string) (any, error)
Commit mocks base method.
func (*MockStoreService) EXPECT ¶
func (m *MockStoreService) EXPECT() *MockStoreServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStoreService) Restore ¶
func (m *MockStoreService) Restore(ctx context.Context, archive io.Reader, from, IP string) ([]core.BatchResult, error)
Restore mocks base method.
func (*MockStoreService) SyncCommitFile ¶
func (m *MockStoreService) SyncCommitFile(ctx context.Context, owner string) (core.SyncStatus, error)
SyncCommitFile mocks base method.
func (*MockStoreService) SyncStatus ¶
func (m *MockStoreService) SyncStatus(ctx context.Context, owner string) (core.SyncStatus, error)
SyncStatus mocks base method.
func (*MockStoreService) ValidateDocument ¶
func (m *MockStoreService) ValidateDocument(ctx context.Context, document, signature string, keys []core.Key) error
ValidateDocument mocks base method.
type MockStoreServiceMockRecorder ¶
type MockStoreServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockStoreServiceMockRecorder is the mock recorder for MockStoreService.
func (*MockStoreServiceMockRecorder) CleanUserAllData ¶
func (mr *MockStoreServiceMockRecorder) CleanUserAllData(ctx, target any) *gomock.Call
CleanUserAllData indicates an expected call of CleanUserAllData.
func (*MockStoreServiceMockRecorder) Commit ¶
func (mr *MockStoreServiceMockRecorder) Commit(ctx, mode, document, signature, option, keys, IP any) *gomock.Call
Commit indicates an expected call of Commit.
func (*MockStoreServiceMockRecorder) Restore ¶
func (mr *MockStoreServiceMockRecorder) Restore(ctx, archive, from, IP any) *gomock.Call
Restore indicates an expected call of Restore.
func (*MockStoreServiceMockRecorder) SyncCommitFile ¶
func (mr *MockStoreServiceMockRecorder) SyncCommitFile(ctx, owner any) *gomock.Call
SyncCommitFile indicates an expected call of SyncCommitFile.
func (*MockStoreServiceMockRecorder) SyncStatus ¶
func (mr *MockStoreServiceMockRecorder) SyncStatus(ctx, owner any) *gomock.Call
SyncStatus indicates an expected call of SyncStatus.
func (*MockStoreServiceMockRecorder) ValidateDocument ¶
func (mr *MockStoreServiceMockRecorder) ValidateDocument(ctx, document, signature, keys any) *gomock.Call
ValidateDocument indicates an expected call of ValidateDocument.
type MockSubscriptionService ¶
type MockSubscriptionService struct {
// contains filtered or unexported fields
}
MockSubscriptionService is a mock of SubscriptionService interface.
func NewMockSubscriptionService ¶
func NewMockSubscriptionService(ctrl *gomock.Controller) *MockSubscriptionService
NewMockSubscriptionService creates a new mock instance.
func (*MockSubscriptionService) Clean ¶
func (m *MockSubscriptionService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockSubscriptionService) DeleteSubscription ¶
func (m *MockSubscriptionService) DeleteSubscription(ctx context.Context, mode core.CommitMode, document string) (core.Subscription, error)
DeleteSubscription mocks base method.
func (*MockSubscriptionService) EXPECT ¶
func (m *MockSubscriptionService) EXPECT() *MockSubscriptionServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSubscriptionService) GetOwnSubscriptions ¶
func (m *MockSubscriptionService) GetOwnSubscriptions(ctx context.Context, owner string) ([]core.Subscription, error)
GetOwnSubscriptions mocks base method.
func (*MockSubscriptionService) GetSubscription ¶
func (m *MockSubscriptionService) GetSubscription(ctx context.Context, id string) (core.Subscription, error)
GetSubscription mocks base method.
func (*MockSubscriptionService) Subscribe ¶
func (m *MockSubscriptionService) Subscribe(ctx context.Context, mode core.CommitMode, document, signature string) (core.SubscriptionItem, error)
Subscribe mocks base method.
func (*MockSubscriptionService) Unsubscribe ¶
func (m *MockSubscriptionService) Unsubscribe(ctx context.Context, mode core.CommitMode, document string) (core.SubscriptionItem, error)
Unsubscribe mocks base method.
func (*MockSubscriptionService) UpsertSubscription ¶
func (m *MockSubscriptionService) UpsertSubscription(ctx context.Context, mode core.CommitMode, document, signature string) (core.Subscription, error)
UpsertSubscription mocks base method.
type MockSubscriptionServiceMockRecorder ¶
type MockSubscriptionServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriptionServiceMockRecorder is the mock recorder for MockSubscriptionService.
func (*MockSubscriptionServiceMockRecorder) Clean ¶
func (mr *MockSubscriptionServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockSubscriptionServiceMockRecorder) DeleteSubscription ¶
func (mr *MockSubscriptionServiceMockRecorder) DeleteSubscription(ctx, mode, document any) *gomock.Call
DeleteSubscription indicates an expected call of DeleteSubscription.
func (*MockSubscriptionServiceMockRecorder) GetOwnSubscriptions ¶
func (mr *MockSubscriptionServiceMockRecorder) GetOwnSubscriptions(ctx, owner any) *gomock.Call
GetOwnSubscriptions indicates an expected call of GetOwnSubscriptions.
func (*MockSubscriptionServiceMockRecorder) GetSubscription ¶
func (mr *MockSubscriptionServiceMockRecorder) GetSubscription(ctx, id any) *gomock.Call
GetSubscription indicates an expected call of GetSubscription.
func (*MockSubscriptionServiceMockRecorder) Subscribe ¶
func (mr *MockSubscriptionServiceMockRecorder) Subscribe(ctx, mode, document, signature any) *gomock.Call
Subscribe indicates an expected call of Subscribe.
func (*MockSubscriptionServiceMockRecorder) Unsubscribe ¶
func (mr *MockSubscriptionServiceMockRecorder) Unsubscribe(ctx, mode, document any) *gomock.Call
Unsubscribe indicates an expected call of Unsubscribe.
func (*MockSubscriptionServiceMockRecorder) UpsertSubscription ¶
func (mr *MockSubscriptionServiceMockRecorder) UpsertSubscription(ctx, mode, document, signature any) *gomock.Call
UpsertSubscription indicates an expected call of UpsertSubscription.
type MockTimelineService ¶
type MockTimelineService struct {
// contains filtered or unexported fields
}
MockTimelineService is a mock of TimelineService interface.
func NewMockTimelineService ¶
func NewMockTimelineService(ctrl *gomock.Controller) *MockTimelineService
NewMockTimelineService creates a new mock instance.
func (*MockTimelineService) Clean ¶
func (m *MockTimelineService) Clean(ctx context.Context, ccid string) error
Clean mocks base method.
func (*MockTimelineService) Count ¶
func (m *MockTimelineService) Count(ctx context.Context) (int64, error)
Count mocks base method.
func (*MockTimelineService) DeleteTimeline ¶
func (m *MockTimelineService) DeleteTimeline(ctx context.Context, mode core.CommitMode, document string) (core.Timeline, error)
DeleteTimeline mocks base method.
func (*MockTimelineService) EXPECT ¶
func (m *MockTimelineService) EXPECT() *MockTimelineServiceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTimelineService) Event ¶
func (m *MockTimelineService) Event(ctx context.Context, mode core.CommitMode, document, signature string) (core.Event, error)
Event mocks base method.
func (*MockTimelineService) GetChunks ¶
func (m *MockTimelineService) GetChunks(ctx context.Context, timelines []string, epoch string) (map[string]core.Chunk, error)
GetChunks mocks base method.
func (*MockTimelineService) GetImmediateItems ¶
func (m *MockTimelineService) GetImmediateItems(ctx context.Context, timelines []string, since time.Time, limit int) ([]core.TimelineItem, error)
GetImmediateItems mocks base method.
func (*MockTimelineService) GetImmediateItemsFromSubscription ¶
func (m *MockTimelineService) GetImmediateItemsFromSubscription(ctx context.Context, subscription string, since time.Time, limit int) ([]core.TimelineItem, error)
GetImmediateItemsFromSubscription mocks base method.
func (*MockTimelineService) GetItem ¶
func (m *MockTimelineService) GetItem(ctx context.Context, timeline, id string) (core.TimelineItem, error)
GetItem mocks base method.
func (*MockTimelineService) GetRecentItems ¶
func (m *MockTimelineService) GetRecentItems(ctx context.Context, timelines []string, until time.Time, limit int) ([]core.TimelineItem, error)
GetRecentItems mocks base method.
func (*MockTimelineService) GetRecentItemsFromSubscription ¶
func (m *MockTimelineService) GetRecentItemsFromSubscription(ctx context.Context, subscription string, until time.Time, limit int) ([]core.TimelineItem, error)
GetRecentItemsFromSubscription mocks base method.
func (*MockTimelineService) GetTimeline ¶
GetTimeline mocks base method.
func (*MockTimelineService) GetTimelineAutoDomain ¶
func (m *MockTimelineService) GetTimelineAutoDomain(ctx context.Context, timelineID string) (core.Timeline, error)
GetTimelineAutoDomain mocks base method.
func (*MockTimelineService) ListLocalRecentlyRemovedItems ¶
func (m *MockTimelineService) ListLocalRecentlyRemovedItems(ctx context.Context, timelines []string) (map[string][]string, error)
ListLocalRecentlyRemovedItems mocks base method.
func (*MockTimelineService) ListTimelineByAuthor ¶
func (m *MockTimelineService) ListTimelineByAuthor(ctx context.Context, author string) ([]core.Timeline, error)
ListTimelineByAuthor mocks base method.
func (*MockTimelineService) ListTimelineBySchema ¶
func (m *MockTimelineService) ListTimelineBySchema(ctx context.Context, schema string) ([]core.Timeline, error)
ListTimelineBySchema mocks base method.
func (*MockTimelineService) ListTimelineSubscriptions ¶
func (m *MockTimelineService) ListTimelineSubscriptions(ctx context.Context) (map[string]int64, error)
ListTimelineSubscriptions mocks base method.
func (*MockTimelineService) LoadChunkBody ¶
func (m *MockTimelineService) LoadChunkBody(ctx context.Context, query map[string]string) (map[string]core.Chunk, error)
LoadChunkBody mocks base method.
func (*MockTimelineService) LookupChunkItr ¶
func (m *MockTimelineService) LookupChunkItr(ctx context.Context, timeliens []string, epoch string) (map[string]string, error)
LookupChunkItr mocks base method.
func (*MockTimelineService) NormalizeTimelineID ¶
func (m *MockTimelineService) NormalizeTimelineID(ctx context.Context, timeline string) (string, error)
NormalizeTimelineID mocks base method.
func (*MockTimelineService) PostItem ¶
func (m *MockTimelineService) PostItem(ctx context.Context, timeline string, item core.TimelineItem, document, signature string) (core.TimelineItem, error)
PostItem mocks base method.
func (*MockTimelineService) PublishEvent ¶
PublishEvent mocks base method.
func (*MockTimelineService) Query ¶
func (m *MockTimelineService) Query(ctx context.Context, timelineID, schema, owner, author string, until time.Time, limit int) ([]core.TimelineItem, error)
Query mocks base method.
func (*MockTimelineService) Realtime ¶
func (m *MockTimelineService) Realtime(ctx context.Context, request <-chan []string, response chan<- core.Event)
Realtime mocks base method.
func (*MockTimelineService) RemoveItemsByResourceID ¶
func (m *MockTimelineService) RemoveItemsByResourceID(ctx context.Context, resourceID string) error
RemoveItemsByResourceID mocks base method.
func (*MockTimelineService) Retract ¶
func (m *MockTimelineService) Retract(ctx context.Context, mode core.CommitMode, document, signature string) (core.TimelineItem, []string, error)
Retract mocks base method.
func (*MockTimelineService) UpdateMetrics ¶
func (m *MockTimelineService) UpdateMetrics()
UpdateMetrics mocks base method.
func (*MockTimelineService) UpsertTimeline ¶
func (m *MockTimelineService) UpsertTimeline(ctx context.Context, mode core.CommitMode, document, signature string) (core.Timeline, error)
UpsertTimeline mocks base method.
type MockTimelineServiceMockRecorder ¶
type MockTimelineServiceMockRecorder struct {
// contains filtered or unexported fields
}
MockTimelineServiceMockRecorder is the mock recorder for MockTimelineService.
func (*MockTimelineServiceMockRecorder) Clean ¶
func (mr *MockTimelineServiceMockRecorder) Clean(ctx, ccid any) *gomock.Call
Clean indicates an expected call of Clean.
func (*MockTimelineServiceMockRecorder) Count ¶
func (mr *MockTimelineServiceMockRecorder) Count(ctx any) *gomock.Call
Count indicates an expected call of Count.
func (*MockTimelineServiceMockRecorder) DeleteTimeline ¶
func (mr *MockTimelineServiceMockRecorder) DeleteTimeline(ctx, mode, document any) *gomock.Call
DeleteTimeline indicates an expected call of DeleteTimeline.
func (*MockTimelineServiceMockRecorder) Event ¶
func (mr *MockTimelineServiceMockRecorder) Event(ctx, mode, document, signature any) *gomock.Call
Event indicates an expected call of Event.
func (*MockTimelineServiceMockRecorder) GetChunks ¶
func (mr *MockTimelineServiceMockRecorder) GetChunks(ctx, timelines, epoch any) *gomock.Call
GetChunks indicates an expected call of GetChunks.
func (*MockTimelineServiceMockRecorder) GetImmediateItems ¶
func (mr *MockTimelineServiceMockRecorder) GetImmediateItems(ctx, timelines, since, limit any) *gomock.Call
GetImmediateItems indicates an expected call of GetImmediateItems.
func (*MockTimelineServiceMockRecorder) GetImmediateItemsFromSubscription ¶
func (mr *MockTimelineServiceMockRecorder) GetImmediateItemsFromSubscription(ctx, subscription, since, limit any) *gomock.Call
GetImmediateItemsFromSubscription indicates an expected call of GetImmediateItemsFromSubscription.
func (*MockTimelineServiceMockRecorder) GetItem ¶
func (mr *MockTimelineServiceMockRecorder) GetItem(ctx, timeline, id any) *gomock.Call
GetItem indicates an expected call of GetItem.
func (*MockTimelineServiceMockRecorder) GetOwners ¶
func (mr *MockTimelineServiceMockRecorder) GetOwners(ctx, timelines any) *gomock.Call
GetOwners indicates an expected call of GetOwners.
func (*MockTimelineServiceMockRecorder) GetRecentItems ¶
func (mr *MockTimelineServiceMockRecorder) GetRecentItems(ctx, timelines, until, limit any) *gomock.Call
GetRecentItems indicates an expected call of GetRecentItems.
func (*MockTimelineServiceMockRecorder) GetRecentItemsFromSubscription ¶
func (mr *MockTimelineServiceMockRecorder) GetRecentItemsFromSubscription(ctx, subscription, until, limit any) *gomock.Call
GetRecentItemsFromSubscription indicates an expected call of GetRecentItemsFromSubscription.
func (*MockTimelineServiceMockRecorder) GetTimeline ¶
func (mr *MockTimelineServiceMockRecorder) GetTimeline(ctx, key any) *gomock.Call
GetTimeline indicates an expected call of GetTimeline.
func (*MockTimelineServiceMockRecorder) GetTimelineAutoDomain ¶
func (mr *MockTimelineServiceMockRecorder) GetTimelineAutoDomain(ctx, timelineID any) *gomock.Call
GetTimelineAutoDomain indicates an expected call of GetTimelineAutoDomain.
func (*MockTimelineServiceMockRecorder) ListLocalRecentlyRemovedItems ¶
func (mr *MockTimelineServiceMockRecorder) ListLocalRecentlyRemovedItems(ctx, timelines any) *gomock.Call
ListLocalRecentlyRemovedItems indicates an expected call of ListLocalRecentlyRemovedItems.
func (*MockTimelineServiceMockRecorder) ListTimelineByAuthor ¶
func (mr *MockTimelineServiceMockRecorder) ListTimelineByAuthor(ctx, author any) *gomock.Call
ListTimelineByAuthor indicates an expected call of ListTimelineByAuthor.
func (*MockTimelineServiceMockRecorder) ListTimelineBySchema ¶
func (mr *MockTimelineServiceMockRecorder) ListTimelineBySchema(ctx, schema any) *gomock.Call
ListTimelineBySchema indicates an expected call of ListTimelineBySchema.
func (*MockTimelineServiceMockRecorder) ListTimelineSubscriptions ¶
func (mr *MockTimelineServiceMockRecorder) ListTimelineSubscriptions(ctx any) *gomock.Call
ListTimelineSubscriptions indicates an expected call of ListTimelineSubscriptions.
func (*MockTimelineServiceMockRecorder) LoadChunkBody ¶
func (mr *MockTimelineServiceMockRecorder) LoadChunkBody(ctx, query any) *gomock.Call
LoadChunkBody indicates an expected call of LoadChunkBody.
func (*MockTimelineServiceMockRecorder) LookupChunkItr ¶
func (mr *MockTimelineServiceMockRecorder) LookupChunkItr(ctx, timeliens, epoch any) *gomock.Call
LookupChunkItr indicates an expected call of LookupChunkItr.
func (*MockTimelineServiceMockRecorder) NormalizeTimelineID ¶
func (mr *MockTimelineServiceMockRecorder) NormalizeTimelineID(ctx, timeline any) *gomock.Call
NormalizeTimelineID indicates an expected call of NormalizeTimelineID.
func (*MockTimelineServiceMockRecorder) PostItem ¶
func (mr *MockTimelineServiceMockRecorder) PostItem(ctx, timeline, item, document, signature any) *gomock.Call
PostItem indicates an expected call of PostItem.
func (*MockTimelineServiceMockRecorder) PublishEvent ¶
func (mr *MockTimelineServiceMockRecorder) PublishEvent(ctx, event any) *gomock.Call
PublishEvent indicates an expected call of PublishEvent.
func (*MockTimelineServiceMockRecorder) Query ¶
func (mr *MockTimelineServiceMockRecorder) Query(ctx, timelineID, schema, owner, author, until, limit any) *gomock.Call
Query indicates an expected call of Query.
func (*MockTimelineServiceMockRecorder) Realtime ¶
func (mr *MockTimelineServiceMockRecorder) Realtime(ctx, request, response any) *gomock.Call
Realtime indicates an expected call of Realtime.
func (*MockTimelineServiceMockRecorder) RemoveItemsByResourceID ¶
func (mr *MockTimelineServiceMockRecorder) RemoveItemsByResourceID(ctx, resourceID any) *gomock.Call
RemoveItemsByResourceID indicates an expected call of RemoveItemsByResourceID.
func (*MockTimelineServiceMockRecorder) Retract ¶
func (mr *MockTimelineServiceMockRecorder) Retract(ctx, mode, document, signature any) *gomock.Call
Retract indicates an expected call of Retract.
func (*MockTimelineServiceMockRecorder) UpdateMetrics ¶
func (mr *MockTimelineServiceMockRecorder) UpdateMetrics() *gomock.Call
UpdateMetrics indicates an expected call of UpdateMetrics.
func (*MockTimelineServiceMockRecorder) UpsertTimeline ¶
func (mr *MockTimelineServiceMockRecorder) UpsertTimeline(ctx, mode, document, signature any) *gomock.Call
UpsertTimeline indicates an expected call of UpsertTimeline.