mock_core

package
v1.6.6-beta15 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package mock_core is a generated GoMock package.

Index

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.

func (*MockAckService) GetAcker 

func (m *MockAckService) GetAcker(ctx context.Context, key string) ([]core.Ack, error)

GetAcker mocks base method.

func (*MockAckService) GetAcking 

func (m *MockAckService) GetAcking(ctx context.Context, key string) ([]core.Ack, error)

GetAcking mocks base method.

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.

func (*MockAckServiceMockRecorder) GetAcker 

func (mr *MockAckServiceMockRecorder) GetAcker(ctx, key any) *gomock.Call

GetAcker indicates an expected call of GetAcker.

func (*MockAckServiceMockRecorder) GetAcking 

func (mr *MockAckServiceMockRecorder) GetAcking(ctx, key any) *gomock.Call

GetAcking indicates an expected call of GetAcking.

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

func (m *MockAgentService) Boot()

Boot mocks base method.

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 

func (m *MockDomainService) ForceFetch(ctx context.Context, fqdn string) (core.Domain, error)

ForceFetch mocks base method.

func (*MockDomainService) Get 

func (m *MockDomainService) Get(ctx context.Context, key string) (core.Domain, error)

Get mocks base method.

func (*MockDomainService) GetByCCID 

func (m *MockDomainService) GetByCCID(ctx context.Context, key string) (core.Domain, error)

GetByCCID mocks base method.

func (*MockDomainService) GetByFQDN 

func (m *MockDomainService) GetByFQDN(ctx context.Context, key string) (core.Domain, error)

GetByFQDN mocks base method.

func (*MockDomainService) List 

func (m *MockDomainService) List(ctx context.Context) ([]core.Domain, error)

List mocks base method.

func (*MockDomainService) Update 

func (m *MockDomainService) Update(ctx context.Context, host core.Domain) error

Update mocks base method.

func (*MockDomainService) UpdateScrapeTime 

func (m *MockDomainService) UpdateScrapeTime(ctx context.Context, id string, scrapeTime time.Time) error

UpdateScrapeTime mocks base method.

func (*MockDomainService) Upsert 

func (m *MockDomainService) Upsert(ctx context.Context, host core.Domain) (core.Domain, error)

Upsert 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.

func (*MockDomainServiceMockRecorder) Upsert 

func (mr *MockDomainServiceMockRecorder) Upsert(ctx, host any) *gomock.Call

Upsert indicates an expected call of Upsert.

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

func (m *MockEntityService) Get(ctx context.Context, ccid string) (core.Entity, error)

Get mocks base method.

func (*MockEntityService) GetByAlias 

func (m *MockEntityService) GetByAlias(ctx context.Context, alias string) (core.Entity, error)

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

func (m *MockEntityService) List(ctx context.Context) ([]core.Entity, error)

List 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) UpdateMeta added in v1.6.6 

func (m *MockEntityService) UpdateMeta(ctx context.Context, key, info string) error

UpdateMeta mocks base method.

func (*MockEntityService) UpdateScore 

func (m *MockEntityService) UpdateScore(ctx context.Context, id string, score int) error

UpdateScore mocks base method.

func (*MockEntityService) UpdateTag 

func (m *MockEntityService) UpdateTag(ctx context.Context, id, tag string) error

UpdateTag 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) UpdateMeta added in v1.6.6 

func (mr *MockEntityServiceMockRecorder) UpdateMeta(ctx, key, info any) *gomock.Call

UpdateMeta indicates an expected call of UpdateMeta.

func (*MockEntityServiceMockRecorder) UpdateScore 

func (mr *MockEntityServiceMockRecorder) UpdateScore(ctx, id, score any) *gomock.Call

UpdateScore indicates an expected call of UpdateScore.

func (*MockEntityServiceMockRecorder) UpdateTag 

func (mr *MockEntityServiceMockRecorder) UpdateTag(ctx, id, tag any) *gomock.Call

UpdateTag indicates an expected call of UpdateTag.

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

func (m *MockJobService) Cancel(ctx context.Context, id string) (core.Job, error)

Cancel mocks base method.

func (*MockJobService) Complete 

func (m *MockJobService) Complete(ctx context.Context, id, status, result string) (core.Job, error)

Complete mocks base method.

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

func (m *MockJobService) Dequeue(ctx context.Context) (*core.Job, error)

Dequeue mocks base method.

func (*MockJobService) EXPECT 

func (m *MockJobService) EXPECT() *MockJobServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockJobService) List 

func (m *MockJobService) List(ctx context.Context, requester string) ([]core.Job, error)

List mocks base method.

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.

func (*MockJobServiceMockRecorder) Dequeue 

func (mr *MockJobServiceMockRecorder) Dequeue(ctx any) *gomock.Call

Dequeue indicates an expected call of Dequeue.

func (*MockJobServiceMockRecorder) List 

func (mr *MockJobServiceMockRecorder) List(ctx, requester any) *gomock.Call

List indicates an expected call of List.

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 

func (m *MockKeyService) GetAllKeys(ctx context.Context, owner string) ([]core.Key, error)

GetAllKeys mocks base method.

func (*MockKeyService) GetKeyResolution 

func (m *MockKeyService) GetKeyResolution(ctx context.Context, keyID string) ([]core.Key, error)

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 

func (m *MockKeyService) ResolveSubkey(ctx context.Context, keyID string) (string, error)

ResolveSubkey mocks base method.

func (*MockKeyService) Revoke 

func (m *MockKeyService) Revoke(ctx context.Context, mode core.CommitMode, payload, signature string) (core.Key, error)

Revoke 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.

func (*MockKeyServiceMockRecorder) Revoke 

func (mr *MockKeyServiceMockRecorder) Revoke(ctx, mode, payload, signature any) *gomock.Call

Revoke indicates an expected call of Revoke.

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 

func (m *MockMessageService) GetAsGuest(ctx context.Context, id string) (core.Message, error)

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) Delete added in v1.6.6 

func (m *MockNotificationService) Delete(ctx context.Context, vendorID, owner string) error

Delete mocks base method.

func (*MockNotificationService) EXPECT 

func (m *MockNotificationService) EXPECT() *MockNotificationServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNotificationService) Get added in v1.6.6 

func (m *MockNotificationService) Get(ctx context.Context, vendorID, owner string) (core.NotificationSubscription, error)

Get mocks base method.

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) Delete added in v1.6.6 

func (mr *MockNotificationServiceMockRecorder) Delete(ctx, vendorID, owner any) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockNotificationServiceMockRecorder) Get added in v1.6.6 

func (mr *MockNotificationServiceMockRecorder) Get(ctx, vendorID, owner any) *gomock.Call

Get indicates an expected call of Get.

func (*MockNotificationServiceMockRecorder) GetAllSubscriptions 

func (mr *MockNotificationServiceMockRecorder) GetAllSubscriptions(ctx any) *gomock.Call

GetAllSubscriptions indicates an expected call of GetAllSubscriptions.

func (*MockNotificationServiceMockRecorder) Subscribe 

func (mr *MockNotificationServiceMockRecorder) Subscribe(ctx, notification any) *gomock.Call

Subscribe indicates an expected call of Subscribe.

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

func (m *MockProfileService) Get(ctx context.Context, id string) (core.Profile, error)

Get mocks base method.

func (*MockProfileService) GetByAuthor 

func (m *MockProfileService) GetByAuthor(ctx context.Context, owner string) ([]core.Profile, error)

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.

func (*MockProfileService) Query added in v1.6.6 

func (m *MockProfileService) Query(ctx context.Context, author, schema string, limit int, since, until time.Time) ([]core.Profile, error)

Query mocks base method.

func (*MockProfileService) Upsert 

func (m *MockProfileService) Upsert(ctx context.Context, mode core.CommitMode, document, signature string) (core.Profile, error)

Upsert 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.

func (*MockProfileServiceMockRecorder) Query added in v1.6.6 

func (mr *MockProfileServiceMockRecorder) Query(ctx, author, schema, limit, since, until any) *gomock.Call

Query indicates an expected call of Query.

func (*MockProfileServiceMockRecorder) Upsert 

func (mr *MockProfileServiceMockRecorder) Upsert(ctx, mode, document, signature any) *gomock.Call

Upsert indicates an expected call of Upsert.

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.

func (*MockSchemaService) IDToUrl 

func (m *MockSchemaService) IDToUrl(ctx context.Context, id uint) (string, error)

IDToUrl mocks base method.

func (*MockSchemaService) UrlToID 

func (m *MockSchemaService) UrlToID(ctx context.Context, url string) (uint, error)

UrlToID mocks base method.

type MockSchemaServiceMockRecorder 

type MockSchemaServiceMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchemaServiceMockRecorder is the mock recorder for MockSchemaService.

func (*MockSchemaServiceMockRecorder) IDToUrl 

func (mr *MockSchemaServiceMockRecorder) IDToUrl(ctx, id any) *gomock.Call

IDToUrl indicates an expected call of IDToUrl.

func (*MockSchemaServiceMockRecorder) UrlToID 

func (mr *MockSchemaServiceMockRecorder) UrlToID(ctx, url any) *gomock.Call

UrlToID indicates an expected call of UrlToID.

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

func (m *MockSemanticIDService) Lookup(ctx context.Context, id, owner string) (string, error)

Lookup mocks base method.

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.

func (*MockSemanticIDServiceMockRecorder) Lookup 

func (mr *MockSemanticIDServiceMockRecorder) Lookup(ctx, id, owner any) *gomock.Call

Lookup indicates an expected call of Lookup.

func (*MockSemanticIDServiceMockRecorder) Name 

func (mr *MockSemanticIDServiceMockRecorder) Name(ctx, id, owner, target, document, signature any) *gomock.Call

Name indicates an expected call of Name.

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

func (m *MockTimelineService) GetOwners(ctx context.Context, timelines []string) ([]string, error)

GetOwners 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 

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

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 

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

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.