mocks

Oct 13, 2023

Changes in this version

type MockEndpointRepository

+ func (m *MockEndpointRepository) FindEndpointByTargetURL(ctx context.Context, projectID, targetURL string) (*datastore.Endpoint, error)

type MockEndpointRepositoryMockRecorder

+ func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByTargetURL(ctx, projectID, targetURL interface{}) *gomock.Call

type MockEventRepository

+ func (m *MockEventRepository) CopyRows(ctx context.Context, projectID string, interval int) error

+ func (m *MockEventRepository) DeleteProjectTokenizedEvents(ctx context.Context, projectID string, filter *datastore.EventFilter) error

+ func (m *MockEventRepository) FindEventsByIdempotencyKey(ctx context.Context, projectID, idempotencyKey string) ([]datastore.Event, error)

+ func (m *MockEventRepository) FindFirstEventWithIdempotencyKey(ctx context.Context, projectID, idempotencyKey string) (*datastore.Event, error)

type MockEventRepositoryMockRecorder

+ func (mr *MockEventRepositoryMockRecorder) CopyRows(ctx, projectID, interval interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) DeleteProjectTokenizedEvents(ctx, projectID, filter interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) FindEventsByIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) FindFirstEventWithIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call

+ type MockIdempotency struct

+ func NewMockIdempotency(ctrl *gomock.Controller) *MockIdempotency

+ func (m *MockIdempotency) EXPECT() *MockIdempotencyMockRecorder

+ func (m *MockIdempotency) Exists(arg0, arg1 string, arg2 []string) (bool, error)

+ func (m *MockIdempotency) GenerateChecksum(arg0 string, arg1 []string) (string, error)

+ type MockIdempotencyMockRecorder struct

+ func (mr *MockIdempotencyMockRecorder) Exists(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockIdempotencyMockRecorder) GenerateChecksum(arg0, arg1 interface{}) *gomock.Call

+ type MockJobRepository struct

+ func NewMockJobRepository(ctrl *gomock.Controller) *MockJobRepository

+ func (m *MockJobRepository) CreateJob(ctx context.Context, job *datastore.Job) error

+ func (m *MockJobRepository) DeleteJob(ctx context.Context, uid, projectID string) error

+ func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder

+ func (m *MockJobRepository) FetchJobById(ctx context.Context, uid, projectID string) (*datastore.Job, error)

+ func (m *MockJobRepository) FetchJobsByProjectId(ctx context.Context, projectID string) ([]datastore.Job, error)

+ func (m *MockJobRepository) FetchRunningJobsByProjectId(ctx context.Context, projectID string) ([]datastore.Job, error)

+ func (m *MockJobRepository) LoadJobsPaged(ctx context.Context, projectID string, pageable datastore.Pageable) ([]datastore.Job, datastore.PaginationData, error)

+ func (m *MockJobRepository) MarkJobAsCompleted(ctx context.Context, uid, projectID string) error

+ func (m *MockJobRepository) MarkJobAsFailed(ctx context.Context, uid, projectID string) error

+ func (m *MockJobRepository) MarkJobAsStarted(ctx context.Context, uid, projectID string) error

+ type MockJobRepositoryMockRecorder struct

+ func (mr *MockJobRepositoryMockRecorder) CreateJob(ctx, job interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) DeleteJob(ctx, uid, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) FetchJobById(ctx, uid, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) FetchJobsByProjectId(ctx, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) FetchRunningJobsByProjectId(ctx, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) LoadJobsPaged(ctx, projectID, pageable interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) MarkJobAsCompleted(ctx, uid, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) MarkJobAsFailed(ctx, uid, projectID interface{}) *gomock.Call

+ func (mr *MockJobRepositoryMockRecorder) MarkJobAsStarted(ctx, uid, projectID interface{}) *gomock.Call

+ type MockMetaEventRepository struct

+ func NewMockMetaEventRepository(ctrl *gomock.Controller) *MockMetaEventRepository

+ func (m *MockMetaEventRepository) CreateMetaEvent(arg0 context.Context, arg1 *datastore.MetaEvent) error

+ func (m *MockMetaEventRepository) EXPECT() *MockMetaEventRepositoryMockRecorder

+ func (m *MockMetaEventRepository) FindMetaEventByID(ctx context.Context, projectID, id string) (*datastore.MetaEvent, error)

+ func (m *MockMetaEventRepository) LoadMetaEventsPaged(ctx context.Context, projectID string, f *datastore.Filter) ([]datastore.MetaEvent, datastore.PaginationData, error)

+ func (m *MockMetaEventRepository) UpdateMetaEvent(ctx context.Context, projectID string, metaEvent *datastore.MetaEvent) error

+ type MockMetaEventRepositoryMockRecorder struct

+ func (mr *MockMetaEventRepositoryMockRecorder) CreateMetaEvent(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockMetaEventRepositoryMockRecorder) FindMetaEventByID(ctx, projectID, id interface{}) *gomock.Call

+ func (mr *MockMetaEventRepositoryMockRecorder) LoadMetaEventsPaged(ctx, projectID, f interface{}) *gomock.Call

+ func (mr *MockMetaEventRepositoryMockRecorder) UpdateMetaEvent(ctx, projectID, metaEvent interface{}) *gomock.Call

type MockPortalLinkRepository

+ func (m *MockPortalLinkRepository) FindPortalLinkByOwnerID(ctx context.Context, projectID, id string) (*datastore.PortalLink, error)

type MockPortalLinkRepositoryMockRecorder

+ func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByOwnerID(ctx, projectID, id interface{}) *gomock.Call

type MockProjectRepository

+ func (m *MockProjectRepository) GetProjectsWithEventsInTheInterval(ctx context.Context, interval int) ([]datastore.ProjectEvents, error)

type MockProjectRepositoryMockRecorder

+ func (mr *MockProjectRepositoryMockRecorder) GetProjectsWithEventsInTheInterval(ctx, interval interface{}) *gomock.Call

type MockSubscriptionRepository

+ func (m *MockSubscriptionRepository) CountEndpointSubscriptions(ctx context.Context, projectID, endpointID string) (int64, error)

+ func (m *MockSubscriptionRepository) TransformPayload(ctx context.Context, function string, payload map[string]interface{}) (interface{}, []string, error)

type MockSubscriptionRepositoryMockRecorder

+ func (mr *MockSubscriptionRepositoryMockRecorder) CountEndpointSubscriptions(ctx, projectID, endpointID interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) TransformPayload(ctx, function, payload interface{}) *gomock.Call

Mar 28, 2023

Changes in this version

type MockEndpointRepository

+ func (m *MockEndpointRepository) DeleteSecret(ctx context.Context, endpoint *datastore.Endpoint, secretID, projectID string) error

+ func (m *MockEndpointRepository) UpdateSecrets(ctx context.Context, endpointID, projectID string, secrets datastore.Secrets) error

type MockEndpointRepositoryMockRecorder

+ func (mr *MockEndpointRepositoryMockRecorder) DeleteSecret(ctx, endpoint, secretID, projectID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) UpdateSecrets(ctx, endpointID, projectID, secrets interface{}) *gomock.Call

+ type MockExportRepository struct

+ func NewMockExportRepository(ctrl *gomock.Controller) *MockExportRepository

+ func (m *MockExportRepository) EXPECT() *MockExportRepositoryMockRecorder

+ func (m *MockExportRepository) ExportRecords(ctx context.Context, tableName, projectID string, createdAt time.Time) (json.RawMessage, int64, error)

+ type MockExportRepositoryMockRecorder struct

+ func (mr *MockExportRepositoryMockRecorder) ExportRecords(ctx, tableName, projectID, createdAt interface{}) *gomock.Call

+ type MockPubSub struct

+ func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub

+ func (m *MockPubSub) Consume()

+ func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder

+ func (m *MockPubSub) Start()

+ func (m *MockPubSub) Stop()

+ type MockPubSubMockRecorder struct

+ func (mr *MockPubSubMockRecorder) Consume() *gomock.Call

+ func (mr *MockPubSubMockRecorder) Start() *gomock.Call

+ func (mr *MockPubSubMockRecorder) Stop() *gomock.Call

Feb 21, 2023

Changes in this version

type MockOrganisationMemberRepository

+ func (m *MockOrganisationMemberRepository) FindUserProjects(ctx context.Context, userID string) ([]datastore.Project, error)

type MockOrganisationMemberRepositoryMockRecorder

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) FindUserProjects(ctx, userID interface{}) *gomock.Call

type MockSourceRepository

+ func (m *MockSourceRepository) FindSourceByName(ctx context.Context, projectId, name string) (*datastore.Source, error)

type MockSourceRepositoryMockRecorder

+ func (mr *MockSourceRepositoryMockRecorder) FindSourceByName(ctx, projectId, name interface{}) *gomock.Call

type MockSubscriptionRepository

+ func (m *MockSubscriptionRepository) FindCLISubscriptions(ctx context.Context, projectID string) ([]datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) FindSubscriptionsBySourceID(arg0 context.Context, arg1, arg2 string) ([]datastore.Subscription, error)

type MockSubscriptionRepositoryMockRecorder

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindCLISubscriptions(ctx, projectID interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsBySourceID(arg0, arg1, arg2 interface{}) *gomock.Call

Feb 8, 2023

Changes in this version

type MockAPIKeyRepository

+ func (m *MockAPIKeyRepository) FindAPIKeyByProjectID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)

type MockAPIKeyRepositoryMockRecorder

+ func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByProjectID(arg0, arg1 interface{}) *gomock.Call

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) LoadEventDeliveriesIntervals(arg0 context.Context, arg1 string, arg2 datastore.SearchParams, ...) ([]datastore.EventInterval, error)

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesIntervals(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

Dec 23, 2022

Changes in this version

+ type MockEndpointRepository struct

+ func NewMockEndpointRepository(ctrl *gomock.Controller) *MockEndpointRepository

+ func (m *MockEndpointRepository) CountProjectEndpoints(ctx context.Context, projectID string) (int64, error)

+ func (m *MockEndpointRepository) CreateEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error

+ func (m *MockEndpointRepository) DeleteEndpoint(ctx context.Context, endpoint *datastore.Endpoint) error

+ func (m *MockEndpointRepository) DeleteProjectEndpoints(arg0 context.Context, arg1 string) error

+ func (m *MockEndpointRepository) EXPECT() *MockEndpointRepositoryMockRecorder

+ func (m *MockEndpointRepository) ExpireSecret(ctx context.Context, projectID, endpointID string, secrets []datastore.Secret) error

+ func (m *MockEndpointRepository) FindEndpointByID(çtx context.Context, id string) (*datastore.Endpoint, error)

+ func (m *MockEndpointRepository) FindEndpointsByAppID(ctx context.Context, appID string) ([]datastore.Endpoint, error)

+ func (m *MockEndpointRepository) FindEndpointsByID(ctx context.Context, ids []string) ([]datastore.Endpoint, error)

+ func (m *MockEndpointRepository) FindEndpointsByOwnerID(ctx context.Context, projectID, ownerID string) ([]datastore.Endpoint, error)

+ func (m *MockEndpointRepository) LoadEndpointsPaged(ctx context.Context, projectID, query string, pageable datastore.Pageable) ([]datastore.Endpoint, datastore.PaginationData, error)

+ func (m *MockEndpointRepository) LoadEndpointsPagedByProjectId(ctx context.Context, projectID string, pageable datastore.Pageable) ([]datastore.Endpoint, datastore.PaginationData, error)

+ func (m *MockEndpointRepository) SearchEndpointsByProjectId(ctx context.Context, projectID string, params datastore.SearchParams) ([]datastore.Endpoint, error)

+ func (m *MockEndpointRepository) UpdateEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error

+ func (m *MockEndpointRepository) UpdateEndpointStatus(ctx context.Context, groupID, endpointID string, ...) error

+ type MockEndpointRepositoryMockRecorder struct

+ func (mr *MockEndpointRepositoryMockRecorder) CountProjectEndpoints(ctx, projectID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) CreateEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) DeleteEndpoint(ctx, endpoint interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) DeleteProjectEndpoints(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) ExpireSecret(ctx, projectID, endpointID, secrets interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByID(çtx, id interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByAppID(ctx, appID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByID(ctx, ids interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByOwnerID(ctx, projectID, ownerID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) LoadEndpointsPaged(ctx, projectID, query, pageable interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) LoadEndpointsPagedByProjectId(ctx, projectID, pageable interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) SearchEndpointsByProjectId(ctx, projectID, params interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call

+ func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpointStatus(ctx, groupID, endpointID, status interface{}) *gomock.Call

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) DeleteProjectEventDeliveries(ctx context.Context, filter *datastore.EventDeliveryFilter, hardDelete bool) error

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) DeleteProjectEventDeliveries(ctx, filter, hardDelete interface{}) *gomock.Call

type MockEventRepository

+ func (m *MockEventRepository) CountEvents(ctx context.Context, f *datastore.Filter) (int64, error)

+ func (m *MockEventRepository) CountProjectMessages(ctx context.Context, projectID string) (int64, error)

+ func (m *MockEventRepository) DeleteProjectEvents(arg0 context.Context, arg1 *datastore.EventFilter, arg2 bool) error

type MockEventRepositoryMockRecorder

+ func (mr *MockEventRepositoryMockRecorder) CountEvents(ctx, f interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) CountProjectMessages(ctx, projectID interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) DeleteProjectEvents(arg0, arg1, arg2 interface{}) *gomock.Call

type MockOrganisationRepository

+ func (m *MockOrganisationRepository) FetchOrganisationByAssignedDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)

+ func (m *MockOrganisationRepository) FetchOrganisationByCustomDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)

type MockOrganisationRepositoryMockRecorder

+ func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByAssignedDomain(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByCustomDomain(arg0, arg1 interface{}) *gomock.Call

+ type MockPortalLinkRepository struct

+ func NewMockPortalLinkRepository(ctrl *gomock.Controller) *MockPortalLinkRepository

+ func (m *MockPortalLinkRepository) CreatePortalLink(arg0 context.Context, arg1 *datastore.PortalLink) error

+ func (m *MockPortalLinkRepository) EXPECT() *MockPortalLinkRepositoryMockRecorder

+ func (m *MockPortalLinkRepository) FindPortalLinkByID(ctx context.Context, projectID, id string) (*datastore.PortalLink, error)

+ func (m *MockPortalLinkRepository) FindPortalLinkByToken(ctx context.Context, token string) (*datastore.PortalLink, error)

+ func (m *MockPortalLinkRepository) LoadPortalLinksPaged(ctx context.Context, projectID string, f *datastore.FilterBy, ...) ([]datastore.PortalLink, datastore.PaginationData, error)

+ func (m *MockPortalLinkRepository) RevokePortalLink(ctx context.Context, projectID, id string) error

+ func (m *MockPortalLinkRepository) UpdatePortalLink(ctx context.Context, projectID string, portal *datastore.PortalLink) error

+ type MockPortalLinkRepositoryMockRecorder struct

+ func (mr *MockPortalLinkRepositoryMockRecorder) CreatePortalLink(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByID(ctx, projectID, id interface{}) *gomock.Call

+ func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByToken(ctx, token interface{}) *gomock.Call

+ func (mr *MockPortalLinkRepositoryMockRecorder) LoadPortalLinksPaged(ctx, projectID, f, pageable interface{}) *gomock.Call

+ func (mr *MockPortalLinkRepositoryMockRecorder) RevokePortalLink(ctx, projectID, id interface{}) *gomock.Call

+ func (mr *MockPortalLinkRepositoryMockRecorder) UpdatePortalLink(ctx, projectID, portal interface{}) *gomock.Call

+ type MockProjectRepository struct

+ func NewMockProjectRepository(ctrl *gomock.Controller) *MockProjectRepository

+ func (m *MockProjectRepository) CreateProject(arg0 context.Context, arg1 *datastore.Project) error

+ func (m *MockProjectRepository) DeleteProject(ctx context.Context, uid string) error

+ func (m *MockProjectRepository) EXPECT() *MockProjectRepositoryMockRecorder

+ func (m *MockProjectRepository) FetchProjectByID(arg0 context.Context, arg1 string) (*datastore.Project, error)

+ func (m *MockProjectRepository) FetchProjectsByIDs(arg0 context.Context, arg1 []string) ([]datastore.Project, error)

+ func (m *MockProjectRepository) FillProjectsStatistics(ctx context.Context, projects []*datastore.Project) error

+ func (m *MockProjectRepository) LoadProjects(arg0 context.Context, arg1 *datastore.ProjectFilter) ([]*datastore.Project, error)

+ func (m *MockProjectRepository) UpdateProject(arg0 context.Context, arg1 *datastore.Project) error

+ type MockProjectRepositoryMockRecorder struct

+ func (mr *MockProjectRepositoryMockRecorder) CreateProject(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) DeleteProject(ctx, uid interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) FetchProjectByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) FetchProjectsByIDs(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) FillProjectsStatistics(ctx, projects interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) LoadProjects(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockProjectRepositoryMockRecorder) UpdateProject(arg0, arg1 interface{}) *gomock.Call

type MockStore

+ func (m *MockStore) CountWithDeleted(ctx context.Context, filter map[string]interface{}) (int64, error)

type MockStoreMockRecorder

+ func (mr *MockStoreMockRecorder) CountWithDeleted(ctx, filter interface{}) *gomock.Call

type MockSubscriptionRepository

+ func (m *MockSubscriptionRepository) FindSubscriptionsByEndpointID(ctx context.Context, projectId, endpointID string) ([]datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) TestSubscriptionFilter(ctx context.Context, payload, filter map[string]interface{}) (bool, error)

type MockSubscriptionRepositoryMockRecorder

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByEndpointID(ctx, projectId, endpointID interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) TestSubscriptionFilter(ctx, payload, filter interface{}) *gomock.Call

type MockUserRepository

+ func (m *MockUserRepository) FindUserByEmailVerificationToken(ctx context.Context, token string) (*datastore.User, error)

type MockUserRepositoryMockRecorder

+ func (mr *MockUserRepositoryMockRecorder) FindUserByEmailVerificationToken(ctx, token interface{}) *gomock.Call

Nov 7, 2022

Changes in this version

type MockApplicationRepository

+ func (m *MockApplicationRepository) ExpireSecret(ctx context.Context, appID, endpointID string, secrets []datastore.Secret) error

type MockApplicationRepositoryMockRecorder

+ func (mr *MockApplicationRepositoryMockRecorder) ExpireSecret(ctx, appID, endpointID, secrets interface{}) *gomock.Call

Oct 25, 2022

Changes in this version

+ type MockDeviceRepository struct

+ func NewMockDeviceRepository(ctrl *gomock.Controller) *MockDeviceRepository

+ func (m *MockDeviceRepository) CreateDevice(ctx context.Context, device *datastore.Device) error

+ func (m *MockDeviceRepository) DeleteDevice(ctx context.Context, uid, appID, groupID string) error

+ func (m *MockDeviceRepository) EXPECT() *MockDeviceRepositoryMockRecorder

+ func (m *MockDeviceRepository) FetchDeviceByHostName(ctx context.Context, hostName, appID, groupID string) (*datastore.Device, error)

+ func (m *MockDeviceRepository) FetchDeviceByID(ctx context.Context, uid, appID, groupID string) (*datastore.Device, error)

+ func (m *MockDeviceRepository) LoadDevicesPaged(ctx context.Context, groupID string, filter *datastore.ApiKeyFilter, ...) ([]datastore.Device, datastore.PaginationData, error)

+ func (m *MockDeviceRepository) UpdateDevice(ctx context.Context, device *datastore.Device, appID, groupID string) error

+ func (m *MockDeviceRepository) UpdateDeviceLastSeen(ctx context.Context, device *datastore.Device, appID, groupID string, ...) error

+ type MockDeviceRepositoryMockRecorder struct

+ func (mr *MockDeviceRepositoryMockRecorder) CreateDevice(ctx, device interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) DeleteDevice(ctx, uid, appID, groupID interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByHostName(ctx, hostName, appID, groupID interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByID(ctx, uid, appID, groupID interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) LoadDevicesPaged(ctx, groupID, filter, pageable interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) UpdateDevice(ctx, device, appID, groupID interface{}) *gomock.Call

+ func (mr *MockDeviceRepositoryMockRecorder) UpdateDeviceLastSeen(ctx, device, appID, groupID, status interface{}) *gomock.Call

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) FindDiscardedEventDeliveries(ctx context.Context, appId, deviceId string, ...) ([]datastore.EventDelivery, error)

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) FindDiscardedEventDeliveries(ctx, appId, deviceId, searchParams interface{}) *gomock.Call

+ type MockStore struct

+ func NewMockStore(ctrl *gomock.Controller) *MockStore

+ func (m *MockStore) Aggregate(ctx context.Context, pipeline mongo.Pipeline, result interface{}, ...) error

+ func (m *MockStore) Count(ctx context.Context, filter map[string]interface{}) (int64, error)

+ func (m *MockStore) DeleteByID(ctx context.Context, id string, hardDelete bool) error

+ func (m *MockStore) DeleteMany(ctx context.Context, filter, payload bson.M, hardDelete bool) error

+ func (m *MockStore) DeleteOne(ctx context.Context, filter bson.M, hardDelete bool) error

+ func (m *MockStore) EXPECT() *MockStoreMockRecorder

+ func (m *MockStore) FindAll(ctx context.Context, filter bson.M, sort, projection, results interface{}) error

+ func (m *MockStore) FindByID(ctx context.Context, id string, projection bson.M, result interface{}) error

+ func (m *MockStore) FindMany(ctx context.Context, filter, projection bson.M, sort interface{}, ...) (datastore.PaginationData, error)

+ func (m *MockStore) FindManyWithDeletedAt(ctx context.Context, filter, projection bson.M, sort interface{}, ...) error

+ func (m *MockStore) FindOne(ctx context.Context, filter, projection bson.M, result interface{}) error

+ func (m *MockStore) Inc(ctx context.Context, filter bson.M, payload interface{}) error

+ func (m *MockStore) Save(ctx context.Context, payload, result interface{}) error

+ func (m *MockStore) SaveMany(ctx context.Context, payload []interface{}) error

+ func (m *MockStore) UpdateByID(ctx context.Context, id string, payload interface{}) error

+ func (m *MockStore) UpdateMany(ctx context.Context, filter, payload bson.M, bulk bool) error

+ func (m *MockStore) UpdateOne(ctx context.Context, filter bson.M, payload interface{}) error

+ func (m *MockStore) WithTransaction(ctx context.Context, fn func(mongo.SessionContext) error) error

+ type MockStoreMockRecorder struct

+ func (mr *MockStoreMockRecorder) Aggregate(ctx, pipeline, result, allowDiskUse interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) Count(ctx, filter interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) DeleteByID(ctx, id, hardDelete interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) DeleteMany(ctx, filter, payload, hardDelete interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) DeleteOne(ctx, filter, hardDelete interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) FindAll(ctx, filter, sort, projection, results interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) FindByID(ctx, id, projection, result interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) FindMany(ctx, filter, projection, sort, page, limit, results interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) FindManyWithDeletedAt(ctx, filter, projection, sort, limit, skip, results interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) FindOne(ctx, filter, projection, result interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) Inc(ctx, filter, payload interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) Save(ctx, payload, result interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) SaveMany(ctx, payload interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) UpdateByID(ctx, id, payload interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) UpdateMany(ctx, filter, payload, bulk interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) UpdateOne(ctx, filter, payload interface{}) *gomock.Call

+ func (mr *MockStoreMockRecorder) WithTransaction(ctx, fn interface{}) *gomock.Call

type MockSubscriptionRepository

+ func (m *MockSubscriptionRepository) FindSubscriptionByDeviceID(ctx context.Context, groupId, deviceID string) (*datastore.Subscription, error)

type MockSubscriptionRepositoryMockRecorder

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByDeviceID(ctx, groupId, deviceID interface{}) *gomock.Call

+ type MockWebSocketConnection struct

+ func NewMockWebSocketConnection(ctrl *gomock.Controller) *MockWebSocketConnection

+ func (m *MockWebSocketConnection) Close() error

+ func (m *MockWebSocketConnection) EXPECT() *MockWebSocketConnectionMockRecorder

+ func (m *MockWebSocketConnection) ReadMessage() (int, []byte, error)

+ func (m *MockWebSocketConnection) SetPingHandler(h func(string) error)

+ func (m *MockWebSocketConnection) SetReadLimit(limit int64)

+ func (m *MockWebSocketConnection) WriteMessage(messageType int, data []byte) error

+ type MockWebSocketConnectionMockRecorder struct

+ func (mr *MockWebSocketConnectionMockRecorder) Close() *gomock.Call

+ func (mr *MockWebSocketConnectionMockRecorder) ReadMessage() *gomock.Call

+ func (mr *MockWebSocketConnectionMockRecorder) SetPingHandler(h interface{}) *gomock.Call

+ func (mr *MockWebSocketConnectionMockRecorder) SetReadLimit(limit interface{}) *gomock.Call

+ func (mr *MockWebSocketConnectionMockRecorder) WriteMessage(messageType, data interface{}) *gomock.Call

Jul 25, 2022

Changes in this version

type MockApplicationRepository

+ func (m *MockApplicationRepository) CreateApplicationEndpoint(arg0 context.Context, arg1, arg2 string, arg3 *datastore.Endpoint) error

type MockApplicationRepositoryMockRecorder

+ func (mr *MockApplicationRepositoryMockRecorder) CreateApplicationEndpoint(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockConfigurationRepository struct

+ func NewMockConfigurationRepository(ctrl *gomock.Controller) *MockConfigurationRepository

+ func (m *MockConfigurationRepository) CreateConfiguration(arg0 context.Context, arg1 *datastore.Configuration) error

+ func (m *MockConfigurationRepository) EXPECT() *MockConfigurationRepositoryMockRecorder

+ func (m *MockConfigurationRepository) LoadConfiguration(arg0 context.Context) (*datastore.Configuration, error)

+ func (m *MockConfigurationRepository) UpdateConfiguration(arg0 context.Context, arg1 *datastore.Configuration) error

+ type MockConfigurationRepositoryMockRecorder struct

+ func (mr *MockConfigurationRepositoryMockRecorder) CreateConfiguration(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockConfigurationRepositoryMockRecorder) LoadConfiguration(arg0 interface{}) *gomock.Call

+ func (mr *MockConfigurationRepositoryMockRecorder) UpdateConfiguration(arg0, arg1 interface{}) *gomock.Call

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) DeleteGroupEventDeliveries(ctx context.Context, filter *datastore.EventDeliveryFilter, hardDelete bool) error

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) DeleteGroupEventDeliveries(ctx, filter, hardDelete interface{}) *gomock.Call

type MockEventRepository

+ func (m *MockEventRepository) FindEventsByIDs(arg0 context.Context, arg1 []string) ([]datastore.Event, error)

type MockEventRepositoryMockRecorder

+ func (mr *MockEventRepositoryMockRecorder) FindEventsByIDs(arg0, arg1 interface{}) *gomock.Call

type MockGroupRepository

+ func (m *MockGroupRepository) FillGroupsStatistics(ctx context.Context, groups []*datastore.Group) error

type MockGroupRepositoryMockRecorder

+ func (mr *MockGroupRepositoryMockRecorder) FillGroupsStatistics(ctx, groups interface{}) *gomock.Call

+ type MockOrganisationInviteRepository struct

+ func NewMockOrganisationInviteRepository(ctrl *gomock.Controller) *MockOrganisationInviteRepository

+ func (m *MockOrganisationInviteRepository) CreateOrganisationInvite(ctx context.Context, iv *datastore.OrganisationInvite) error

+ func (m *MockOrganisationInviteRepository) DeleteOrganisationInvite(ctx context.Context, uid string) error

+ func (m *MockOrganisationInviteRepository) EXPECT() *MockOrganisationInviteRepositoryMockRecorder

+ func (m *MockOrganisationInviteRepository) FetchOrganisationInviteByID(ctx context.Context, uid string) (*datastore.OrganisationInvite, error)

+ func (m *MockOrganisationInviteRepository) FetchOrganisationInviteByToken(ctx context.Context, token string) (*datastore.OrganisationInvite, error)

+ func (m *MockOrganisationInviteRepository) LoadOrganisationsInvitesPaged(ctx context.Context, orgID string, inviteStatus datastore.InviteStatus, ...) ([]datastore.OrganisationInvite, datastore.PaginationData, error)

+ func (m *MockOrganisationInviteRepository) UpdateOrganisationInvite(ctx context.Context, iv *datastore.OrganisationInvite) error

+ type MockOrganisationInviteRepositoryMockRecorder struct

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) CreateOrganisationInvite(ctx, iv interface{}) *gomock.Call

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) DeleteOrganisationInvite(ctx, uid interface{}) *gomock.Call

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByID(ctx, uid interface{}) *gomock.Call

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByToken(ctx, token interface{}) *gomock.Call

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) LoadOrganisationsInvitesPaged(ctx, orgID, inviteStatus, pageable interface{}) *gomock.Call

+ func (mr *MockOrganisationInviteRepositoryMockRecorder) UpdateOrganisationInvite(ctx, iv interface{}) *gomock.Call

+ type MockOrganisationMemberRepository struct

+ func NewMockOrganisationMemberRepository(ctrl *gomock.Controller) *MockOrganisationMemberRepository

+ func (m *MockOrganisationMemberRepository) CreateOrganisationMember(ctx context.Context, member *datastore.OrganisationMember) error

+ func (m *MockOrganisationMemberRepository) DeleteOrganisationMember(ctx context.Context, memberID, orgID string) error

+ func (m *MockOrganisationMemberRepository) EXPECT() *MockOrganisationMemberRepositoryMockRecorder

+ func (m *MockOrganisationMemberRepository) FetchOrganisationMemberByID(ctx context.Context, memberID, organisationID string) (*datastore.OrganisationMember, error)

+ func (m *MockOrganisationMemberRepository) FetchOrganisationMemberByUserID(ctx context.Context, userID, organisationID string) (*datastore.OrganisationMember, error)

+ func (m *MockOrganisationMemberRepository) LoadOrganisationMembersPaged(ctx context.Context, organisationID string, pageable datastore.Pageable) ([]*datastore.OrganisationMember, datastore.PaginationData, error)

+ func (m *MockOrganisationMemberRepository) LoadUserOrganisationsPaged(ctx context.Context, userID string, pageable datastore.Pageable) ([]datastore.Organisation, datastore.PaginationData, error)

+ func (m *MockOrganisationMemberRepository) UpdateOrganisationMember(ctx context.Context, member *datastore.OrganisationMember) error

+ type MockOrganisationMemberRepositoryMockRecorder struct

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) CreateOrganisationMember(ctx, member interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) DeleteOrganisationMember(ctx, memberID, orgID interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByID(ctx, memberID, organisationID interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByUserID(ctx, userID, organisationID interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) LoadOrganisationMembersPaged(ctx, organisationID, pageable interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) LoadUserOrganisationsPaged(ctx, userID, pageable interface{}) *gomock.Call

+ func (mr *MockOrganisationMemberRepositoryMockRecorder) UpdateOrganisationMember(ctx, member interface{}) *gomock.Call

type MockOrganisationRepository

+ func (m *MockOrganisationRepository) DeleteOrganisation(arg0 context.Context, arg1 string) error

+ func (m *MockOrganisationRepository) LoadOrganisationsPaged(arg0 context.Context, arg1 datastore.Pageable) ([]datastore.Organisation, datastore.PaginationData, error)

type MockOrganisationRepositoryMockRecorder

+ func (mr *MockOrganisationRepositoryMockRecorder) DeleteOrganisation(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOrganisationRepositoryMockRecorder) LoadOrganisationsPaged(arg0, arg1 interface{}) *gomock.Call

type MockQueuer

+ func (m *MockQueuer) Options() queue.QueueOptions

type MockQueuerMockRecorder

+ func (mr *MockQueuerMockRecorder) Options() *gomock.Call

+ type MockSearcher struct

+ func NewMockSearcher(ctrl *gomock.Controller) *MockSearcher

+ func (m *MockSearcher) EXPECT() *MockSearcherMockRecorder

+ func (m *MockSearcher) Index(collection string, document convoy.GenericMap) error

+ func (m *MockSearcher) Remove(collection string, filter *datastore.Filter) error

+ func (m *MockSearcher) Search(collection string, filter *datastore.Filter) ([]string, datastore.PaginationData, error)

+ type MockSearcherMockRecorder struct

+ func (mr *MockSearcherMockRecorder) Index(collection, document interface{}) *gomock.Call

+ func (mr *MockSearcherMockRecorder) Remove(collection, filter interface{}) *gomock.Call

+ func (mr *MockSearcherMockRecorder) Search(collection, filter interface{}) *gomock.Call

+ type MockSmtpClient struct

+ func NewMockSmtpClient(ctrl *gomock.Controller) *MockSmtpClient

+ func (m *MockSmtpClient) EXPECT() *MockSmtpClientMockRecorder

+ func (m *MockSmtpClient) SendEmail(emailAddr, subject string, body bytes.Buffer) error

+ type MockSmtpClientMockRecorder struct

+ func (mr *MockSmtpClientMockRecorder) SendEmail(emailAddr, subject, body interface{}) *gomock.Call

+ type MockSourceRepository struct

+ func NewMockSourceRepository(ctrl *gomock.Controller) *MockSourceRepository

+ func (m *MockSourceRepository) CreateSource(arg0 context.Context, arg1 *datastore.Source) error

+ func (m *MockSourceRepository) DeleteSourceByID(ctx context.Context, groupID, id string) error

+ func (m *MockSourceRepository) EXPECT() *MockSourceRepositoryMockRecorder

+ func (m *MockSourceRepository) FindSourceByID(ctx context.Context, groupID, id string) (*datastore.Source, error)

+ func (m *MockSourceRepository) FindSourceByMaskID(ctx context.Context, maskID string) (*datastore.Source, error)

+ func (m *MockSourceRepository) LoadSourcesPaged(ctx context.Context, groupID string, filter *datastore.SourceFilter, ...) ([]datastore.Source, datastore.PaginationData, error)

+ func (m *MockSourceRepository) UpdateSource(ctx context.Context, groupID string, source *datastore.Source) error

+ type MockSourceRepositoryMockRecorder struct

+ func (mr *MockSourceRepositoryMockRecorder) CreateSource(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockSourceRepositoryMockRecorder) DeleteSourceByID(ctx, groupID, id interface{}) *gomock.Call

+ func (mr *MockSourceRepositoryMockRecorder) FindSourceByID(ctx, groupID, id interface{}) *gomock.Call

+ func (mr *MockSourceRepositoryMockRecorder) FindSourceByMaskID(ctx, maskID interface{}) *gomock.Call

+ func (mr *MockSourceRepositoryMockRecorder) LoadSourcesPaged(ctx, groupID, filter, pageable interface{}) *gomock.Call

+ func (mr *MockSourceRepositoryMockRecorder) UpdateSource(ctx, groupID, source interface{}) *gomock.Call

+ type MockSubscriptionRepository struct

+ func NewMockSubscriptionRepository(ctrl *gomock.Controller) *MockSubscriptionRepository

+ func (m *MockSubscriptionRepository) CreateSubscription(arg0 context.Context, arg1 string, arg2 *datastore.Subscription) error

+ func (m *MockSubscriptionRepository) DeleteSubscription(arg0 context.Context, arg1 string, arg2 *datastore.Subscription) error

+ func (m *MockSubscriptionRepository) EXPECT() *MockSubscriptionRepositoryMockRecorder

+ func (m *MockSubscriptionRepository) FindSubscriptionByID(arg0 context.Context, arg1, arg2 string) (*datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) FindSubscriptionsByAppID(ctx context.Context, groupId, appID string) ([]datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) FindSubscriptionsByEventType(arg0 context.Context, arg1, arg2 string, arg3 datastore.EventType) ([]datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) FindSubscriptionsBySourceIDs(arg0 context.Context, arg1, arg2 string) ([]datastore.Subscription, error)

+ func (m *MockSubscriptionRepository) LoadSubscriptionsPaged(arg0 context.Context, arg1 string, arg2 datastore.Pageable) ([]datastore.Subscription, datastore.PaginationData, error)

+ func (m *MockSubscriptionRepository) UpdateSubscription(arg0 context.Context, arg1 string, arg2 *datastore.Subscription) error

+ func (m *MockSubscriptionRepository) UpdateSubscriptionStatus(arg0 context.Context, arg1, arg2 string, arg3 datastore.SubscriptionStatus) error

+ type MockSubscriptionRepositoryMockRecorder struct

+ func (mr *MockSubscriptionRepositoryMockRecorder) CreateSubscription(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) DeleteSubscription(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByID(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByAppID(ctx, groupId, appID interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByEventType(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsBySourceIDs(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) LoadSubscriptionsPaged(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) UpdateSubscription(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockSubscriptionRepositoryMockRecorder) UpdateSubscriptionStatus(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockUserRepository struct

+ func NewMockUserRepository(ctrl *gomock.Controller) *MockUserRepository

+ func (m *MockUserRepository) CreateUser(arg0 context.Context, arg1 *datastore.User) error

+ func (m *MockUserRepository) EXPECT() *MockUserRepositoryMockRecorder

+ func (m *MockUserRepository) FindUserByEmail(arg0 context.Context, arg1 string) (*datastore.User, error)

+ func (m *MockUserRepository) FindUserByID(arg0 context.Context, arg1 string) (*datastore.User, error)

+ func (m *MockUserRepository) FindUserByToken(arg0 context.Context, arg1 string) (*datastore.User, error)

+ func (m *MockUserRepository) LoadUsersPaged(arg0 context.Context, arg1 datastore.Pageable) ([]datastore.User, datastore.PaginationData, error)

+ func (m *MockUserRepository) UpdateUser(ctx context.Context, user *datastore.User) error

+ type MockUserRepositoryMockRecorder struct

+ func (mr *MockUserRepositoryMockRecorder) CreateUser(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockUserRepositoryMockRecorder) FindUserByEmail(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockUserRepositoryMockRecorder) FindUserByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockUserRepositoryMockRecorder) FindUserByToken(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockUserRepositoryMockRecorder) LoadUsersPaged(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockUserRepositoryMockRecorder) UpdateUser(ctx, user interface{}) *gomock.Call

Apr 25, 2022

Changes in this version

+ type MockCache struct

+ func NewMockCache(ctrl *gomock.Controller) *MockCache

+ func (m *MockCache) Delete(ctx context.Context, key string) error

+ func (m *MockCache) EXPECT() *MockCacheMockRecorder

+ func (m *MockCache) Get(ctx context.Context, key string, data interface{}) error

+ func (m *MockCache) Set(ctx context.Context, key string, data interface{}, expiration time.Duration) error

+ type MockCacheMockRecorder struct

+ func (mr *MockCacheMockRecorder) Delete(ctx, key interface{}) *gomock.Call

+ func (mr *MockCacheMockRecorder) Get(ctx, key, data interface{}) *gomock.Call

+ func (mr *MockCacheMockRecorder) Set(ctx, key, data, expiration interface{}) *gomock.Call

type MockQueuer

+ func (m *MockQueuer) WriteEvent(arg0 context.Context, arg1 convoy.TaskName, arg2 *datastore.Event, ...) error

+ func (m *MockQueuer) WriteEventDelivery(arg0 context.Context, arg1 convoy.TaskName, arg2 *datastore.EventDelivery, ...) error

type MockQueuerMockRecorder

+ func (mr *MockQueuerMockRecorder) WriteEvent(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockQueuerMockRecorder) WriteEventDelivery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockSender struct

+ func NewMockSender(ctrl *gomock.Controller) *MockSender

+ func (m *MockSender) EXPECT() *MockSenderMockRecorder

+ func (m *MockSender) SendNotification(arg0 context.Context, arg1 *notification.Notification) error

+ type MockSenderMockRecorder struct

+ func (mr *MockSenderMockRecorder) SendNotification(arg0, arg1 interface{}) *gomock.Call

type MockTracer

+ func (m *MockTracer) NewContext(ctx context.Context, txn *newrelic.Transaction) context.Context

type MockTracerMockRecorder

+ func (mr *MockTracerMockRecorder) NewContext(ctx, txn interface{}) *gomock.Call

Mar 25, 2022

Changes in this version

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) CountEventDeliveries(arg0 context.Context, arg1, arg2, arg3 string, ...) (int64, error)

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) CountEventDeliveries(arg0, arg1, arg2, arg3, arg4, arg5 interface{}) *gomock.Call

+ type MockRateLimiter struct

+ func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter

+ func (m *MockRateLimiter) Allow(ctx context.Context, key string, limit, duration int) (*redis_rate.Result, error)

+ func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder

+ func (m *MockRateLimiter) ShouldAllow(ctx context.Context, key string, limit, duration int) (*redis_rate.Result, error)

+ type MockRateLimiterMockRecorder struct

+ func (mr *MockRateLimiterMockRecorder) Allow(ctx, key, limit, duration interface{}) *gomock.Call

+ func (mr *MockRateLimiterMockRecorder) ShouldAllow(ctx, key, limit, duration interface{}) *gomock.Call

Mar 9, 2022

Changes in this version

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) UpdateStatusOfEventDeliveries(arg0 context.Context, arg1 []string, arg2 datastore.EventDeliveryStatus) error

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDeliveries(arg0, arg1, arg2 interface{}) *gomock.Call

Mar 7, 2022

Changes in this version

type MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) CountDeliveriesByStatus(arg0 context.Context, arg1 datastore.EventDeliveryStatus) (int64, error)

type MockEventDeliveryRepositoryMockRecorder

+ func (mr *MockEventDeliveryRepositoryMockRecorder) CountDeliveriesByStatus(arg0, arg1 interface{}) *gomock.Call

Dec 25, 2021

Changes in this version

type MockEventRepository

+ func (m *MockEventRepository) LoadAbandonedEventsForPostingRetry(arg0 context.Context) ([]convoy.Event, error)

+ func (m *MockEventRepository) LoadEventsForPostingRetry(arg0 context.Context) ([]convoy.Event, error)

+ func (m *MockEventRepository) LoadEventsPagedByAppId(arg0 context.Context, arg1 string, arg2 models.SearchParams, ...) ([]convoy.Event, mongopagination.PaginationData, error)

+ func (m *MockEventRepository) LoadEventsScheduledForPosting(arg0 context.Context) ([]convoy.Event, error)

type MockEventRepositoryMockRecorder

+ func (mr *MockEventRepositoryMockRecorder) LoadAbandonedEventsForPostingRetry(arg0 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) LoadEventsForPostingRetry(arg0 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) LoadEventsPagedByAppId(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) LoadEventsScheduledForPosting(arg0 interface{}) *gomock.Call

Sep 7, 2021

Changes in this version

type MockApplicationRepository

+ func (m *MockApplicationRepository) LoadApplications(arg0 context.Context, s string) ([]convoy.Application, error)

+ func (m *MockApplicationRepository) LoadApplicationsPagedByOrgId(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Application, mongopagination.PaginationData, error)

+ func (m *MockApplicationRepository) SearchApplicationsByOrgId(arg0 context.Context, arg1 string, arg2 models.SearchParams) ([]convoy.Application, error)

type MockApplicationRepositoryMockRecorder

+ func (mr *MockApplicationRepositoryMockRecorder) LoadApplications(arg0 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPagedByOrgId(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) SearchApplicationsByOrgId(arg0, arg1, arg2 interface{}) *gomock.Call

+ type MockMessageRepository struct

+ func NewMockMessageRepository(ctrl *gomock.Controller) *MockMessageRepository

+ func (m *MockMessageRepository) CreateMessage(arg0 context.Context, arg1 *convoy.Message) error

+ func (m *MockMessageRepository) EXPECT() *MockMessageRepositoryMockRecorder

+ func (m *MockMessageRepository) FindMessageByID(ctx context.Context, id string) (*convoy.Message, error)

+ func (m *MockMessageRepository) LoadAbandonedMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)

+ func (m *MockMessageRepository) LoadMessageIntervals(arg0 context.Context, arg1 string, arg2 models.SearchParams, ...) ([]models.MessageInterval, error)

+ func (m *MockMessageRepository) LoadMessagesForPostingRetry(arg0 context.Context) ([]convoy.Message, error)

+ func (m *MockMessageRepository) LoadMessagesPaged(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Message, mongopagination.PaginationData, error)

+ func (m *MockMessageRepository) LoadMessagesPagedByAppId(arg0 context.Context, arg1 string, arg2 models.Pageable) ([]convoy.Message, mongopagination.PaginationData, error)

+ func (m *MockMessageRepository) LoadMessagesScheduledForPosting(arg0 context.Context) ([]convoy.Message, error)

+ func (m *MockMessageRepository) UpdateStatusOfMessages(arg0 context.Context, arg1 []convoy.Message, arg2 convoy.MessageStatus) error

+ func (m_2 *MockMessageRepository) UpdateMessageWithAttempt(ctx context.Context, m convoy.Message, attempt convoy.MessageAttempt) error

+ type MockMessageRepositoryMockRecorder struct

+ func (mr *MockMessageRepositoryMockRecorder) CreateMessage(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) FindMessageByID(ctx, id interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadAbandonedMessagesForPostingRetry(arg0 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadMessageIntervals(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadMessagesForPostingRetry(arg0 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPaged(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadMessagesPagedByAppId(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) LoadMessagesScheduledForPosting(arg0 interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) UpdateMessageWithAttempt(ctx, m, attempt interface{}) *gomock.Call

+ func (mr *MockMessageRepositoryMockRecorder) UpdateStatusOfMessages(arg0, arg1, arg2 interface{}) *gomock.Call

+ type MockOrganisationRepository struct

+ func NewMockOrganisationRepository(ctrl *gomock.Controller) *MockOrganisationRepository

+ func (m *MockOrganisationRepository) CreateOrganisation(arg0 context.Context, arg1 *convoy.Organisation) error

+ func (m *MockOrganisationRepository) EXPECT() *MockOrganisationRepositoryMockRecorder

+ func (m *MockOrganisationRepository) FetchOrganisationByID(arg0 context.Context, arg1 string) (*convoy.Organisation, error)

+ func (m *MockOrganisationRepository) LoadOrganisations(arg0 context.Context) ([]*convoy.Organisation, error)

+ func (m *MockOrganisationRepository) UpdateOrganisation(arg0 context.Context, arg1 *convoy.Organisation) error

+ type MockOrganisationRepositoryMockRecorder struct

+ func (mr *MockOrganisationRepositoryMockRecorder) CreateOrganisation(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockOrganisationRepositoryMockRecorder) LoadOrganisations(arg0 interface{}) *gomock.Call

+ func (mr *MockOrganisationRepositoryMockRecorder) UpdateOrganisation(arg0, arg1 interface{}) *gomock.Call

Feb 16, 2022

Changes in this version

+ type MockAPIKeyRepository struct

+ func NewMockAPIKeyRepository(ctrl *gomock.Controller) *MockAPIKeyRepository

+ func (m *MockAPIKeyRepository) CreateAPIKey(arg0 context.Context, arg1 *datastore.APIKey) error

+ func (m *MockAPIKeyRepository) EXPECT() *MockAPIKeyRepositoryMockRecorder

+ func (m *MockAPIKeyRepository) FindAPIKeyByHash(arg0 context.Context, arg1 string) (*datastore.APIKey, error)

+ func (m *MockAPIKeyRepository) FindAPIKeyByID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)

+ func (m *MockAPIKeyRepository) FindAPIKeyByMaskID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)

+ func (m *MockAPIKeyRepository) LoadAPIKeysPaged(arg0 context.Context, arg1 *datastore.Pageable) ([]datastore.APIKey, datastore.PaginationData, error)

+ func (m *MockAPIKeyRepository) RevokeAPIKeys(arg0 context.Context, arg1 []string) error

+ func (m *MockAPIKeyRepository) UpdateAPIKey(arg0 context.Context, arg1 *datastore.APIKey) error

+ type MockAPIKeyRepositoryMockRecorder struct

+ func (mr *MockAPIKeyRepositoryMockRecorder) CreateAPIKey(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByHash(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByMaskID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) LoadAPIKeysPaged(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) RevokeAPIKeys(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockAPIKeyRepositoryMockRecorder) UpdateAPIKey(arg0, arg1 interface{}) *gomock.Call

+ type MockApplicationRepository struct

+ func NewMockApplicationRepository(ctrl *gomock.Controller) *MockApplicationRepository

+ func (m *MockApplicationRepository) CountGroupApplications(ctx context.Context, groupID string) (int64, error)

+ func (m *MockApplicationRepository) CreateApplication(arg0 context.Context, arg1 *datastore.Application) error

+ func (m *MockApplicationRepository) DeleteApplication(arg0 context.Context, arg1 *datastore.Application) error

+ func (m *MockApplicationRepository) DeleteGroupApps(arg0 context.Context, arg1 string) error

+ func (m *MockApplicationRepository) EXPECT() *MockApplicationRepositoryMockRecorder

+ func (m *MockApplicationRepository) FindApplicationByID(arg0 context.Context, arg1 string) (*datastore.Application, error)

+ func (m *MockApplicationRepository) FindApplicationEndpointByID(arg0 context.Context, arg1, arg2 string) (*datastore.Endpoint, error)

+ func (m *MockApplicationRepository) LoadApplicationsPaged(arg0 context.Context, arg1, arg2 string, arg3 datastore.Pageable) ([]datastore.Application, datastore.PaginationData, error)

+ func (m *MockApplicationRepository) LoadApplicationsPagedByGroupId(arg0 context.Context, arg1 string, arg2 datastore.Pageable) ([]datastore.Application, datastore.PaginationData, error)

+ func (m *MockApplicationRepository) SearchApplicationsByGroupId(arg0 context.Context, arg1 string, arg2 datastore.SearchParams) ([]datastore.Application, error)

+ func (m *MockApplicationRepository) UpdateApplication(arg0 context.Context, arg1 *datastore.Application) error

+ func (m *MockApplicationRepository) UpdateApplicationEndpointsStatus(arg0 context.Context, arg1 string, arg2 []string, ...) error

+ type MockApplicationRepositoryMockRecorder struct

+ func (mr *MockApplicationRepositoryMockRecorder) CountGroupApplications(ctx, groupID interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) CreateApplication(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) DeleteApplication(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) DeleteGroupApps(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) FindApplicationByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) FindApplicationEndpointByID(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPaged(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) LoadApplicationsPagedByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) SearchApplicationsByGroupId(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) UpdateApplication(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockApplicationRepositoryMockRecorder) UpdateApplicationEndpointsStatus(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockEventDeliveryRepository struct

+ func NewMockEventDeliveryRepository(ctrl *gomock.Controller) *MockEventDeliveryRepository

+ func (m *MockEventDeliveryRepository) CreateEventDelivery(arg0 context.Context, arg1 *datastore.EventDelivery) error

+ func (m *MockEventDeliveryRepository) EXPECT() *MockEventDeliveryRepositoryMockRecorder

+ func (m *MockEventDeliveryRepository) FindEventDeliveriesByEventID(arg0 context.Context, arg1 string) ([]datastore.EventDelivery, error)

+ func (m *MockEventDeliveryRepository) FindEventDeliveriesByIDs(arg0 context.Context, arg1 []string) ([]datastore.EventDelivery, error)

+ func (m *MockEventDeliveryRepository) FindEventDeliveryByID(arg0 context.Context, arg1 string) (*datastore.EventDelivery, error)

+ func (m *MockEventDeliveryRepository) LoadEventDeliveriesPaged(arg0 context.Context, arg1, arg2, arg3 string, ...) ([]datastore.EventDelivery, datastore.PaginationData, error)

+ func (m *MockEventDeliveryRepository) UpdateEventDeliveryWithAttempt(arg0 context.Context, arg1 datastore.EventDelivery, ...) error

+ func (m *MockEventDeliveryRepository) UpdateStatusOfEventDelivery(arg0 context.Context, arg1 datastore.EventDelivery, ...) error

+ type MockEventDeliveryRepositoryMockRecorder struct

+ func (mr *MockEventDeliveryRepositoryMockRecorder) CreateEventDelivery(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByEventID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByIDs(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveryByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesPaged(arg0, arg1, arg2, arg3, arg4, arg5, arg6 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateEventDeliveryWithAttempt(arg0, arg1, arg2 interface{}) *gomock.Call

+ func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDelivery(arg0, arg1, arg2 interface{}) *gomock.Call

+ type MockEventRepository struct

+ func NewMockEventRepository(ctrl *gomock.Controller) *MockEventRepository

+ func (m *MockEventRepository) CountGroupMessages(ctx context.Context, groupID string) (int64, error)

+ func (m *MockEventRepository) CreateEvent(arg0 context.Context, arg1 *datastore.Event) error

+ func (m *MockEventRepository) DeleteGroupEvents(arg0 context.Context, arg1 string) error

+ func (m *MockEventRepository) EXPECT() *MockEventRepositoryMockRecorder

+ func (m *MockEventRepository) FindEventByID(ctx context.Context, id string) (*datastore.Event, error)

+ func (m *MockEventRepository) LoadEventIntervals(arg0 context.Context, arg1 string, arg2 datastore.SearchParams, ...) ([]datastore.EventInterval, error)

+ func (m *MockEventRepository) LoadEventsPaged(arg0 context.Context, arg1, arg2 string, arg3 datastore.SearchParams, ...) ([]datastore.Event, datastore.PaginationData, error)

+ type MockEventRepositoryMockRecorder struct

+ func (mr *MockEventRepositoryMockRecorder) CountGroupMessages(ctx, groupID interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) CreateEvent(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) DeleteGroupEvents(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) FindEventByID(ctx, id interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) LoadEventIntervals(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

+ func (mr *MockEventRepositoryMockRecorder) LoadEventsPaged(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

+ type MockGroupRepository struct

+ func NewMockGroupRepository(ctrl *gomock.Controller) *MockGroupRepository

+ func (m *MockGroupRepository) CreateGroup(arg0 context.Context, arg1 *datastore.Group) error

+ func (m *MockGroupRepository) DeleteGroup(ctx context.Context, uid string) error

+ func (m *MockGroupRepository) EXPECT() *MockGroupRepositoryMockRecorder

+ func (m *MockGroupRepository) FetchGroupByID(arg0 context.Context, arg1 string) (*datastore.Group, error)

+ func (m *MockGroupRepository) FetchGroupsByIDs(arg0 context.Context, arg1 []string) ([]datastore.Group, error)

+ func (m *MockGroupRepository) LoadGroups(arg0 context.Context, arg1 *datastore.GroupFilter) ([]*datastore.Group, error)

+ func (m *MockGroupRepository) UpdateGroup(arg0 context.Context, arg1 *datastore.Group) error

+ type MockGroupRepositoryMockRecorder struct

+ func (mr *MockGroupRepositoryMockRecorder) CreateGroup(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockGroupRepositoryMockRecorder) DeleteGroup(ctx, uid interface{}) *gomock.Call

+ func (mr *MockGroupRepositoryMockRecorder) FetchGroupByID(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockGroupRepositoryMockRecorder) FetchGroupsByIDs(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockGroupRepositoryMockRecorder) LoadGroups(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockGroupRepositoryMockRecorder) UpdateGroup(arg0, arg1 interface{}) *gomock.Call

+ type MockQueuer struct

+ func NewMockQueuer(ctrl *gomock.Controller) *MockQueuer

+ func (m *MockQueuer) Close() error

+ func (m *MockQueuer) Consumer() taskq.QueueConsumer

+ func (m *MockQueuer) EXPECT() *MockQueuerMockRecorder

+ func (m *MockQueuer) Write(arg0 context.Context, arg1 convoy.TaskName, arg2 *datastore.EventDelivery, ...) error

+ type MockQueuerMockRecorder struct

+ func (mr *MockQueuerMockRecorder) Close() *gomock.Call

+ func (mr *MockQueuerMockRecorder) Consumer() *gomock.Call

+ func (mr *MockQueuerMockRecorder) Write(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

+ type MockTracer struct

+ func NewMockTracer(ctrl *gomock.Controller) *MockTracer

+ func (m *MockTracer) EXPECT() *MockTracerMockRecorder

+ func (m *MockTracer) RequestWithTransactionContext(r *http.Request, txn *newrelic.Transaction) *http.Request

+ func (m *MockTracer) SetWebRequestHTTP(r *http.Request, txn *newrelic.Transaction)

+ func (m *MockTracer) SetWebResponse(w http.ResponseWriter, txn *newrelic.Transaction) http.ResponseWriter

+ func (m *MockTracer) StartTransaction(name string) *newrelic.Transaction

+ type MockTracerMockRecorder struct

+ func (mr *MockTracerMockRecorder) RequestWithTransactionContext(r, txn interface{}) *gomock.Call

+ func (mr *MockTracerMockRecorder) SetWebRequestHTTP(r, txn interface{}) *gomock.Call

+ func (mr *MockTracerMockRecorder) SetWebResponse(w, txn interface{}) *gomock.Call

+ func (mr *MockTracerMockRecorder) StartTransaction(name interface{}) *gomock.Call