Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type 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) FindAPIKeyByProjectID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)
- func (m *MockAPIKeyRepository) LoadAPIKeysPaged(arg0 context.Context, arg1 *datastore.ApiKeyFilter, arg2 *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
- 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) FindAPIKeyByProjectID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAPIKeyRepositoryMockRecorder) LoadAPIKeysPaged(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockAPIKeyRepositoryMockRecorder) RevokeAPIKeys(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockAPIKeyRepositoryMockRecorder) UpdateAPIKey(arg0, arg1 interface{}) *gomock.Call
- type 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
- type 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
- 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 MockDeviceRepository
- func (m *MockDeviceRepository) CreateDevice(ctx context.Context, device *datastore.Device) error
- func (m *MockDeviceRepository) DeleteDevice(ctx context.Context, uid, appID, projectID string) error
- func (m *MockDeviceRepository) EXPECT() *MockDeviceRepositoryMockRecorder
- func (m *MockDeviceRepository) FetchDeviceByHostName(ctx context.Context, hostName, appID, projectID string) (*datastore.Device, error)
- func (m *MockDeviceRepository) FetchDeviceByID(ctx context.Context, uid, appID, projectID string) (*datastore.Device, error)
- func (m *MockDeviceRepository) LoadDevicesPaged(ctx context.Context, projectID string, filter *datastore.ApiKeyFilter, ...) ([]datastore.Device, datastore.PaginationData, error)
- func (m *MockDeviceRepository) UpdateDevice(ctx context.Context, device *datastore.Device, appID, projectID string) error
- func (m *MockDeviceRepository) UpdateDeviceLastSeen(ctx context.Context, device *datastore.Device, appID, projectID string, ...) error
- type MockDeviceRepositoryMockRecorder
- func (mr *MockDeviceRepositoryMockRecorder) CreateDevice(ctx, device interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) DeleteDevice(ctx, uid, appID, projectID interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByHostName(ctx, hostName, appID, projectID interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByID(ctx, uid, appID, projectID interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) LoadDevicesPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) UpdateDevice(ctx, device, appID, projectID interface{}) *gomock.Call
- func (mr *MockDeviceRepositoryMockRecorder) UpdateDeviceLastSeen(ctx, device, appID, projectID, status interface{}) *gomock.Call
- type 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, projectID string) error
- func (m *MockEndpointRepository) DeleteSecret(ctx context.Context, endpoint *datastore.Endpoint, secretID, projectID string) error
- func (m *MockEndpointRepository) EXPECT() *MockEndpointRepositoryMockRecorder
- func (m *MockEndpointRepository) FindEndpointByID(ctx context.Context, id, projectID string) (*datastore.Endpoint, error)
- func (m *MockEndpointRepository) FindEndpointByTargetURL(ctx context.Context, projectID, targetURL string) (*datastore.Endpoint, error)
- func (m *MockEndpointRepository) FindEndpointsByAppID(ctx context.Context, appID, projectID string) ([]datastore.Endpoint, error)
- func (m *MockEndpointRepository) FindEndpointsByID(ctx context.Context, ids []string, projectID 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 string, filter *datastore.Filter, ...) ([]datastore.Endpoint, datastore.PaginationData, error)
- func (m *MockEndpointRepository) UpdateEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error
- func (m *MockEndpointRepository) UpdateEndpointStatus(ctx context.Context, projectID, endpointID string, ...) error
- func (m *MockEndpointRepository) UpdateSecrets(ctx context.Context, endpointID, projectID string, secrets datastore.Secrets) error
- type MockEndpointRepositoryMockRecorder
- 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, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) DeleteSecret(ctx, endpoint, secretID, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByID(ctx, id, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByTargetURL(ctx, projectID, targetURL interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByAppID(ctx, appID, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByID(ctx, ids, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByOwnerID(ctx, projectID, ownerID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) LoadEndpointsPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpointStatus(ctx, projectID, endpointID, status interface{}) *gomock.Call
- func (mr *MockEndpointRepositoryMockRecorder) UpdateSecrets(ctx, endpointID, projectID, secrets interface{}) *gomock.Call
- type MockEventDeliveryRepository
- func (m *MockEventDeliveryRepository) CountDeliveriesByStatus(ctx context.Context, projectID string, status datastore.EventDeliveryStatus, ...) (int64, error)
- func (m *MockEventDeliveryRepository) CountEventDeliveries(ctx context.Context, projectID string, endpointIDs []string, eventID string, ...) (int64, error)
- func (m *MockEventDeliveryRepository) CreateEventDelivery(arg0 context.Context, arg1 *datastore.EventDelivery) error
- func (m *MockEventDeliveryRepository) DeleteProjectEventDeliveries(ctx context.Context, projectID string, filter *datastore.EventDeliveryFilter, ...) error
- func (m *MockEventDeliveryRepository) EXPECT() *MockEventDeliveryRepositoryMockRecorder
- func (m *MockEventDeliveryRepository) FindDiscardedEventDeliveries(ctx context.Context, projectID, deviceId string, params datastore.SearchParams) ([]datastore.EventDelivery, error)
- func (m *MockEventDeliveryRepository) FindEventDeliveriesByEventID(ctx context.Context, projectID, id string) ([]datastore.EventDelivery, error)
- func (m *MockEventDeliveryRepository) FindEventDeliveriesByIDs(ctx context.Context, projectID string, ids []string) ([]datastore.EventDelivery, error)
- func (m *MockEventDeliveryRepository) FindEventDeliveryByID(ctx context.Context, projectID, id string) (*datastore.EventDelivery, error)
- func (m *MockEventDeliveryRepository) LoadEventDeliveriesIntervals(ctx context.Context, projectID string, params datastore.SearchParams, ...) ([]datastore.EventInterval, error)
- func (m *MockEventDeliveryRepository) LoadEventDeliveriesPaged(ctx context.Context, projectID string, endpointIDs []string, ...) ([]datastore.EventDelivery, datastore.PaginationData, error)
- func (m *MockEventDeliveryRepository) UpdateEventDeliveryWithAttempt(ctx context.Context, projectID string, eventDelivery datastore.EventDelivery, ...) error
- func (m *MockEventDeliveryRepository) UpdateStatusOfEventDeliveries(ctx context.Context, projectID string, ids []string, ...) error
- func (m *MockEventDeliveryRepository) UpdateStatusOfEventDelivery(ctx context.Context, projectID string, eventDelivery datastore.EventDelivery, ...) error
- type MockEventDeliveryRepositoryMockRecorder
- func (mr *MockEventDeliveryRepositoryMockRecorder) CountDeliveriesByStatus(ctx, projectID, status, params interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) CountEventDeliveries(ctx, projectID, endpointIDs, eventID, status, params interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) CreateEventDelivery(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) DeleteProjectEventDeliveries(ctx, projectID, filter, hardDelete interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) FindDiscardedEventDeliveries(ctx, projectID, deviceId, params interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByEventID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByIDs(ctx, projectID, ids interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveryByID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesIntervals(ctx, projectID, params, period interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesPaged(...) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateEventDeliveryWithAttempt(ctx, projectID, eventDelivery, attempt interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDeliveries(ctx, projectID, ids, status interface{}) *gomock.Call
- func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDelivery(ctx, projectID, eventDelivery, status interface{}) *gomock.Call
- type MockEventRepository
- func (m *MockEventRepository) CopyRows(ctx context.Context, projectID string, interval int) error
- func (m *MockEventRepository) CountEvents(ctx context.Context, projectID string, f *datastore.Filter) (int64, error)
- func (m *MockEventRepository) CountProjectMessages(ctx context.Context, projectID string) (int64, error)
- func (m *MockEventRepository) CreateEvent(arg0 context.Context, arg1 *datastore.Event) error
- func (m *MockEventRepository) DeleteProjectEvents(ctx context.Context, projectID string, f *datastore.EventFilter, ...) error
- func (m *MockEventRepository) DeleteProjectTokenizedEvents(ctx context.Context, projectID string, filter *datastore.EventFilter) error
- func (m *MockEventRepository) EXPECT() *MockEventRepositoryMockRecorder
- func (m *MockEventRepository) FindEventByID(ctx context.Context, projectID, id string) (*datastore.Event, error)
- func (m *MockEventRepository) FindEventsByIDs(ctx context.Context, projectID string, ids []string) ([]datastore.Event, 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)
- func (m *MockEventRepository) LoadEventsPaged(ctx context.Context, projectID string, f *datastore.Filter) ([]datastore.Event, datastore.PaginationData, error)
- type MockEventRepositoryMockRecorder
- func (mr *MockEventRepositoryMockRecorder) CopyRows(ctx, projectID, interval interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) CountEvents(ctx, projectID, f interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) CountProjectMessages(ctx, projectID interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) CreateEvent(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) DeleteProjectEvents(ctx, projectID, f, hardDelete interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) DeleteProjectTokenizedEvents(ctx, projectID, filter interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) FindEventByID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) FindEventsByIDs(ctx, projectID, ids interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) FindEventsByIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) FindFirstEventWithIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call
- func (mr *MockEventRepositoryMockRecorder) LoadEventsPaged(ctx, projectID, f interface{}) *gomock.Call
- type MockExportRepository
- type MockExportRepositoryMockRecorder
- type MockIdempotency
- type MockIdempotencyMockRecorder
- type 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
- 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
- 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
- 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 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
- 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
- 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) FindUserProjects(ctx context.Context, userID string) ([]datastore.Project, error)
- func (m *MockOrganisationMemberRepository) LoadOrganisationMembersPaged(ctx context.Context, organisationID, userID string, ...) ([]*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
- 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) FindUserProjects(ctx, userID interface{}) *gomock.Call
- func (mr *MockOrganisationMemberRepositoryMockRecorder) LoadOrganisationMembersPaged(ctx, organisationID, userID, 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) CreateOrganisation(arg0 context.Context, arg1 *datastore.Organisation) error
- func (m *MockOrganisationRepository) DeleteOrganisation(arg0 context.Context, arg1 string) error
- func (m *MockOrganisationRepository) EXPECT() *MockOrganisationRepositoryMockRecorder
- func (m *MockOrganisationRepository) FetchOrganisationByAssignedDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
- func (m *MockOrganisationRepository) FetchOrganisationByCustomDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
- func (m *MockOrganisationRepository) FetchOrganisationByID(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
- func (m *MockOrganisationRepository) LoadOrganisationsPaged(arg0 context.Context, arg1 datastore.Pageable) ([]datastore.Organisation, datastore.PaginationData, error)
- func (m *MockOrganisationRepository) UpdateOrganisation(arg0 context.Context, arg1 *datastore.Organisation) error
- type MockOrganisationRepositoryMockRecorder
- func (mr *MockOrganisationRepositoryMockRecorder) CreateOrganisation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) DeleteOrganisation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByAssignedDomain(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByCustomDomain(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) LoadOrganisationsPaged(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockOrganisationRepositoryMockRecorder) UpdateOrganisation(arg0, arg1 interface{}) *gomock.Call
- type 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) FindPortalLinkByOwnerID(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
- func (mr *MockPortalLinkRepositoryMockRecorder) CreatePortalLink(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByOwnerID(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
- 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) FillProjectsStatistics(ctx context.Context, project *datastore.Project) error
- func (m *MockProjectRepository) GetProjectsWithEventsInTheInterval(ctx context.Context, interval int) ([]datastore.ProjectEvents, 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
- 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) FillProjectsStatistics(ctx, project interface{}) *gomock.Call
- func (mr *MockProjectRepositoryMockRecorder) GetProjectsWithEventsInTheInterval(ctx, interval interface{}) *gomock.Call
- func (mr *MockProjectRepositoryMockRecorder) LoadProjects(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockProjectRepositoryMockRecorder) UpdateProject(arg0, arg1 interface{}) *gomock.Call
- type MockPubSub
- type MockPubSubMockRecorder
- type MockQueuer
- type MockQueuerMockRecorder
- type MockRateLimiter
- type MockRateLimiterMockRecorder
- type MockSearcher
- func (m *MockSearcher) EXPECT() *MockSearcherMockRecorder
- func (m *MockSearcher) Index(collection string, document map[string]interface{}) error
- func (m *MockSearcher) Remove(collection string, filter *datastore.SearchFilter) error
- func (m *MockSearcher) Search(collection string, filter *datastore.SearchFilter) ([]string, datastore.PaginationData, error)
- type MockSearcherMockRecorder
- type MockSmtpClient
- type MockSmtpClientMockRecorder
- type MockSourceRepository
- func (m *MockSourceRepository) CreateSource(arg0 context.Context, arg1 *datastore.Source) error
- func (m *MockSourceRepository) DeleteSourceByID(ctx context.Context, projectID, id, sourceVerifierID string) error
- func (m *MockSourceRepository) EXPECT() *MockSourceRepositoryMockRecorder
- func (m *MockSourceRepository) FindSourceByID(ctx context.Context, projectID, id string) (*datastore.Source, error)
- func (m *MockSourceRepository) FindSourceByMaskID(ctx context.Context, maskID string) (*datastore.Source, error)
- func (m *MockSourceRepository) FindSourceByName(ctx context.Context, projectId, name string) (*datastore.Source, error)
- func (m *MockSourceRepository) LoadSourcesPaged(ctx context.Context, projectID string, filter *datastore.SourceFilter, ...) ([]datastore.Source, datastore.PaginationData, error)
- func (m *MockSourceRepository) UpdateSource(ctx context.Context, projectID string, source *datastore.Source) error
- type MockSourceRepositoryMockRecorder
- func (mr *MockSourceRepositoryMockRecorder) CreateSource(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) DeleteSourceByID(ctx, projectID, id, sourceVerifierID interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) FindSourceByID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) FindSourceByMaskID(ctx, maskID interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) FindSourceByName(ctx, projectId, name interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) LoadSourcesPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
- func (mr *MockSourceRepositoryMockRecorder) UpdateSource(ctx, projectID, source interface{}) *gomock.Call
- type MockSubscriptionRepository
- func (m *MockSubscriptionRepository) CountEndpointSubscriptions(ctx context.Context, projectID, endpointID string) (int64, error)
- func (m *MockSubscriptionRepository) CreateSubscription(arg0 context.Context, arg1 string, arg2 *datastore.Subscription) error
- func (m *MockSubscriptionRepository) DeleteSubscription(ctx context.Context, projectID string, subscription *datastore.Subscription) error
- func (m *MockSubscriptionRepository) EXPECT() *MockSubscriptionRepositoryMockRecorder
- func (m *MockSubscriptionRepository) FindCLISubscriptions(ctx context.Context, projectID string) ([]datastore.Subscription, error)
- func (m *MockSubscriptionRepository) FindSubscriptionByDeviceID(ctx context.Context, projectId, deviceID string, ...) (*datastore.Subscription, error)
- func (m *MockSubscriptionRepository) FindSubscriptionByID(ctx context.Context, projectID, id string) (*datastore.Subscription, error)
- func (m *MockSubscriptionRepository) FindSubscriptionsByEndpointID(ctx context.Context, projectId, endpointID string) ([]datastore.Subscription, error)
- func (m *MockSubscriptionRepository) FindSubscriptionsBySourceID(ctx context.Context, projectID, sourceID string) ([]datastore.Subscription, error)
- func (m *MockSubscriptionRepository) LoadSubscriptionsPaged(ctx context.Context, projectID string, filter *datastore.FilterBy, ...) ([]datastore.Subscription, datastore.PaginationData, error)
- func (m *MockSubscriptionRepository) TestSubscriptionFilter(ctx context.Context, payload, filter interface{}) (bool, error)
- func (m *MockSubscriptionRepository) TransformPayload(ctx context.Context, function string, payload map[string]interface{}) (interface{}, []string, error)
- func (m *MockSubscriptionRepository) UpdateSubscription(ctx context.Context, projectID string, subscription *datastore.Subscription) error
- type MockSubscriptionRepositoryMockRecorder
- func (mr *MockSubscriptionRepositoryMockRecorder) CountEndpointSubscriptions(ctx, projectID, endpointID interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) CreateSubscription(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) DeleteSubscription(ctx, projectID, subscription interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) FindCLISubscriptions(ctx, projectID interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByDeviceID(ctx, projectId, deviceID, subscriptionType interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByID(ctx, projectID, id interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByEndpointID(ctx, projectId, endpointID interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsBySourceID(ctx, projectID, sourceID interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) LoadSubscriptionsPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) TestSubscriptionFilter(ctx, payload, filter interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) TransformPayload(ctx, function, payload interface{}) *gomock.Call
- func (mr *MockSubscriptionRepositoryMockRecorder) UpdateSubscription(ctx, projectID, subscription interface{}) *gomock.Call
- type MockTracer
- func (m *MockTracer) EXPECT() *MockTracerMockRecorder
- func (m *MockTracer) NewContext(ctx context.Context, txn *newrelic.Transaction) context.Context
- 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
- func (mr *MockTracerMockRecorder) NewContext(ctx, txn interface{}) *gomock.Call
- 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
- type 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) FindUserByEmailVerificationToken(ctx context.Context, token 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
- func (mr *MockUserRepositoryMockRecorder) CreateUser(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockUserRepositoryMockRecorder) FindUserByEmail(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockUserRepositoryMockRecorder) FindUserByEmailVerificationToken(ctx, token 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
- type 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
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAPIKeyRepository ¶
type MockAPIKeyRepository struct {
// contains filtered or unexported fields
}
MockAPIKeyRepository is a mock of APIKeyRepository interface.
func NewMockAPIKeyRepository ¶
func NewMockAPIKeyRepository(ctrl *gomock.Controller) *MockAPIKeyRepository
NewMockAPIKeyRepository creates a new mock instance.
func (*MockAPIKeyRepository) CreateAPIKey ¶
CreateAPIKey mocks base method.
func (*MockAPIKeyRepository) EXPECT ¶
func (m *MockAPIKeyRepository) EXPECT() *MockAPIKeyRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAPIKeyRepository) FindAPIKeyByHash ¶
func (m *MockAPIKeyRepository) FindAPIKeyByHash(arg0 context.Context, arg1 string) (*datastore.APIKey, error)
FindAPIKeyByHash mocks base method.
func (*MockAPIKeyRepository) FindAPIKeyByID ¶
func (m *MockAPIKeyRepository) FindAPIKeyByID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)
FindAPIKeyByID mocks base method.
func (*MockAPIKeyRepository) FindAPIKeyByMaskID ¶
func (m *MockAPIKeyRepository) FindAPIKeyByMaskID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)
FindAPIKeyByMaskID mocks base method.
func (*MockAPIKeyRepository) FindAPIKeyByProjectID ¶ added in v0.8.1
func (m *MockAPIKeyRepository) FindAPIKeyByProjectID(arg0 context.Context, arg1 string) (*datastore.APIKey, error)
FindAPIKeyByProjectID mocks base method.
func (*MockAPIKeyRepository) LoadAPIKeysPaged ¶
func (m *MockAPIKeyRepository) LoadAPIKeysPaged(arg0 context.Context, arg1 *datastore.ApiKeyFilter, arg2 *datastore.Pageable) ([]datastore.APIKey, datastore.PaginationData, error)
LoadAPIKeysPaged mocks base method.
func (*MockAPIKeyRepository) RevokeAPIKeys ¶
func (m *MockAPIKeyRepository) RevokeAPIKeys(arg0 context.Context, arg1 []string) error
RevokeAPIKeys mocks base method.
func (*MockAPIKeyRepository) UpdateAPIKey ¶
UpdateAPIKey mocks base method.
type MockAPIKeyRepositoryMockRecorder ¶
type MockAPIKeyRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockAPIKeyRepositoryMockRecorder is the mock recorder for MockAPIKeyRepository.
func (*MockAPIKeyRepositoryMockRecorder) CreateAPIKey ¶
func (mr *MockAPIKeyRepositoryMockRecorder) CreateAPIKey(arg0, arg1 interface{}) *gomock.Call
CreateAPIKey indicates an expected call of CreateAPIKey.
func (*MockAPIKeyRepositoryMockRecorder) FindAPIKeyByHash ¶
func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByHash(arg0, arg1 interface{}) *gomock.Call
FindAPIKeyByHash indicates an expected call of FindAPIKeyByHash.
func (*MockAPIKeyRepositoryMockRecorder) FindAPIKeyByID ¶
func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByID(arg0, arg1 interface{}) *gomock.Call
FindAPIKeyByID indicates an expected call of FindAPIKeyByID.
func (*MockAPIKeyRepositoryMockRecorder) FindAPIKeyByMaskID ¶
func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByMaskID(arg0, arg1 interface{}) *gomock.Call
FindAPIKeyByMaskID indicates an expected call of FindAPIKeyByMaskID.
func (*MockAPIKeyRepositoryMockRecorder) FindAPIKeyByProjectID ¶ added in v0.8.1
func (mr *MockAPIKeyRepositoryMockRecorder) FindAPIKeyByProjectID(arg0, arg1 interface{}) *gomock.Call
FindAPIKeyByProjectID indicates an expected call of FindAPIKeyByProjectID.
func (*MockAPIKeyRepositoryMockRecorder) LoadAPIKeysPaged ¶
func (mr *MockAPIKeyRepositoryMockRecorder) LoadAPIKeysPaged(arg0, arg1, arg2 interface{}) *gomock.Call
LoadAPIKeysPaged indicates an expected call of LoadAPIKeysPaged.
func (*MockAPIKeyRepositoryMockRecorder) RevokeAPIKeys ¶
func (mr *MockAPIKeyRepositoryMockRecorder) RevokeAPIKeys(arg0, arg1 interface{}) *gomock.Call
RevokeAPIKeys indicates an expected call of RevokeAPIKeys.
func (*MockAPIKeyRepositoryMockRecorder) UpdateAPIKey ¶
func (mr *MockAPIKeyRepositoryMockRecorder) UpdateAPIKey(arg0, arg1 interface{}) *gomock.Call
UpdateAPIKey indicates an expected call of UpdateAPIKey.
type MockCache ¶ added in v0.5.3
type MockCache struct {
// contains filtered or unexported fields
}
MockCache is a mock of Cache interface.
func NewMockCache ¶ added in v0.5.3
func NewMockCache(ctrl *gomock.Controller) *MockCache
NewMockCache creates a new mock instance.
func (*MockCache) EXPECT ¶ added in v0.5.3
func (m *MockCache) EXPECT() *MockCacheMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockCacheMockRecorder ¶ added in v0.5.3
type MockCacheMockRecorder struct {
// contains filtered or unexported fields
}
MockCacheMockRecorder is the mock recorder for MockCache.
func (*MockCacheMockRecorder) Delete ¶ added in v0.5.3
func (mr *MockCacheMockRecorder) Delete(ctx, key interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockCacheMockRecorder) Get ¶ added in v0.5.3
func (mr *MockCacheMockRecorder) Get(ctx, key, data interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockCacheMockRecorder) Set ¶ added in v0.5.3
func (mr *MockCacheMockRecorder) Set(ctx, key, data, expiration interface{}) *gomock.Call
Set indicates an expected call of Set.
type MockConfigurationRepository ¶ added in v0.6.0
type MockConfigurationRepository struct {
// contains filtered or unexported fields
}
MockConfigurationRepository is a mock of ConfigurationRepository interface.
func NewMockConfigurationRepository ¶ added in v0.6.0
func NewMockConfigurationRepository(ctrl *gomock.Controller) *MockConfigurationRepository
NewMockConfigurationRepository creates a new mock instance.
func (*MockConfigurationRepository) CreateConfiguration ¶ added in v0.6.0
func (m *MockConfigurationRepository) CreateConfiguration(arg0 context.Context, arg1 *datastore.Configuration) error
CreateConfiguration mocks base method.
func (*MockConfigurationRepository) EXPECT ¶ added in v0.6.0
func (m *MockConfigurationRepository) EXPECT() *MockConfigurationRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConfigurationRepository) LoadConfiguration ¶ added in v0.6.0
func (m *MockConfigurationRepository) LoadConfiguration(arg0 context.Context) (*datastore.Configuration, error)
LoadConfiguration mocks base method.
func (*MockConfigurationRepository) UpdateConfiguration ¶ added in v0.6.0
func (m *MockConfigurationRepository) UpdateConfiguration(arg0 context.Context, arg1 *datastore.Configuration) error
UpdateConfiguration mocks base method.
type MockConfigurationRepositoryMockRecorder ¶ added in v0.6.0
type MockConfigurationRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockConfigurationRepositoryMockRecorder is the mock recorder for MockConfigurationRepository.
func (*MockConfigurationRepositoryMockRecorder) CreateConfiguration ¶ added in v0.6.0
func (mr *MockConfigurationRepositoryMockRecorder) CreateConfiguration(arg0, arg1 interface{}) *gomock.Call
CreateConfiguration indicates an expected call of CreateConfiguration.
func (*MockConfigurationRepositoryMockRecorder) LoadConfiguration ¶ added in v0.6.0
func (mr *MockConfigurationRepositoryMockRecorder) LoadConfiguration(arg0 interface{}) *gomock.Call
LoadConfiguration indicates an expected call of LoadConfiguration.
func (*MockConfigurationRepositoryMockRecorder) UpdateConfiguration ¶ added in v0.6.0
func (mr *MockConfigurationRepositoryMockRecorder) UpdateConfiguration(arg0, arg1 interface{}) *gomock.Call
UpdateConfiguration indicates an expected call of UpdateConfiguration.
type MockDeviceRepository ¶ added in v0.7.0
type MockDeviceRepository struct {
// contains filtered or unexported fields
}
MockDeviceRepository is a mock of DeviceRepository interface.
func NewMockDeviceRepository ¶ added in v0.7.0
func NewMockDeviceRepository(ctrl *gomock.Controller) *MockDeviceRepository
NewMockDeviceRepository creates a new mock instance.
func (*MockDeviceRepository) CreateDevice ¶ added in v0.7.0
CreateDevice mocks base method.
func (*MockDeviceRepository) DeleteDevice ¶ added in v0.7.0
func (m *MockDeviceRepository) DeleteDevice(ctx context.Context, uid, appID, projectID string) error
DeleteDevice mocks base method.
func (*MockDeviceRepository) EXPECT ¶ added in v0.7.0
func (m *MockDeviceRepository) EXPECT() *MockDeviceRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockDeviceRepository) FetchDeviceByHostName ¶ added in v0.7.0
func (m *MockDeviceRepository) FetchDeviceByHostName(ctx context.Context, hostName, appID, projectID string) (*datastore.Device, error)
FetchDeviceByHostName mocks base method.
func (*MockDeviceRepository) FetchDeviceByID ¶ added in v0.7.0
func (m *MockDeviceRepository) FetchDeviceByID(ctx context.Context, uid, appID, projectID string) (*datastore.Device, error)
FetchDeviceByID mocks base method.
func (*MockDeviceRepository) LoadDevicesPaged ¶ added in v0.7.0
func (m *MockDeviceRepository) LoadDevicesPaged(ctx context.Context, projectID string, filter *datastore.ApiKeyFilter, pageable datastore.Pageable) ([]datastore.Device, datastore.PaginationData, error)
LoadDevicesPaged mocks base method.
func (*MockDeviceRepository) UpdateDevice ¶ added in v0.7.0
func (m *MockDeviceRepository) UpdateDevice(ctx context.Context, device *datastore.Device, appID, projectID string) error
UpdateDevice mocks base method.
func (*MockDeviceRepository) UpdateDeviceLastSeen ¶ added in v0.7.0
func (m *MockDeviceRepository) UpdateDeviceLastSeen(ctx context.Context, device *datastore.Device, appID, projectID string, status datastore.DeviceStatus) error
UpdateDeviceLastSeen mocks base method.
type MockDeviceRepositoryMockRecorder ¶ added in v0.7.0
type MockDeviceRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockDeviceRepositoryMockRecorder is the mock recorder for MockDeviceRepository.
func (*MockDeviceRepositoryMockRecorder) CreateDevice ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) CreateDevice(ctx, device interface{}) *gomock.Call
CreateDevice indicates an expected call of CreateDevice.
func (*MockDeviceRepositoryMockRecorder) DeleteDevice ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) DeleteDevice(ctx, uid, appID, projectID interface{}) *gomock.Call
DeleteDevice indicates an expected call of DeleteDevice.
func (*MockDeviceRepositoryMockRecorder) FetchDeviceByHostName ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByHostName(ctx, hostName, appID, projectID interface{}) *gomock.Call
FetchDeviceByHostName indicates an expected call of FetchDeviceByHostName.
func (*MockDeviceRepositoryMockRecorder) FetchDeviceByID ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) FetchDeviceByID(ctx, uid, appID, projectID interface{}) *gomock.Call
FetchDeviceByID indicates an expected call of FetchDeviceByID.
func (*MockDeviceRepositoryMockRecorder) LoadDevicesPaged ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) LoadDevicesPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
LoadDevicesPaged indicates an expected call of LoadDevicesPaged.
func (*MockDeviceRepositoryMockRecorder) UpdateDevice ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) UpdateDevice(ctx, device, appID, projectID interface{}) *gomock.Call
UpdateDevice indicates an expected call of UpdateDevice.
func (*MockDeviceRepositoryMockRecorder) UpdateDeviceLastSeen ¶ added in v0.7.0
func (mr *MockDeviceRepositoryMockRecorder) UpdateDeviceLastSeen(ctx, device, appID, projectID, status interface{}) *gomock.Call
UpdateDeviceLastSeen indicates an expected call of UpdateDeviceLastSeen.
type MockEndpointRepository ¶ added in v0.8.0
type MockEndpointRepository struct {
// contains filtered or unexported fields
}
MockEndpointRepository is a mock of EndpointRepository interface.
func NewMockEndpointRepository ¶ added in v0.8.0
func NewMockEndpointRepository(ctrl *gomock.Controller) *MockEndpointRepository
NewMockEndpointRepository creates a new mock instance.
func (*MockEndpointRepository) CountProjectEndpoints ¶ added in v0.8.0
func (m *MockEndpointRepository) CountProjectEndpoints(ctx context.Context, projectID string) (int64, error)
CountProjectEndpoints mocks base method.
func (*MockEndpointRepository) CreateEndpoint ¶ added in v0.8.0
func (m *MockEndpointRepository) CreateEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error
CreateEndpoint mocks base method.
func (*MockEndpointRepository) DeleteEndpoint ¶ added in v0.8.0
func (m *MockEndpointRepository) DeleteEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error
DeleteEndpoint mocks base method.
func (*MockEndpointRepository) DeleteSecret ¶ added in v0.9.0
func (m *MockEndpointRepository) DeleteSecret(ctx context.Context, endpoint *datastore.Endpoint, secretID, projectID string) error
DeleteSecret mocks base method.
func (*MockEndpointRepository) EXPECT ¶ added in v0.8.0
func (m *MockEndpointRepository) EXPECT() *MockEndpointRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEndpointRepository) FindEndpointByID ¶ added in v0.8.0
func (m *MockEndpointRepository) FindEndpointByID(ctx context.Context, id, projectID string) (*datastore.Endpoint, error)
FindEndpointByID mocks base method.
func (*MockEndpointRepository) FindEndpointByTargetURL ¶ added in v1.1.6
func (m *MockEndpointRepository) FindEndpointByTargetURL(ctx context.Context, projectID, targetURL string) (*datastore.Endpoint, error)
FindEndpointByTargetURL mocks base method.
func (*MockEndpointRepository) FindEndpointsByAppID ¶ added in v0.8.0
func (m *MockEndpointRepository) FindEndpointsByAppID(ctx context.Context, appID, projectID string) ([]datastore.Endpoint, error)
FindEndpointsByAppID mocks base method.
func (*MockEndpointRepository) FindEndpointsByID ¶ added in v0.8.0
func (m *MockEndpointRepository) FindEndpointsByID(ctx context.Context, ids []string, projectID string) ([]datastore.Endpoint, error)
FindEndpointsByID mocks base method.
func (*MockEndpointRepository) FindEndpointsByOwnerID ¶ added in v0.8.0
func (m *MockEndpointRepository) FindEndpointsByOwnerID(ctx context.Context, projectID, ownerID string) ([]datastore.Endpoint, error)
FindEndpointsByOwnerID mocks base method.
func (*MockEndpointRepository) LoadEndpointsPaged ¶ added in v0.8.0
func (m *MockEndpointRepository) LoadEndpointsPaged(ctx context.Context, projectID string, filter *datastore.Filter, pageable datastore.Pageable) ([]datastore.Endpoint, datastore.PaginationData, error)
LoadEndpointsPaged mocks base method.
func (*MockEndpointRepository) UpdateEndpoint ¶ added in v0.8.0
func (m *MockEndpointRepository) UpdateEndpoint(ctx context.Context, endpoint *datastore.Endpoint, projectID string) error
UpdateEndpoint mocks base method.
func (*MockEndpointRepository) UpdateEndpointStatus ¶ added in v0.8.0
func (m *MockEndpointRepository) UpdateEndpointStatus(ctx context.Context, projectID, endpointID string, status datastore.EndpointStatus) error
UpdateEndpointStatus mocks base method.
func (*MockEndpointRepository) UpdateSecrets ¶ added in v0.9.0
func (m *MockEndpointRepository) UpdateSecrets(ctx context.Context, endpointID, projectID string, secrets datastore.Secrets) error
UpdateSecrets mocks base method.
type MockEndpointRepositoryMockRecorder ¶ added in v0.8.0
type MockEndpointRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockEndpointRepositoryMockRecorder is the mock recorder for MockEndpointRepository.
func (*MockEndpointRepositoryMockRecorder) CountProjectEndpoints ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) CountProjectEndpoints(ctx, projectID interface{}) *gomock.Call
CountProjectEndpoints indicates an expected call of CountProjectEndpoints.
func (*MockEndpointRepositoryMockRecorder) CreateEndpoint ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) CreateEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call
CreateEndpoint indicates an expected call of CreateEndpoint.
func (*MockEndpointRepositoryMockRecorder) DeleteEndpoint ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) DeleteEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call
DeleteEndpoint indicates an expected call of DeleteEndpoint.
func (*MockEndpointRepositoryMockRecorder) DeleteSecret ¶ added in v0.9.0
func (mr *MockEndpointRepositoryMockRecorder) DeleteSecret(ctx, endpoint, secretID, projectID interface{}) *gomock.Call
DeleteSecret indicates an expected call of DeleteSecret.
func (*MockEndpointRepositoryMockRecorder) FindEndpointByID ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByID(ctx, id, projectID interface{}) *gomock.Call
FindEndpointByID indicates an expected call of FindEndpointByID.
func (*MockEndpointRepositoryMockRecorder) FindEndpointByTargetURL ¶ added in v1.1.6
func (mr *MockEndpointRepositoryMockRecorder) FindEndpointByTargetURL(ctx, projectID, targetURL interface{}) *gomock.Call
FindEndpointByTargetURL indicates an expected call of FindEndpointByTargetURL.
func (*MockEndpointRepositoryMockRecorder) FindEndpointsByAppID ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByAppID(ctx, appID, projectID interface{}) *gomock.Call
FindEndpointsByAppID indicates an expected call of FindEndpointsByAppID.
func (*MockEndpointRepositoryMockRecorder) FindEndpointsByID ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByID(ctx, ids, projectID interface{}) *gomock.Call
FindEndpointsByID indicates an expected call of FindEndpointsByID.
func (*MockEndpointRepositoryMockRecorder) FindEndpointsByOwnerID ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) FindEndpointsByOwnerID(ctx, projectID, ownerID interface{}) *gomock.Call
FindEndpointsByOwnerID indicates an expected call of FindEndpointsByOwnerID.
func (*MockEndpointRepositoryMockRecorder) LoadEndpointsPaged ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) LoadEndpointsPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
LoadEndpointsPaged indicates an expected call of LoadEndpointsPaged.
func (*MockEndpointRepositoryMockRecorder) UpdateEndpoint ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpoint(ctx, endpoint, projectID interface{}) *gomock.Call
UpdateEndpoint indicates an expected call of UpdateEndpoint.
func (*MockEndpointRepositoryMockRecorder) UpdateEndpointStatus ¶ added in v0.8.0
func (mr *MockEndpointRepositoryMockRecorder) UpdateEndpointStatus(ctx, projectID, endpointID, status interface{}) *gomock.Call
UpdateEndpointStatus indicates an expected call of UpdateEndpointStatus.
func (*MockEndpointRepositoryMockRecorder) UpdateSecrets ¶ added in v0.9.0
func (mr *MockEndpointRepositoryMockRecorder) UpdateSecrets(ctx, endpointID, projectID, secrets interface{}) *gomock.Call
UpdateSecrets indicates an expected call of UpdateSecrets.
type MockEventDeliveryRepository ¶
type MockEventDeliveryRepository struct {
// contains filtered or unexported fields
}
MockEventDeliveryRepository is a mock of EventDeliveryRepository interface.
func NewMockEventDeliveryRepository ¶
func NewMockEventDeliveryRepository(ctrl *gomock.Controller) *MockEventDeliveryRepository
NewMockEventDeliveryRepository creates a new mock instance.
func (*MockEventDeliveryRepository) CountDeliveriesByStatus ¶ added in v0.4.18
func (m *MockEventDeliveryRepository) CountDeliveriesByStatus(ctx context.Context, projectID string, status datastore.EventDeliveryStatus, params datastore.SearchParams) (int64, error)
CountDeliveriesByStatus mocks base method.
func (*MockEventDeliveryRepository) CountEventDeliveries ¶ added in v0.5.0
func (m *MockEventDeliveryRepository) CountEventDeliveries(ctx context.Context, projectID string, endpointIDs []string, eventID string, status []datastore.EventDeliveryStatus, params datastore.SearchParams) (int64, error)
CountEventDeliveries mocks base method.
func (*MockEventDeliveryRepository) CreateEventDelivery ¶
func (m *MockEventDeliveryRepository) CreateEventDelivery(arg0 context.Context, arg1 *datastore.EventDelivery) error
CreateEventDelivery mocks base method.
func (*MockEventDeliveryRepository) DeleteProjectEventDeliveries ¶ added in v0.8.0
func (m *MockEventDeliveryRepository) DeleteProjectEventDeliveries(ctx context.Context, projectID string, filter *datastore.EventDeliveryFilter, hardDelete bool) error
DeleteProjectEventDeliveries mocks base method.
func (*MockEventDeliveryRepository) EXPECT ¶
func (m *MockEventDeliveryRepository) EXPECT() *MockEventDeliveryRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventDeliveryRepository) FindDiscardedEventDeliveries ¶ added in v0.7.0
func (m *MockEventDeliveryRepository) FindDiscardedEventDeliveries(ctx context.Context, projectID, deviceId string, params datastore.SearchParams) ([]datastore.EventDelivery, error)
FindDiscardedEventDeliveries mocks base method.
func (*MockEventDeliveryRepository) FindEventDeliveriesByEventID ¶
func (m *MockEventDeliveryRepository) FindEventDeliveriesByEventID(ctx context.Context, projectID, id string) ([]datastore.EventDelivery, error)
FindEventDeliveriesByEventID mocks base method.
func (*MockEventDeliveryRepository) FindEventDeliveriesByIDs ¶
func (m *MockEventDeliveryRepository) FindEventDeliveriesByIDs(ctx context.Context, projectID string, ids []string) ([]datastore.EventDelivery, error)
FindEventDeliveriesByIDs mocks base method.
func (*MockEventDeliveryRepository) FindEventDeliveryByID ¶
func (m *MockEventDeliveryRepository) FindEventDeliveryByID(ctx context.Context, projectID, id string) (*datastore.EventDelivery, error)
FindEventDeliveryByID mocks base method.
func (*MockEventDeliveryRepository) LoadEventDeliveriesIntervals ¶ added in v0.8.1
func (m *MockEventDeliveryRepository) LoadEventDeliveriesIntervals(ctx context.Context, projectID string, params datastore.SearchParams, period datastore.Period) ([]datastore.EventInterval, error)
LoadEventDeliveriesIntervals mocks base method.
func (*MockEventDeliveryRepository) LoadEventDeliveriesPaged ¶
func (m *MockEventDeliveryRepository) LoadEventDeliveriesPaged(ctx context.Context, projectID string, endpointIDs []string, eventID, subscriptionID string, status []datastore.EventDeliveryStatus, params datastore.SearchParams, pageable datastore.Pageable, idempotencyKey string) ([]datastore.EventDelivery, datastore.PaginationData, error)
LoadEventDeliveriesPaged mocks base method.
func (*MockEventDeliveryRepository) UpdateEventDeliveryWithAttempt ¶
func (m *MockEventDeliveryRepository) UpdateEventDeliveryWithAttempt(ctx context.Context, projectID string, eventDelivery datastore.EventDelivery, attempt datastore.DeliveryAttempt) error
UpdateEventDeliveryWithAttempt mocks base method.
func (*MockEventDeliveryRepository) UpdateStatusOfEventDeliveries ¶ added in v0.4.19
func (m *MockEventDeliveryRepository) UpdateStatusOfEventDeliveries(ctx context.Context, projectID string, ids []string, status datastore.EventDeliveryStatus) error
UpdateStatusOfEventDeliveries mocks base method.
func (*MockEventDeliveryRepository) UpdateStatusOfEventDelivery ¶
func (m *MockEventDeliveryRepository) UpdateStatusOfEventDelivery(ctx context.Context, projectID string, eventDelivery datastore.EventDelivery, status datastore.EventDeliveryStatus) error
UpdateStatusOfEventDelivery mocks base method.
type MockEventDeliveryRepositoryMockRecorder ¶
type MockEventDeliveryRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockEventDeliveryRepositoryMockRecorder is the mock recorder for MockEventDeliveryRepository.
func (*MockEventDeliveryRepositoryMockRecorder) CountDeliveriesByStatus ¶ added in v0.4.18
func (mr *MockEventDeliveryRepositoryMockRecorder) CountDeliveriesByStatus(ctx, projectID, status, params interface{}) *gomock.Call
CountDeliveriesByStatus indicates an expected call of CountDeliveriesByStatus.
func (*MockEventDeliveryRepositoryMockRecorder) CountEventDeliveries ¶ added in v0.5.0
func (mr *MockEventDeliveryRepositoryMockRecorder) CountEventDeliveries(ctx, projectID, endpointIDs, eventID, status, params interface{}) *gomock.Call
CountEventDeliveries indicates an expected call of CountEventDeliveries.
func (*MockEventDeliveryRepositoryMockRecorder) CreateEventDelivery ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) CreateEventDelivery(arg0, arg1 interface{}) *gomock.Call
CreateEventDelivery indicates an expected call of CreateEventDelivery.
func (*MockEventDeliveryRepositoryMockRecorder) DeleteProjectEventDeliveries ¶ added in v0.8.0
func (mr *MockEventDeliveryRepositoryMockRecorder) DeleteProjectEventDeliveries(ctx, projectID, filter, hardDelete interface{}) *gomock.Call
DeleteProjectEventDeliveries indicates an expected call of DeleteProjectEventDeliveries.
func (*MockEventDeliveryRepositoryMockRecorder) FindDiscardedEventDeliveries ¶ added in v0.7.0
func (mr *MockEventDeliveryRepositoryMockRecorder) FindDiscardedEventDeliveries(ctx, projectID, deviceId, params interface{}) *gomock.Call
FindDiscardedEventDeliveries indicates an expected call of FindDiscardedEventDeliveries.
func (*MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByEventID ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByEventID(ctx, projectID, id interface{}) *gomock.Call
FindEventDeliveriesByEventID indicates an expected call of FindEventDeliveriesByEventID.
func (*MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByIDs ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveriesByIDs(ctx, projectID, ids interface{}) *gomock.Call
FindEventDeliveriesByIDs indicates an expected call of FindEventDeliveriesByIDs.
func (*MockEventDeliveryRepositoryMockRecorder) FindEventDeliveryByID ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) FindEventDeliveryByID(ctx, projectID, id interface{}) *gomock.Call
FindEventDeliveryByID indicates an expected call of FindEventDeliveryByID.
func (*MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesIntervals ¶ added in v0.8.1
func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesIntervals(ctx, projectID, params, period interface{}) *gomock.Call
LoadEventDeliveriesIntervals indicates an expected call of LoadEventDeliveriesIntervals.
func (*MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesPaged ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) LoadEventDeliveriesPaged(ctx, projectID, endpointIDs, eventID, subscriptionID, status, params, pageable, idempotencyKey interface{}) *gomock.Call
LoadEventDeliveriesPaged indicates an expected call of LoadEventDeliveriesPaged.
func (*MockEventDeliveryRepositoryMockRecorder) UpdateEventDeliveryWithAttempt ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateEventDeliveryWithAttempt(ctx, projectID, eventDelivery, attempt interface{}) *gomock.Call
UpdateEventDeliveryWithAttempt indicates an expected call of UpdateEventDeliveryWithAttempt.
func (*MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDeliveries ¶ added in v0.4.19
func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDeliveries(ctx, projectID, ids, status interface{}) *gomock.Call
UpdateStatusOfEventDeliveries indicates an expected call of UpdateStatusOfEventDeliveries.
func (*MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDelivery ¶
func (mr *MockEventDeliveryRepositoryMockRecorder) UpdateStatusOfEventDelivery(ctx, projectID, eventDelivery, status interface{}) *gomock.Call
UpdateStatusOfEventDelivery indicates an expected call of UpdateStatusOfEventDelivery.
type MockEventRepository ¶
type MockEventRepository struct {
// contains filtered or unexported fields
}
MockEventRepository is a mock of EventRepository interface.
func NewMockEventRepository ¶
func NewMockEventRepository(ctrl *gomock.Controller) *MockEventRepository
NewMockEventRepository creates a new mock instance.
func (*MockEventRepository) CountEvents ¶ added in v0.8.0
func (m *MockEventRepository) CountEvents(ctx context.Context, projectID string, f *datastore.Filter) (int64, error)
CountEvents mocks base method.
func (*MockEventRepository) CountProjectMessages ¶ added in v0.8.0
func (m *MockEventRepository) CountProjectMessages(ctx context.Context, projectID string) (int64, error)
CountProjectMessages mocks base method.
func (*MockEventRepository) CreateEvent ¶
CreateEvent mocks base method.
func (*MockEventRepository) DeleteProjectEvents ¶ added in v0.8.0
func (m *MockEventRepository) DeleteProjectEvents(ctx context.Context, projectID string, f *datastore.EventFilter, hardDelete bool) error
DeleteProjectEvents mocks base method.
func (*MockEventRepository) DeleteProjectTokenizedEvents ¶ added in v1.1.6
func (m *MockEventRepository) DeleteProjectTokenizedEvents(ctx context.Context, projectID string, filter *datastore.EventFilter) error
DeleteProjectTokenizedEvents mocks base method.
func (*MockEventRepository) EXPECT ¶
func (m *MockEventRepository) EXPECT() *MockEventRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEventRepository) FindEventByID ¶
func (m *MockEventRepository) FindEventByID(ctx context.Context, projectID, id string) (*datastore.Event, error)
FindEventByID mocks base method.
func (*MockEventRepository) FindEventsByIDs ¶ added in v0.6.0
func (m *MockEventRepository) FindEventsByIDs(ctx context.Context, projectID string, ids []string) ([]datastore.Event, error)
FindEventsByIDs mocks base method.
func (*MockEventRepository) FindEventsByIdempotencyKey ¶ added in v1.1.6
func (m *MockEventRepository) FindEventsByIdempotencyKey(ctx context.Context, projectID, idempotencyKey string) ([]datastore.Event, error)
FindEventsByIdempotencyKey mocks base method.
func (*MockEventRepository) FindFirstEventWithIdempotencyKey ¶ added in v1.1.6
func (m *MockEventRepository) FindFirstEventWithIdempotencyKey(ctx context.Context, projectID, idempotencyKey string) (*datastore.Event, error)
FindFirstEventWithIdempotencyKey mocks base method.
func (*MockEventRepository) LoadEventsPaged ¶
func (m *MockEventRepository) LoadEventsPaged(ctx context.Context, projectID string, f *datastore.Filter) ([]datastore.Event, datastore.PaginationData, error)
LoadEventsPaged mocks base method.
type MockEventRepositoryMockRecorder ¶
type MockEventRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockEventRepositoryMockRecorder is the mock recorder for MockEventRepository.
func (*MockEventRepositoryMockRecorder) CopyRows ¶ added in v1.1.6
func (mr *MockEventRepositoryMockRecorder) CopyRows(ctx, projectID, interval interface{}) *gomock.Call
CopyRows indicates an expected call of CopyRows.
func (*MockEventRepositoryMockRecorder) CountEvents ¶ added in v0.8.0
func (mr *MockEventRepositoryMockRecorder) CountEvents(ctx, projectID, f interface{}) *gomock.Call
CountEvents indicates an expected call of CountEvents.
func (*MockEventRepositoryMockRecorder) CountProjectMessages ¶ added in v0.8.0
func (mr *MockEventRepositoryMockRecorder) CountProjectMessages(ctx, projectID interface{}) *gomock.Call
CountProjectMessages indicates an expected call of CountProjectMessages.
func (*MockEventRepositoryMockRecorder) CreateEvent ¶
func (mr *MockEventRepositoryMockRecorder) CreateEvent(arg0, arg1 interface{}) *gomock.Call
CreateEvent indicates an expected call of CreateEvent.
func (*MockEventRepositoryMockRecorder) DeleteProjectEvents ¶ added in v0.8.0
func (mr *MockEventRepositoryMockRecorder) DeleteProjectEvents(ctx, projectID, f, hardDelete interface{}) *gomock.Call
DeleteProjectEvents indicates an expected call of DeleteProjectEvents.
func (*MockEventRepositoryMockRecorder) DeleteProjectTokenizedEvents ¶ added in v1.1.6
func (mr *MockEventRepositoryMockRecorder) DeleteProjectTokenizedEvents(ctx, projectID, filter interface{}) *gomock.Call
DeleteProjectTokenizedEvents indicates an expected call of DeleteProjectTokenizedEvents.
func (*MockEventRepositoryMockRecorder) FindEventByID ¶
func (mr *MockEventRepositoryMockRecorder) FindEventByID(ctx, projectID, id interface{}) *gomock.Call
FindEventByID indicates an expected call of FindEventByID.
func (*MockEventRepositoryMockRecorder) FindEventsByIDs ¶ added in v0.6.0
func (mr *MockEventRepositoryMockRecorder) FindEventsByIDs(ctx, projectID, ids interface{}) *gomock.Call
FindEventsByIDs indicates an expected call of FindEventsByIDs.
func (*MockEventRepositoryMockRecorder) FindEventsByIdempotencyKey ¶ added in v1.1.6
func (mr *MockEventRepositoryMockRecorder) FindEventsByIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call
FindEventsByIdempotencyKey indicates an expected call of FindEventsByIdempotencyKey.
func (*MockEventRepositoryMockRecorder) FindFirstEventWithIdempotencyKey ¶ added in v1.1.6
func (mr *MockEventRepositoryMockRecorder) FindFirstEventWithIdempotencyKey(ctx, projectID, idempotencyKey interface{}) *gomock.Call
FindFirstEventWithIdempotencyKey indicates an expected call of FindFirstEventWithIdempotencyKey.
func (*MockEventRepositoryMockRecorder) LoadEventsPaged ¶
func (mr *MockEventRepositoryMockRecorder) LoadEventsPaged(ctx, projectID, f interface{}) *gomock.Call
LoadEventsPaged indicates an expected call of LoadEventsPaged.
type MockExportRepository ¶ added in v0.9.0
type MockExportRepository struct {
// contains filtered or unexported fields
}
MockExportRepository is a mock of ExportRepository interface.
func NewMockExportRepository ¶ added in v0.9.0
func NewMockExportRepository(ctrl *gomock.Controller) *MockExportRepository
NewMockExportRepository creates a new mock instance.
func (*MockExportRepository) EXPECT ¶ added in v0.9.0
func (m *MockExportRepository) EXPECT() *MockExportRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockExportRepositoryMockRecorder ¶ added in v0.9.0
type MockExportRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockExportRepositoryMockRecorder is the mock recorder for MockExportRepository.
func (*MockExportRepositoryMockRecorder) ExportRecords ¶ added in v0.9.0
func (mr *MockExportRepositoryMockRecorder) ExportRecords(ctx, tableName, projectID, createdAt, w interface{}) *gomock.Call
ExportRecords indicates an expected call of ExportRecords.
type MockIdempotency ¶ added in v1.1.6
type MockIdempotency struct {
// contains filtered or unexported fields
}
MockIdempotency is a mock of Idempotency interface.
func NewMockIdempotency ¶ added in v1.1.6
func NewMockIdempotency(ctrl *gomock.Controller) *MockIdempotency
NewMockIdempotency creates a new mock instance.
func (*MockIdempotency) EXPECT ¶ added in v1.1.6
func (m *MockIdempotency) EXPECT() *MockIdempotencyMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIdempotency) Exists ¶ added in v1.1.6
func (m *MockIdempotency) Exists(arg0, arg1 string, arg2 []string) (bool, error)
Exists mocks base method.
func (*MockIdempotency) GenerateChecksum ¶ added in v1.1.6
func (m *MockIdempotency) GenerateChecksum(arg0 string, arg1 []string) (string, error)
GenerateChecksum mocks base method.
type MockIdempotencyMockRecorder ¶ added in v1.1.6
type MockIdempotencyMockRecorder struct {
// contains filtered or unexported fields
}
MockIdempotencyMockRecorder is the mock recorder for MockIdempotency.
func (*MockIdempotencyMockRecorder) Exists ¶ added in v1.1.6
func (mr *MockIdempotencyMockRecorder) Exists(arg0, arg1, arg2 interface{}) *gomock.Call
Exists indicates an expected call of Exists.
func (*MockIdempotencyMockRecorder) GenerateChecksum ¶ added in v1.1.6
func (mr *MockIdempotencyMockRecorder) GenerateChecksum(arg0, arg1 interface{}) *gomock.Call
GenerateChecksum indicates an expected call of GenerateChecksum.
type MockJobRepository ¶ added in v1.1.6
type MockJobRepository struct {
// contains filtered or unexported fields
}
MockJobRepository is a mock of JobRepository interface.
func NewMockJobRepository ¶ added in v1.1.6
func NewMockJobRepository(ctrl *gomock.Controller) *MockJobRepository
NewMockJobRepository creates a new mock instance.
func (*MockJobRepository) DeleteJob ¶ added in v1.1.6
func (m *MockJobRepository) DeleteJob(ctx context.Context, uid, projectID string) error
DeleteJob mocks base method.
func (*MockJobRepository) EXPECT ¶ added in v1.1.6
func (m *MockJobRepository) EXPECT() *MockJobRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockJobRepository) FetchJobById ¶ added in v1.1.6
func (m *MockJobRepository) FetchJobById(ctx context.Context, uid, projectID string) (*datastore.Job, error)
FetchJobById mocks base method.
func (*MockJobRepository) FetchJobsByProjectId ¶ added in v1.1.6
func (m *MockJobRepository) FetchJobsByProjectId(ctx context.Context, projectID string) ([]datastore.Job, error)
FetchJobsByProjectId mocks base method.
func (*MockJobRepository) FetchRunningJobsByProjectId ¶ added in v1.1.6
func (m *MockJobRepository) FetchRunningJobsByProjectId(ctx context.Context, projectID string) ([]datastore.Job, error)
FetchRunningJobsByProjectId mocks base method.
func (*MockJobRepository) LoadJobsPaged ¶ added in v1.1.6
func (m *MockJobRepository) LoadJobsPaged(ctx context.Context, projectID string, pageable datastore.Pageable) ([]datastore.Job, datastore.PaginationData, error)
LoadJobsPaged mocks base method.
func (*MockJobRepository) MarkJobAsCompleted ¶ added in v1.1.6
func (m *MockJobRepository) MarkJobAsCompleted(ctx context.Context, uid, projectID string) error
MarkJobAsCompleted mocks base method.
func (*MockJobRepository) MarkJobAsFailed ¶ added in v1.1.6
func (m *MockJobRepository) MarkJobAsFailed(ctx context.Context, uid, projectID string) error
MarkJobAsFailed mocks base method.
func (*MockJobRepository) MarkJobAsStarted ¶ added in v1.1.6
func (m *MockJobRepository) MarkJobAsStarted(ctx context.Context, uid, projectID string) error
MarkJobAsStarted mocks base method.
type MockJobRepositoryMockRecorder ¶ added in v1.1.6
type MockJobRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockJobRepositoryMockRecorder is the mock recorder for MockJobRepository.
func (*MockJobRepositoryMockRecorder) CreateJob ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) CreateJob(ctx, job interface{}) *gomock.Call
CreateJob indicates an expected call of CreateJob.
func (*MockJobRepositoryMockRecorder) DeleteJob ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) DeleteJob(ctx, uid, projectID interface{}) *gomock.Call
DeleteJob indicates an expected call of DeleteJob.
func (*MockJobRepositoryMockRecorder) FetchJobById ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) FetchJobById(ctx, uid, projectID interface{}) *gomock.Call
FetchJobById indicates an expected call of FetchJobById.
func (*MockJobRepositoryMockRecorder) FetchJobsByProjectId ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) FetchJobsByProjectId(ctx, projectID interface{}) *gomock.Call
FetchJobsByProjectId indicates an expected call of FetchJobsByProjectId.
func (*MockJobRepositoryMockRecorder) FetchRunningJobsByProjectId ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) FetchRunningJobsByProjectId(ctx, projectID interface{}) *gomock.Call
FetchRunningJobsByProjectId indicates an expected call of FetchRunningJobsByProjectId.
func (*MockJobRepositoryMockRecorder) LoadJobsPaged ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) LoadJobsPaged(ctx, projectID, pageable interface{}) *gomock.Call
LoadJobsPaged indicates an expected call of LoadJobsPaged.
func (*MockJobRepositoryMockRecorder) MarkJobAsCompleted ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) MarkJobAsCompleted(ctx, uid, projectID interface{}) *gomock.Call
MarkJobAsCompleted indicates an expected call of MarkJobAsCompleted.
func (*MockJobRepositoryMockRecorder) MarkJobAsFailed ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) MarkJobAsFailed(ctx, uid, projectID interface{}) *gomock.Call
MarkJobAsFailed indicates an expected call of MarkJobAsFailed.
func (*MockJobRepositoryMockRecorder) MarkJobAsStarted ¶ added in v1.1.6
func (mr *MockJobRepositoryMockRecorder) MarkJobAsStarted(ctx, uid, projectID interface{}) *gomock.Call
MarkJobAsStarted indicates an expected call of MarkJobAsStarted.
type MockMetaEventRepository ¶ added in v1.1.6
type MockMetaEventRepository struct {
// contains filtered or unexported fields
}
MockMetaEventRepository is a mock of MetaEventRepository interface.
func NewMockMetaEventRepository ¶ added in v1.1.6
func NewMockMetaEventRepository(ctrl *gomock.Controller) *MockMetaEventRepository
NewMockMetaEventRepository creates a new mock instance.
func (*MockMetaEventRepository) CreateMetaEvent ¶ added in v1.1.6
func (m *MockMetaEventRepository) CreateMetaEvent(arg0 context.Context, arg1 *datastore.MetaEvent) error
CreateMetaEvent mocks base method.
func (*MockMetaEventRepository) EXPECT ¶ added in v1.1.6
func (m *MockMetaEventRepository) EXPECT() *MockMetaEventRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMetaEventRepository) FindMetaEventByID ¶ added in v1.1.6
func (m *MockMetaEventRepository) FindMetaEventByID(ctx context.Context, projectID, id string) (*datastore.MetaEvent, error)
FindMetaEventByID mocks base method.
func (*MockMetaEventRepository) LoadMetaEventsPaged ¶ added in v1.1.6
func (m *MockMetaEventRepository) LoadMetaEventsPaged(ctx context.Context, projectID string, f *datastore.Filter) ([]datastore.MetaEvent, datastore.PaginationData, error)
LoadMetaEventsPaged mocks base method.
func (*MockMetaEventRepository) UpdateMetaEvent ¶ added in v1.1.6
func (m *MockMetaEventRepository) UpdateMetaEvent(ctx context.Context, projectID string, metaEvent *datastore.MetaEvent) error
UpdateMetaEvent mocks base method.
type MockMetaEventRepositoryMockRecorder ¶ added in v1.1.6
type MockMetaEventRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockMetaEventRepositoryMockRecorder is the mock recorder for MockMetaEventRepository.
func (*MockMetaEventRepositoryMockRecorder) CreateMetaEvent ¶ added in v1.1.6
func (mr *MockMetaEventRepositoryMockRecorder) CreateMetaEvent(arg0, arg1 interface{}) *gomock.Call
CreateMetaEvent indicates an expected call of CreateMetaEvent.
func (*MockMetaEventRepositoryMockRecorder) FindMetaEventByID ¶ added in v1.1.6
func (mr *MockMetaEventRepositoryMockRecorder) FindMetaEventByID(ctx, projectID, id interface{}) *gomock.Call
FindMetaEventByID indicates an expected call of FindMetaEventByID.
func (*MockMetaEventRepositoryMockRecorder) LoadMetaEventsPaged ¶ added in v1.1.6
func (mr *MockMetaEventRepositoryMockRecorder) LoadMetaEventsPaged(ctx, projectID, f interface{}) *gomock.Call
LoadMetaEventsPaged indicates an expected call of LoadMetaEventsPaged.
func (*MockMetaEventRepositoryMockRecorder) UpdateMetaEvent ¶ added in v1.1.6
func (mr *MockMetaEventRepositoryMockRecorder) UpdateMetaEvent(ctx, projectID, metaEvent interface{}) *gomock.Call
UpdateMetaEvent indicates an expected call of UpdateMetaEvent.
type MockOrganisationInviteRepository ¶ added in v0.6.0
type MockOrganisationInviteRepository struct {
// contains filtered or unexported fields
}
MockOrganisationInviteRepository is a mock of OrganisationInviteRepository interface.
func NewMockOrganisationInviteRepository ¶ added in v0.6.0
func NewMockOrganisationInviteRepository(ctrl *gomock.Controller) *MockOrganisationInviteRepository
NewMockOrganisationInviteRepository creates a new mock instance.
func (*MockOrganisationInviteRepository) CreateOrganisationInvite ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) CreateOrganisationInvite(ctx context.Context, iv *datastore.OrganisationInvite) error
CreateOrganisationInvite mocks base method.
func (*MockOrganisationInviteRepository) DeleteOrganisationInvite ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) DeleteOrganisationInvite(ctx context.Context, uid string) error
DeleteOrganisationInvite mocks base method.
func (*MockOrganisationInviteRepository) EXPECT ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) EXPECT() *MockOrganisationInviteRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockOrganisationInviteRepository) FetchOrganisationInviteByID ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) FetchOrganisationInviteByID(ctx context.Context, uid string) (*datastore.OrganisationInvite, error)
FetchOrganisationInviteByID mocks base method.
func (*MockOrganisationInviteRepository) FetchOrganisationInviteByToken ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) FetchOrganisationInviteByToken(ctx context.Context, token string) (*datastore.OrganisationInvite, error)
FetchOrganisationInviteByToken mocks base method.
func (*MockOrganisationInviteRepository) LoadOrganisationsInvitesPaged ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) LoadOrganisationsInvitesPaged(ctx context.Context, orgID string, inviteStatus datastore.InviteStatus, pageable datastore.Pageable) ([]datastore.OrganisationInvite, datastore.PaginationData, error)
LoadOrganisationsInvitesPaged mocks base method.
func (*MockOrganisationInviteRepository) UpdateOrganisationInvite ¶ added in v0.6.0
func (m *MockOrganisationInviteRepository) UpdateOrganisationInvite(ctx context.Context, iv *datastore.OrganisationInvite) error
UpdateOrganisationInvite mocks base method.
type MockOrganisationInviteRepositoryMockRecorder ¶ added in v0.6.0
type MockOrganisationInviteRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockOrganisationInviteRepositoryMockRecorder is the mock recorder for MockOrganisationInviteRepository.
func (*MockOrganisationInviteRepositoryMockRecorder) CreateOrganisationInvite ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) CreateOrganisationInvite(ctx, iv interface{}) *gomock.Call
CreateOrganisationInvite indicates an expected call of CreateOrganisationInvite.
func (*MockOrganisationInviteRepositoryMockRecorder) DeleteOrganisationInvite ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) DeleteOrganisationInvite(ctx, uid interface{}) *gomock.Call
DeleteOrganisationInvite indicates an expected call of DeleteOrganisationInvite.
func (*MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByID ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByID(ctx, uid interface{}) *gomock.Call
FetchOrganisationInviteByID indicates an expected call of FetchOrganisationInviteByID.
func (*MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByToken ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) FetchOrganisationInviteByToken(ctx, token interface{}) *gomock.Call
FetchOrganisationInviteByToken indicates an expected call of FetchOrganisationInviteByToken.
func (*MockOrganisationInviteRepositoryMockRecorder) LoadOrganisationsInvitesPaged ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) LoadOrganisationsInvitesPaged(ctx, orgID, inviteStatus, pageable interface{}) *gomock.Call
LoadOrganisationsInvitesPaged indicates an expected call of LoadOrganisationsInvitesPaged.
func (*MockOrganisationInviteRepositoryMockRecorder) UpdateOrganisationInvite ¶ added in v0.6.0
func (mr *MockOrganisationInviteRepositoryMockRecorder) UpdateOrganisationInvite(ctx, iv interface{}) *gomock.Call
UpdateOrganisationInvite indicates an expected call of UpdateOrganisationInvite.
type MockOrganisationMemberRepository ¶ added in v0.6.0
type MockOrganisationMemberRepository struct {
// contains filtered or unexported fields
}
MockOrganisationMemberRepository is a mock of OrganisationMemberRepository interface.
func NewMockOrganisationMemberRepository ¶ added in v0.6.0
func NewMockOrganisationMemberRepository(ctrl *gomock.Controller) *MockOrganisationMemberRepository
NewMockOrganisationMemberRepository creates a new mock instance.
func (*MockOrganisationMemberRepository) CreateOrganisationMember ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) CreateOrganisationMember(ctx context.Context, member *datastore.OrganisationMember) error
CreateOrganisationMember mocks base method.
func (*MockOrganisationMemberRepository) DeleteOrganisationMember ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) DeleteOrganisationMember(ctx context.Context, memberID, orgID string) error
DeleteOrganisationMember mocks base method.
func (*MockOrganisationMemberRepository) EXPECT ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) EXPECT() *MockOrganisationMemberRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockOrganisationMemberRepository) FetchOrganisationMemberByID ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) FetchOrganisationMemberByID(ctx context.Context, memberID, organisationID string) (*datastore.OrganisationMember, error)
FetchOrganisationMemberByID mocks base method.
func (*MockOrganisationMemberRepository) FetchOrganisationMemberByUserID ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) FetchOrganisationMemberByUserID(ctx context.Context, userID, organisationID string) (*datastore.OrganisationMember, error)
FetchOrganisationMemberByUserID mocks base method.
func (*MockOrganisationMemberRepository) FindUserProjects ¶ added in v0.8.2
func (m *MockOrganisationMemberRepository) FindUserProjects(ctx context.Context, userID string) ([]datastore.Project, error)
FindUserProjects mocks base method.
func (*MockOrganisationMemberRepository) LoadOrganisationMembersPaged ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) LoadOrganisationMembersPaged(ctx context.Context, organisationID, userID string, pageable datastore.Pageable) ([]*datastore.OrganisationMember, datastore.PaginationData, error)
LoadOrganisationMembersPaged mocks base method.
func (*MockOrganisationMemberRepository) LoadUserOrganisationsPaged ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) LoadUserOrganisationsPaged(ctx context.Context, userID string, pageable datastore.Pageable) ([]datastore.Organisation, datastore.PaginationData, error)
LoadUserOrganisationsPaged mocks base method.
func (*MockOrganisationMemberRepository) UpdateOrganisationMember ¶ added in v0.6.0
func (m *MockOrganisationMemberRepository) UpdateOrganisationMember(ctx context.Context, member *datastore.OrganisationMember) error
UpdateOrganisationMember mocks base method.
type MockOrganisationMemberRepositoryMockRecorder ¶ added in v0.6.0
type MockOrganisationMemberRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockOrganisationMemberRepositoryMockRecorder is the mock recorder for MockOrganisationMemberRepository.
func (*MockOrganisationMemberRepositoryMockRecorder) CreateOrganisationMember ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) CreateOrganisationMember(ctx, member interface{}) *gomock.Call
CreateOrganisationMember indicates an expected call of CreateOrganisationMember.
func (*MockOrganisationMemberRepositoryMockRecorder) DeleteOrganisationMember ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) DeleteOrganisationMember(ctx, memberID, orgID interface{}) *gomock.Call
DeleteOrganisationMember indicates an expected call of DeleteOrganisationMember.
func (*MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByID ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByID(ctx, memberID, organisationID interface{}) *gomock.Call
FetchOrganisationMemberByID indicates an expected call of FetchOrganisationMemberByID.
func (*MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByUserID ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) FetchOrganisationMemberByUserID(ctx, userID, organisationID interface{}) *gomock.Call
FetchOrganisationMemberByUserID indicates an expected call of FetchOrganisationMemberByUserID.
func (*MockOrganisationMemberRepositoryMockRecorder) FindUserProjects ¶ added in v0.8.2
func (mr *MockOrganisationMemberRepositoryMockRecorder) FindUserProjects(ctx, userID interface{}) *gomock.Call
FindUserProjects indicates an expected call of FindUserProjects.
func (*MockOrganisationMemberRepositoryMockRecorder) LoadOrganisationMembersPaged ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) LoadOrganisationMembersPaged(ctx, organisationID, userID, pageable interface{}) *gomock.Call
LoadOrganisationMembersPaged indicates an expected call of LoadOrganisationMembersPaged.
func (*MockOrganisationMemberRepositoryMockRecorder) LoadUserOrganisationsPaged ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) LoadUserOrganisationsPaged(ctx, userID, pageable interface{}) *gomock.Call
LoadUserOrganisationsPaged indicates an expected call of LoadUserOrganisationsPaged.
func (*MockOrganisationMemberRepositoryMockRecorder) UpdateOrganisationMember ¶ added in v0.6.0
func (mr *MockOrganisationMemberRepositoryMockRecorder) UpdateOrganisationMember(ctx, member interface{}) *gomock.Call
UpdateOrganisationMember indicates an expected call of UpdateOrganisationMember.
type MockOrganisationRepository ¶ added in v0.1.0
type MockOrganisationRepository struct {
// contains filtered or unexported fields
}
MockOrganisationRepository is a mock of OrganisationRepository interface.
func NewMockOrganisationRepository ¶ added in v0.1.0
func NewMockOrganisationRepository(ctrl *gomock.Controller) *MockOrganisationRepository
NewMockOrganisationRepository creates a new mock instance.
func (*MockOrganisationRepository) CreateOrganisation ¶ added in v0.1.0
func (m *MockOrganisationRepository) CreateOrganisation(arg0 context.Context, arg1 *datastore.Organisation) error
CreateOrganisation mocks base method.
func (*MockOrganisationRepository) DeleteOrganisation ¶ added in v0.6.0
func (m *MockOrganisationRepository) DeleteOrganisation(arg0 context.Context, arg1 string) error
DeleteOrganisation mocks base method.
func (*MockOrganisationRepository) EXPECT ¶ added in v0.1.0
func (m *MockOrganisationRepository) EXPECT() *MockOrganisationRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockOrganisationRepository) FetchOrganisationByAssignedDomain ¶ added in v0.8.0
func (m *MockOrganisationRepository) FetchOrganisationByAssignedDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
FetchOrganisationByAssignedDomain mocks base method.
func (*MockOrganisationRepository) FetchOrganisationByCustomDomain ¶ added in v0.8.0
func (m *MockOrganisationRepository) FetchOrganisationByCustomDomain(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
FetchOrganisationByCustomDomain mocks base method.
func (*MockOrganisationRepository) FetchOrganisationByID ¶ added in v0.1.0
func (m *MockOrganisationRepository) FetchOrganisationByID(arg0 context.Context, arg1 string) (*datastore.Organisation, error)
FetchOrganisationByID mocks base method.
func (*MockOrganisationRepository) LoadOrganisationsPaged ¶ added in v0.6.0
func (m *MockOrganisationRepository) LoadOrganisationsPaged(arg0 context.Context, arg1 datastore.Pageable) ([]datastore.Organisation, datastore.PaginationData, error)
LoadOrganisationsPaged mocks base method.
func (*MockOrganisationRepository) UpdateOrganisation ¶ added in v0.1.0
func (m *MockOrganisationRepository) UpdateOrganisation(arg0 context.Context, arg1 *datastore.Organisation) error
UpdateOrganisation mocks base method.
type MockOrganisationRepositoryMockRecorder ¶ added in v0.1.0
type MockOrganisationRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockOrganisationRepositoryMockRecorder is the mock recorder for MockOrganisationRepository.
func (*MockOrganisationRepositoryMockRecorder) CreateOrganisation ¶ added in v0.1.0
func (mr *MockOrganisationRepositoryMockRecorder) CreateOrganisation(arg0, arg1 interface{}) *gomock.Call
CreateOrganisation indicates an expected call of CreateOrganisation.
func (*MockOrganisationRepositoryMockRecorder) DeleteOrganisation ¶ added in v0.6.0
func (mr *MockOrganisationRepositoryMockRecorder) DeleteOrganisation(arg0, arg1 interface{}) *gomock.Call
DeleteOrganisation indicates an expected call of DeleteOrganisation.
func (*MockOrganisationRepositoryMockRecorder) FetchOrganisationByAssignedDomain ¶ added in v0.8.0
func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByAssignedDomain(arg0, arg1 interface{}) *gomock.Call
FetchOrganisationByAssignedDomain indicates an expected call of FetchOrganisationByAssignedDomain.
func (*MockOrganisationRepositoryMockRecorder) FetchOrganisationByCustomDomain ¶ added in v0.8.0
func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByCustomDomain(arg0, arg1 interface{}) *gomock.Call
FetchOrganisationByCustomDomain indicates an expected call of FetchOrganisationByCustomDomain.
func (*MockOrganisationRepositoryMockRecorder) FetchOrganisationByID ¶ added in v0.1.0
func (mr *MockOrganisationRepositoryMockRecorder) FetchOrganisationByID(arg0, arg1 interface{}) *gomock.Call
FetchOrganisationByID indicates an expected call of FetchOrganisationByID.
func (*MockOrganisationRepositoryMockRecorder) LoadOrganisationsPaged ¶ added in v0.6.0
func (mr *MockOrganisationRepositoryMockRecorder) LoadOrganisationsPaged(arg0, arg1 interface{}) *gomock.Call
LoadOrganisationsPaged indicates an expected call of LoadOrganisationsPaged.
func (*MockOrganisationRepositoryMockRecorder) UpdateOrganisation ¶ added in v0.1.0
func (mr *MockOrganisationRepositoryMockRecorder) UpdateOrganisation(arg0, arg1 interface{}) *gomock.Call
UpdateOrganisation indicates an expected call of UpdateOrganisation.
type MockPortalLinkRepository ¶ added in v0.8.0
type MockPortalLinkRepository struct {
// contains filtered or unexported fields
}
MockPortalLinkRepository is a mock of PortalLinkRepository interface.
func NewMockPortalLinkRepository ¶ added in v0.8.0
func NewMockPortalLinkRepository(ctrl *gomock.Controller) *MockPortalLinkRepository
NewMockPortalLinkRepository creates a new mock instance.
func (*MockPortalLinkRepository) CreatePortalLink ¶ added in v0.8.0
func (m *MockPortalLinkRepository) CreatePortalLink(arg0 context.Context, arg1 *datastore.PortalLink) error
CreatePortalLink mocks base method.
func (*MockPortalLinkRepository) EXPECT ¶ added in v0.8.0
func (m *MockPortalLinkRepository) EXPECT() *MockPortalLinkRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPortalLinkRepository) FindPortalLinkByID ¶ added in v0.8.0
func (m *MockPortalLinkRepository) FindPortalLinkByID(ctx context.Context, projectID, id string) (*datastore.PortalLink, error)
FindPortalLinkByID mocks base method.
func (*MockPortalLinkRepository) FindPortalLinkByOwnerID ¶ added in v1.1.6
func (m *MockPortalLinkRepository) FindPortalLinkByOwnerID(ctx context.Context, projectID, id string) (*datastore.PortalLink, error)
FindPortalLinkByOwnerID mocks base method.
func (*MockPortalLinkRepository) FindPortalLinkByToken ¶ added in v0.8.0
func (m *MockPortalLinkRepository) FindPortalLinkByToken(ctx context.Context, token string) (*datastore.PortalLink, error)
FindPortalLinkByToken mocks base method.
func (*MockPortalLinkRepository) LoadPortalLinksPaged ¶ added in v0.8.0
func (m *MockPortalLinkRepository) LoadPortalLinksPaged(ctx context.Context, projectID string, f *datastore.FilterBy, pageable datastore.Pageable) ([]datastore.PortalLink, datastore.PaginationData, error)
LoadPortalLinksPaged mocks base method.
func (*MockPortalLinkRepository) RevokePortalLink ¶ added in v0.8.0
func (m *MockPortalLinkRepository) RevokePortalLink(ctx context.Context, projectID, id string) error
RevokePortalLink mocks base method.
func (*MockPortalLinkRepository) UpdatePortalLink ¶ added in v0.8.0
func (m *MockPortalLinkRepository) UpdatePortalLink(ctx context.Context, projectID string, portal *datastore.PortalLink) error
UpdatePortalLink mocks base method.
type MockPortalLinkRepositoryMockRecorder ¶ added in v0.8.0
type MockPortalLinkRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockPortalLinkRepositoryMockRecorder is the mock recorder for MockPortalLinkRepository.
func (*MockPortalLinkRepositoryMockRecorder) CreatePortalLink ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) CreatePortalLink(arg0, arg1 interface{}) *gomock.Call
CreatePortalLink indicates an expected call of CreatePortalLink.
func (*MockPortalLinkRepositoryMockRecorder) FindPortalLinkByID ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByID(ctx, projectID, id interface{}) *gomock.Call
FindPortalLinkByID indicates an expected call of FindPortalLinkByID.
func (*MockPortalLinkRepositoryMockRecorder) FindPortalLinkByOwnerID ¶ added in v1.1.6
func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByOwnerID(ctx, projectID, id interface{}) *gomock.Call
FindPortalLinkByOwnerID indicates an expected call of FindPortalLinkByOwnerID.
func (*MockPortalLinkRepositoryMockRecorder) FindPortalLinkByToken ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) FindPortalLinkByToken(ctx, token interface{}) *gomock.Call
FindPortalLinkByToken indicates an expected call of FindPortalLinkByToken.
func (*MockPortalLinkRepositoryMockRecorder) LoadPortalLinksPaged ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) LoadPortalLinksPaged(ctx, projectID, f, pageable interface{}) *gomock.Call
LoadPortalLinksPaged indicates an expected call of LoadPortalLinksPaged.
func (*MockPortalLinkRepositoryMockRecorder) RevokePortalLink ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) RevokePortalLink(ctx, projectID, id interface{}) *gomock.Call
RevokePortalLink indicates an expected call of RevokePortalLink.
func (*MockPortalLinkRepositoryMockRecorder) UpdatePortalLink ¶ added in v0.8.0
func (mr *MockPortalLinkRepositoryMockRecorder) UpdatePortalLink(ctx, projectID, portal interface{}) *gomock.Call
UpdatePortalLink indicates an expected call of UpdatePortalLink.
type MockProjectRepository ¶ added in v0.8.0
type MockProjectRepository struct {
// contains filtered or unexported fields
}
MockProjectRepository is a mock of ProjectRepository interface.
func NewMockProjectRepository ¶ added in v0.8.0
func NewMockProjectRepository(ctrl *gomock.Controller) *MockProjectRepository
NewMockProjectRepository creates a new mock instance.
func (*MockProjectRepository) CreateProject ¶ added in v0.8.0
CreateProject mocks base method.
func (*MockProjectRepository) DeleteProject ¶ added in v0.8.0
func (m *MockProjectRepository) DeleteProject(ctx context.Context, uid string) error
DeleteProject mocks base method.
func (*MockProjectRepository) EXPECT ¶ added in v0.8.0
func (m *MockProjectRepository) EXPECT() *MockProjectRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProjectRepository) FetchProjectByID ¶ added in v0.8.0
func (m *MockProjectRepository) FetchProjectByID(arg0 context.Context, arg1 string) (*datastore.Project, error)
FetchProjectByID mocks base method.
func (*MockProjectRepository) FillProjectsStatistics ¶ added in v0.8.0
func (m *MockProjectRepository) FillProjectsStatistics(ctx context.Context, project *datastore.Project) error
FillProjectsStatistics mocks base method.
func (*MockProjectRepository) GetProjectsWithEventsInTheInterval ¶ added in v1.1.6
func (m *MockProjectRepository) GetProjectsWithEventsInTheInterval(ctx context.Context, interval int) ([]datastore.ProjectEvents, error)
GetProjectsWithEventsInTheInterval mocks base method.
func (*MockProjectRepository) LoadProjects ¶ added in v0.8.0
func (m *MockProjectRepository) LoadProjects(arg0 context.Context, arg1 *datastore.ProjectFilter) ([]*datastore.Project, error)
LoadProjects mocks base method.
func (*MockProjectRepository) UpdateProject ¶ added in v0.8.0
UpdateProject mocks base method.
type MockProjectRepositoryMockRecorder ¶ added in v0.8.0
type MockProjectRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockProjectRepositoryMockRecorder is the mock recorder for MockProjectRepository.
func (*MockProjectRepositoryMockRecorder) CreateProject ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) CreateProject(arg0, arg1 interface{}) *gomock.Call
CreateProject indicates an expected call of CreateProject.
func (*MockProjectRepositoryMockRecorder) DeleteProject ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) DeleteProject(ctx, uid interface{}) *gomock.Call
DeleteProject indicates an expected call of DeleteProject.
func (*MockProjectRepositoryMockRecorder) FetchProjectByID ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) FetchProjectByID(arg0, arg1 interface{}) *gomock.Call
FetchProjectByID indicates an expected call of FetchProjectByID.
func (*MockProjectRepositoryMockRecorder) FillProjectsStatistics ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) FillProjectsStatistics(ctx, project interface{}) *gomock.Call
FillProjectsStatistics indicates an expected call of FillProjectsStatistics.
func (*MockProjectRepositoryMockRecorder) GetProjectsWithEventsInTheInterval ¶ added in v1.1.6
func (mr *MockProjectRepositoryMockRecorder) GetProjectsWithEventsInTheInterval(ctx, interval interface{}) *gomock.Call
GetProjectsWithEventsInTheInterval indicates an expected call of GetProjectsWithEventsInTheInterval.
func (*MockProjectRepositoryMockRecorder) LoadProjects ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) LoadProjects(arg0, arg1 interface{}) *gomock.Call
LoadProjects indicates an expected call of LoadProjects.
func (*MockProjectRepositoryMockRecorder) UpdateProject ¶ added in v0.8.0
func (mr *MockProjectRepositoryMockRecorder) UpdateProject(arg0, arg1 interface{}) *gomock.Call
UpdateProject indicates an expected call of UpdateProject.
type MockPubSub ¶ added in v0.9.0
type MockPubSub struct {
// contains filtered or unexported fields
}
MockPubSub is a mock of PubSub interface.
func NewMockPubSub ¶ added in v0.9.0
func NewMockPubSub(ctrl *gomock.Controller) *MockPubSub
NewMockPubSub creates a new mock instance.
func (*MockPubSub) Consume ¶ added in v0.9.0
func (m *MockPubSub) Consume()
Consume mocks base method.
func (*MockPubSub) EXPECT ¶ added in v0.9.0
func (m *MockPubSub) EXPECT() *MockPubSubMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockPubSubMockRecorder ¶ added in v0.9.0
type MockPubSubMockRecorder struct {
// contains filtered or unexported fields
}
MockPubSubMockRecorder is the mock recorder for MockPubSub.
func (*MockPubSubMockRecorder) Consume ¶ added in v0.9.0
func (mr *MockPubSubMockRecorder) Consume() *gomock.Call
Consume indicates an expected call of Consume.
func (*MockPubSubMockRecorder) Start ¶ added in v0.9.0
func (mr *MockPubSubMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockPubSubMockRecorder) Stop ¶ added in v0.9.0
func (mr *MockPubSubMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type MockQueuer ¶
type MockQueuer struct {
// contains filtered or unexported fields
}
MockQueuer is a mock of Queuer interface.
func NewMockQueuer ¶
func NewMockQueuer(ctrl *gomock.Controller) *MockQueuer
NewMockQueuer creates a new mock instance.
func (*MockQueuer) EXPECT ¶
func (m *MockQueuer) EXPECT() *MockQueuerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockQueuer) Options ¶ added in v0.6.0
func (m *MockQueuer) Options() queue.QueueOptions
Options mocks base method.
type MockQueuerMockRecorder ¶
type MockQueuerMockRecorder struct {
// contains filtered or unexported fields
}
MockQueuerMockRecorder is the mock recorder for MockQueuer.
func (*MockQueuerMockRecorder) Options ¶ added in v0.6.0
func (mr *MockQueuerMockRecorder) Options() *gomock.Call
Options indicates an expected call of Options.
func (*MockQueuerMockRecorder) Write ¶
func (mr *MockQueuerMockRecorder) Write(arg0, arg1, arg2 interface{}) *gomock.Call
Write indicates an expected call of Write.
type MockRateLimiter ¶ added in v0.5.0
type MockRateLimiter struct {
// contains filtered or unexported fields
}
MockRateLimiter is a mock of RateLimiter interface.
func NewMockRateLimiter ¶ added in v0.5.0
func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter
NewMockRateLimiter creates a new mock instance.
func (*MockRateLimiter) Allow ¶ added in v0.5.0
func (m *MockRateLimiter) Allow(ctx context.Context, key string, limit, duration int) (*redis_rate.Result, error)
Allow mocks base method.
func (*MockRateLimiter) EXPECT ¶ added in v0.5.0
func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRateLimiter) ShouldAllow ¶ added in v0.5.0
func (m *MockRateLimiter) ShouldAllow(ctx context.Context, key string, limit, duration int) (*redis_rate.Result, error)
ShouldAllow mocks base method.
type MockRateLimiterMockRecorder ¶ added in v0.5.0
type MockRateLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.
func (*MockRateLimiterMockRecorder) Allow ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) Allow(ctx, key, limit, duration interface{}) *gomock.Call
Allow indicates an expected call of Allow.
func (*MockRateLimiterMockRecorder) ShouldAllow ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) ShouldAllow(ctx, key, limit, duration interface{}) *gomock.Call
ShouldAllow indicates an expected call of ShouldAllow.
type MockSearcher ¶ added in v0.6.0
type MockSearcher struct {
// contains filtered or unexported fields
}
MockSearcher is a mock of Searcher interface.
func NewMockSearcher ¶ added in v0.6.0
func NewMockSearcher(ctrl *gomock.Controller) *MockSearcher
NewMockSearcher creates a new mock instance.
func (*MockSearcher) EXPECT ¶ added in v0.6.0
func (m *MockSearcher) EXPECT() *MockSearcherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSearcher) Index ¶ added in v0.6.0
func (m *MockSearcher) Index(collection string, document map[string]interface{}) error
Index mocks base method.
func (*MockSearcher) Remove ¶ added in v0.6.0
func (m *MockSearcher) Remove(collection string, filter *datastore.SearchFilter) error
Remove mocks base method.
func (*MockSearcher) Search ¶ added in v0.6.0
func (m *MockSearcher) Search(collection string, filter *datastore.SearchFilter) ([]string, datastore.PaginationData, error)
Search mocks base method.
type MockSearcherMockRecorder ¶ added in v0.6.0
type MockSearcherMockRecorder struct {
// contains filtered or unexported fields
}
MockSearcherMockRecorder is the mock recorder for MockSearcher.
func (*MockSearcherMockRecorder) Index ¶ added in v0.6.0
func (mr *MockSearcherMockRecorder) Index(collection, document interface{}) *gomock.Call
Index indicates an expected call of Index.
func (*MockSearcherMockRecorder) Remove ¶ added in v0.6.0
func (mr *MockSearcherMockRecorder) Remove(collection, filter interface{}) *gomock.Call
Remove indicates an expected call of Remove.
func (*MockSearcherMockRecorder) Search ¶ added in v0.6.0
func (mr *MockSearcherMockRecorder) Search(collection, filter interface{}) *gomock.Call
Search indicates an expected call of Search.
type MockSmtpClient ¶ added in v0.6.0
type MockSmtpClient struct {
// contains filtered or unexported fields
}
MockSmtpClient is a mock of SmtpClient interface.
func NewMockSmtpClient ¶ added in v0.6.0
func NewMockSmtpClient(ctrl *gomock.Controller) *MockSmtpClient
NewMockSmtpClient creates a new mock instance.
func (*MockSmtpClient) EXPECT ¶ added in v0.6.0
func (m *MockSmtpClient) EXPECT() *MockSmtpClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockSmtpClientMockRecorder ¶ added in v0.6.0
type MockSmtpClientMockRecorder struct {
// contains filtered or unexported fields
}
MockSmtpClientMockRecorder is the mock recorder for MockSmtpClient.
func (*MockSmtpClientMockRecorder) SendEmail ¶ added in v0.6.0
func (mr *MockSmtpClientMockRecorder) SendEmail(emailAddr, subject, body interface{}) *gomock.Call
SendEmail indicates an expected call of SendEmail.
type MockSourceRepository ¶ added in v0.6.0
type MockSourceRepository struct {
// contains filtered or unexported fields
}
MockSourceRepository is a mock of SourceRepository interface.
func NewMockSourceRepository ¶ added in v0.6.0
func NewMockSourceRepository(ctrl *gomock.Controller) *MockSourceRepository
NewMockSourceRepository creates a new mock instance.
func (*MockSourceRepository) CreateSource ¶ added in v0.6.0
CreateSource mocks base method.
func (*MockSourceRepository) DeleteSourceByID ¶ added in v0.6.0
func (m *MockSourceRepository) DeleteSourceByID(ctx context.Context, projectID, id, sourceVerifierID string) error
DeleteSourceByID mocks base method.
func (*MockSourceRepository) EXPECT ¶ added in v0.6.0
func (m *MockSourceRepository) EXPECT() *MockSourceRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSourceRepository) FindSourceByID ¶ added in v0.6.0
func (m *MockSourceRepository) FindSourceByID(ctx context.Context, projectID, id string) (*datastore.Source, error)
FindSourceByID mocks base method.
func (*MockSourceRepository) FindSourceByMaskID ¶ added in v0.6.0
func (m *MockSourceRepository) FindSourceByMaskID(ctx context.Context, maskID string) (*datastore.Source, error)
FindSourceByMaskID mocks base method.
func (*MockSourceRepository) FindSourceByName ¶ added in v0.8.2
func (m *MockSourceRepository) FindSourceByName(ctx context.Context, projectId, name string) (*datastore.Source, error)
FindSourceByName mocks base method.
func (*MockSourceRepository) LoadSourcesPaged ¶ added in v0.6.0
func (m *MockSourceRepository) LoadSourcesPaged(ctx context.Context, projectID string, filter *datastore.SourceFilter, pageable datastore.Pageable) ([]datastore.Source, datastore.PaginationData, error)
LoadSourcesPaged mocks base method.
func (*MockSourceRepository) UpdateSource ¶ added in v0.6.0
func (m *MockSourceRepository) UpdateSource(ctx context.Context, projectID string, source *datastore.Source) error
UpdateSource mocks base method.
type MockSourceRepositoryMockRecorder ¶ added in v0.6.0
type MockSourceRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockSourceRepositoryMockRecorder is the mock recorder for MockSourceRepository.
func (*MockSourceRepositoryMockRecorder) CreateSource ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) CreateSource(arg0, arg1 interface{}) *gomock.Call
CreateSource indicates an expected call of CreateSource.
func (*MockSourceRepositoryMockRecorder) DeleteSourceByID ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) DeleteSourceByID(ctx, projectID, id, sourceVerifierID interface{}) *gomock.Call
DeleteSourceByID indicates an expected call of DeleteSourceByID.
func (*MockSourceRepositoryMockRecorder) FindSourceByID ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) FindSourceByID(ctx, projectID, id interface{}) *gomock.Call
FindSourceByID indicates an expected call of FindSourceByID.
func (*MockSourceRepositoryMockRecorder) FindSourceByMaskID ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) FindSourceByMaskID(ctx, maskID interface{}) *gomock.Call
FindSourceByMaskID indicates an expected call of FindSourceByMaskID.
func (*MockSourceRepositoryMockRecorder) FindSourceByName ¶ added in v0.8.2
func (mr *MockSourceRepositoryMockRecorder) FindSourceByName(ctx, projectId, name interface{}) *gomock.Call
FindSourceByName indicates an expected call of FindSourceByName.
func (*MockSourceRepositoryMockRecorder) LoadSourcesPaged ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) LoadSourcesPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
LoadSourcesPaged indicates an expected call of LoadSourcesPaged.
func (*MockSourceRepositoryMockRecorder) UpdateSource ¶ added in v0.6.0
func (mr *MockSourceRepositoryMockRecorder) UpdateSource(ctx, projectID, source interface{}) *gomock.Call
UpdateSource indicates an expected call of UpdateSource.
type MockSubscriptionRepository ¶ added in v0.6.0
type MockSubscriptionRepository struct {
// contains filtered or unexported fields
}
MockSubscriptionRepository is a mock of SubscriptionRepository interface.
func NewMockSubscriptionRepository ¶ added in v0.6.0
func NewMockSubscriptionRepository(ctrl *gomock.Controller) *MockSubscriptionRepository
NewMockSubscriptionRepository creates a new mock instance.
func (*MockSubscriptionRepository) CountEndpointSubscriptions ¶ added in v1.1.6
func (m *MockSubscriptionRepository) CountEndpointSubscriptions(ctx context.Context, projectID, endpointID string) (int64, error)
CountEndpointSubscriptions mocks base method.
func (*MockSubscriptionRepository) CreateSubscription ¶ added in v0.6.0
func (m *MockSubscriptionRepository) CreateSubscription(arg0 context.Context, arg1 string, arg2 *datastore.Subscription) error
CreateSubscription mocks base method.
func (*MockSubscriptionRepository) DeleteSubscription ¶ added in v0.6.0
func (m *MockSubscriptionRepository) DeleteSubscription(ctx context.Context, projectID string, subscription *datastore.Subscription) error
DeleteSubscription mocks base method.
func (*MockSubscriptionRepository) EXPECT ¶ added in v0.6.0
func (m *MockSubscriptionRepository) EXPECT() *MockSubscriptionRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSubscriptionRepository) FindCLISubscriptions ¶ added in v0.8.2
func (m *MockSubscriptionRepository) FindCLISubscriptions(ctx context.Context, projectID string) ([]datastore.Subscription, error)
FindCLISubscriptions mocks base method.
func (*MockSubscriptionRepository) FindSubscriptionByDeviceID ¶ added in v0.7.0
func (m *MockSubscriptionRepository) FindSubscriptionByDeviceID(ctx context.Context, projectId, deviceID string, subscriptionType datastore.SubscriptionType) (*datastore.Subscription, error)
FindSubscriptionByDeviceID mocks base method.
func (*MockSubscriptionRepository) FindSubscriptionByID ¶ added in v0.6.0
func (m *MockSubscriptionRepository) FindSubscriptionByID(ctx context.Context, projectID, id string) (*datastore.Subscription, error)
FindSubscriptionByID mocks base method.
func (*MockSubscriptionRepository) FindSubscriptionsByEndpointID ¶ added in v0.8.0
func (m *MockSubscriptionRepository) FindSubscriptionsByEndpointID(ctx context.Context, projectId, endpointID string) ([]datastore.Subscription, error)
FindSubscriptionsByEndpointID mocks base method.
func (*MockSubscriptionRepository) FindSubscriptionsBySourceID ¶ added in v0.8.2
func (m *MockSubscriptionRepository) FindSubscriptionsBySourceID(ctx context.Context, projectID, sourceID string) ([]datastore.Subscription, error)
FindSubscriptionsBySourceID mocks base method.
func (*MockSubscriptionRepository) LoadSubscriptionsPaged ¶ added in v0.6.0
func (m *MockSubscriptionRepository) LoadSubscriptionsPaged(ctx context.Context, projectID string, filter *datastore.FilterBy, pageable datastore.Pageable) ([]datastore.Subscription, datastore.PaginationData, error)
LoadSubscriptionsPaged mocks base method.
func (*MockSubscriptionRepository) TestSubscriptionFilter ¶ added in v0.8.0
func (m *MockSubscriptionRepository) TestSubscriptionFilter(ctx context.Context, payload, filter interface{}) (bool, error)
TestSubscriptionFilter mocks base method.
func (*MockSubscriptionRepository) TransformPayload ¶ added in v1.1.6
func (m *MockSubscriptionRepository) TransformPayload(ctx context.Context, function string, payload map[string]interface{}) (interface{}, []string, error)
TransformPayload mocks base method.
func (*MockSubscriptionRepository) UpdateSubscription ¶ added in v0.6.0
func (m *MockSubscriptionRepository) UpdateSubscription(ctx context.Context, projectID string, subscription *datastore.Subscription) error
UpdateSubscription mocks base method.
type MockSubscriptionRepositoryMockRecorder ¶ added in v0.6.0
type MockSubscriptionRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockSubscriptionRepositoryMockRecorder is the mock recorder for MockSubscriptionRepository.
func (*MockSubscriptionRepositoryMockRecorder) CountEndpointSubscriptions ¶ added in v1.1.6
func (mr *MockSubscriptionRepositoryMockRecorder) CountEndpointSubscriptions(ctx, projectID, endpointID interface{}) *gomock.Call
CountEndpointSubscriptions indicates an expected call of CountEndpointSubscriptions.
func (*MockSubscriptionRepositoryMockRecorder) CreateSubscription ¶ added in v0.6.0
func (mr *MockSubscriptionRepositoryMockRecorder) CreateSubscription(arg0, arg1, arg2 interface{}) *gomock.Call
CreateSubscription indicates an expected call of CreateSubscription.
func (*MockSubscriptionRepositoryMockRecorder) DeleteSubscription ¶ added in v0.6.0
func (mr *MockSubscriptionRepositoryMockRecorder) DeleteSubscription(ctx, projectID, subscription interface{}) *gomock.Call
DeleteSubscription indicates an expected call of DeleteSubscription.
func (*MockSubscriptionRepositoryMockRecorder) FindCLISubscriptions ¶ added in v0.8.2
func (mr *MockSubscriptionRepositoryMockRecorder) FindCLISubscriptions(ctx, projectID interface{}) *gomock.Call
FindCLISubscriptions indicates an expected call of FindCLISubscriptions.
func (*MockSubscriptionRepositoryMockRecorder) FindSubscriptionByDeviceID ¶ added in v0.7.0
func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByDeviceID(ctx, projectId, deviceID, subscriptionType interface{}) *gomock.Call
FindSubscriptionByDeviceID indicates an expected call of FindSubscriptionByDeviceID.
func (*MockSubscriptionRepositoryMockRecorder) FindSubscriptionByID ¶ added in v0.6.0
func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionByID(ctx, projectID, id interface{}) *gomock.Call
FindSubscriptionByID indicates an expected call of FindSubscriptionByID.
func (*MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByEndpointID ¶ added in v0.8.0
func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsByEndpointID(ctx, projectId, endpointID interface{}) *gomock.Call
FindSubscriptionsByEndpointID indicates an expected call of FindSubscriptionsByEndpointID.
func (*MockSubscriptionRepositoryMockRecorder) FindSubscriptionsBySourceID ¶ added in v0.8.2
func (mr *MockSubscriptionRepositoryMockRecorder) FindSubscriptionsBySourceID(ctx, projectID, sourceID interface{}) *gomock.Call
FindSubscriptionsBySourceID indicates an expected call of FindSubscriptionsBySourceID.
func (*MockSubscriptionRepositoryMockRecorder) LoadSubscriptionsPaged ¶ added in v0.6.0
func (mr *MockSubscriptionRepositoryMockRecorder) LoadSubscriptionsPaged(ctx, projectID, filter, pageable interface{}) *gomock.Call
LoadSubscriptionsPaged indicates an expected call of LoadSubscriptionsPaged.
func (*MockSubscriptionRepositoryMockRecorder) TestSubscriptionFilter ¶ added in v0.8.0
func (mr *MockSubscriptionRepositoryMockRecorder) TestSubscriptionFilter(ctx, payload, filter interface{}) *gomock.Call
TestSubscriptionFilter indicates an expected call of TestSubscriptionFilter.
func (*MockSubscriptionRepositoryMockRecorder) TransformPayload ¶ added in v1.1.6
func (mr *MockSubscriptionRepositoryMockRecorder) TransformPayload(ctx, function, payload interface{}) *gomock.Call
TransformPayload indicates an expected call of TransformPayload.
func (*MockSubscriptionRepositoryMockRecorder) UpdateSubscription ¶ added in v0.6.0
func (mr *MockSubscriptionRepositoryMockRecorder) UpdateSubscription(ctx, projectID, subscription interface{}) *gomock.Call
UpdateSubscription indicates an expected call of UpdateSubscription.
type MockTracer ¶
type MockTracer struct {
// contains filtered or unexported fields
}
MockTracer is a mock of Tracer interface.
func NewMockTracer ¶
func NewMockTracer(ctrl *gomock.Controller) *MockTracer
NewMockTracer creates a new mock instance.
func (*MockTracer) EXPECT ¶
func (m *MockTracer) EXPECT() *MockTracerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTracer) NewContext ¶ added in v0.5.3
func (m *MockTracer) NewContext(ctx context.Context, txn *newrelic.Transaction) context.Context
NewContext mocks base method.
func (*MockTracer) RequestWithTransactionContext ¶
func (m *MockTracer) RequestWithTransactionContext(r *http.Request, txn *newrelic.Transaction) *http.Request
RequestWithTransactionContext mocks base method.
func (*MockTracer) SetWebRequestHTTP ¶
func (m *MockTracer) SetWebRequestHTTP(r *http.Request, txn *newrelic.Transaction)
SetWebRequestHTTP mocks base method.
func (*MockTracer) SetWebResponse ¶
func (m *MockTracer) SetWebResponse(w http.ResponseWriter, txn *newrelic.Transaction) http.ResponseWriter
SetWebResponse mocks base method.
func (*MockTracer) StartTransaction ¶
func (m *MockTracer) StartTransaction(name string) *newrelic.Transaction
StartTransaction mocks base method.
type MockTracerMockRecorder ¶
type MockTracerMockRecorder struct {
// contains filtered or unexported fields
}
MockTracerMockRecorder is the mock recorder for MockTracer.
func (*MockTracerMockRecorder) NewContext ¶ added in v0.5.3
func (mr *MockTracerMockRecorder) NewContext(ctx, txn interface{}) *gomock.Call
NewContext indicates an expected call of NewContext.
func (*MockTracerMockRecorder) RequestWithTransactionContext ¶
func (mr *MockTracerMockRecorder) RequestWithTransactionContext(r, txn interface{}) *gomock.Call
RequestWithTransactionContext indicates an expected call of RequestWithTransactionContext.
func (*MockTracerMockRecorder) SetWebRequestHTTP ¶
func (mr *MockTracerMockRecorder) SetWebRequestHTTP(r, txn interface{}) *gomock.Call
SetWebRequestHTTP indicates an expected call of SetWebRequestHTTP.
func (*MockTracerMockRecorder) SetWebResponse ¶
func (mr *MockTracerMockRecorder) SetWebResponse(w, txn interface{}) *gomock.Call
SetWebResponse indicates an expected call of SetWebResponse.
func (*MockTracerMockRecorder) StartTransaction ¶
func (mr *MockTracerMockRecorder) StartTransaction(name interface{}) *gomock.Call
StartTransaction indicates an expected call of StartTransaction.
type MockUserRepository ¶ added in v0.6.0
type MockUserRepository struct {
// contains filtered or unexported fields
}
MockUserRepository is a mock of UserRepository interface.
func NewMockUserRepository ¶ added in v0.6.0
func NewMockUserRepository(ctrl *gomock.Controller) *MockUserRepository
NewMockUserRepository creates a new mock instance.
func (*MockUserRepository) CreateUser ¶ added in v0.6.0
CreateUser mocks base method.
func (*MockUserRepository) EXPECT ¶ added in v0.6.0
func (m *MockUserRepository) EXPECT() *MockUserRepositoryMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockUserRepository) FindUserByEmail ¶ added in v0.6.0
func (m *MockUserRepository) FindUserByEmail(arg0 context.Context, arg1 string) (*datastore.User, error)
FindUserByEmail mocks base method.
func (*MockUserRepository) FindUserByEmailVerificationToken ¶ added in v0.8.0
func (m *MockUserRepository) FindUserByEmailVerificationToken(ctx context.Context, token string) (*datastore.User, error)
FindUserByEmailVerificationToken mocks base method.
func (*MockUserRepository) FindUserByID ¶ added in v0.6.0
func (m *MockUserRepository) FindUserByID(arg0 context.Context, arg1 string) (*datastore.User, error)
FindUserByID mocks base method.
func (*MockUserRepository) FindUserByToken ¶ added in v0.6.0
func (m *MockUserRepository) FindUserByToken(arg0 context.Context, arg1 string) (*datastore.User, error)
FindUserByToken mocks base method.
func (*MockUserRepository) LoadUsersPaged ¶ added in v0.6.0
func (m *MockUserRepository) LoadUsersPaged(arg0 context.Context, arg1 datastore.Pageable) ([]datastore.User, datastore.PaginationData, error)
LoadUsersPaged mocks base method.
func (*MockUserRepository) UpdateUser ¶ added in v0.6.0
UpdateUser mocks base method.
type MockUserRepositoryMockRecorder ¶ added in v0.6.0
type MockUserRepositoryMockRecorder struct {
// contains filtered or unexported fields
}
MockUserRepositoryMockRecorder is the mock recorder for MockUserRepository.
func (*MockUserRepositoryMockRecorder) CreateUser ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) CreateUser(arg0, arg1 interface{}) *gomock.Call
CreateUser indicates an expected call of CreateUser.
func (*MockUserRepositoryMockRecorder) FindUserByEmail ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) FindUserByEmail(arg0, arg1 interface{}) *gomock.Call
FindUserByEmail indicates an expected call of FindUserByEmail.
func (*MockUserRepositoryMockRecorder) FindUserByEmailVerificationToken ¶ added in v0.8.0
func (mr *MockUserRepositoryMockRecorder) FindUserByEmailVerificationToken(ctx, token interface{}) *gomock.Call
FindUserByEmailVerificationToken indicates an expected call of FindUserByEmailVerificationToken.
func (*MockUserRepositoryMockRecorder) FindUserByID ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) FindUserByID(arg0, arg1 interface{}) *gomock.Call
FindUserByID indicates an expected call of FindUserByID.
func (*MockUserRepositoryMockRecorder) FindUserByToken ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) FindUserByToken(arg0, arg1 interface{}) *gomock.Call
FindUserByToken indicates an expected call of FindUserByToken.
func (*MockUserRepositoryMockRecorder) LoadUsersPaged ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) LoadUsersPaged(arg0, arg1 interface{}) *gomock.Call
LoadUsersPaged indicates an expected call of LoadUsersPaged.
func (*MockUserRepositoryMockRecorder) UpdateUser ¶ added in v0.6.0
func (mr *MockUserRepositoryMockRecorder) UpdateUser(ctx, user interface{}) *gomock.Call
UpdateUser indicates an expected call of UpdateUser.
type MockWebSocketConnection ¶ added in v0.7.0
type MockWebSocketConnection struct {
// contains filtered or unexported fields
}
MockWebSocketConnection is a mock of WebSocketConnection interface.
func NewMockWebSocketConnection ¶ added in v0.7.0
func NewMockWebSocketConnection(ctrl *gomock.Controller) *MockWebSocketConnection
NewMockWebSocketConnection creates a new mock instance.
func (*MockWebSocketConnection) Close ¶ added in v0.7.0
func (m *MockWebSocketConnection) Close() error
Close mocks base method.
func (*MockWebSocketConnection) EXPECT ¶ added in v0.7.0
func (m *MockWebSocketConnection) EXPECT() *MockWebSocketConnectionMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockWebSocketConnection) ReadMessage ¶ added in v0.7.0
func (m *MockWebSocketConnection) ReadMessage() (int, []byte, error)
ReadMessage mocks base method.
func (*MockWebSocketConnection) SetPingHandler ¶ added in v0.7.0
func (m *MockWebSocketConnection) SetPingHandler(h func(string) error)
SetPingHandler mocks base method.
func (*MockWebSocketConnection) SetReadLimit ¶ added in v0.7.0
func (m *MockWebSocketConnection) SetReadLimit(limit int64)
SetReadLimit mocks base method.
func (*MockWebSocketConnection) WriteMessage ¶ added in v0.7.0
func (m *MockWebSocketConnection) WriteMessage(messageType int, data []byte) error
WriteMessage mocks base method.
type MockWebSocketConnectionMockRecorder ¶ added in v0.7.0
type MockWebSocketConnectionMockRecorder struct {
// contains filtered or unexported fields
}
MockWebSocketConnectionMockRecorder is the mock recorder for MockWebSocketConnection.
func (*MockWebSocketConnectionMockRecorder) Close ¶ added in v0.7.0
func (mr *MockWebSocketConnectionMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockWebSocketConnectionMockRecorder) ReadMessage ¶ added in v0.7.0
func (mr *MockWebSocketConnectionMockRecorder) ReadMessage() *gomock.Call
ReadMessage indicates an expected call of ReadMessage.
func (*MockWebSocketConnectionMockRecorder) SetPingHandler ¶ added in v0.7.0
func (mr *MockWebSocketConnectionMockRecorder) SetPingHandler(h interface{}) *gomock.Call
SetPingHandler indicates an expected call of SetPingHandler.
func (*MockWebSocketConnectionMockRecorder) SetReadLimit ¶ added in v0.7.0
func (mr *MockWebSocketConnectionMockRecorder) SetReadLimit(limit interface{}) *gomock.Call
SetReadLimit indicates an expected call of SetReadLimit.
func (*MockWebSocketConnectionMockRecorder) WriteMessage ¶ added in v0.7.0
func (mr *MockWebSocketConnectionMockRecorder) WriteMessage(messageType, data interface{}) *gomock.Call
WriteMessage indicates an expected call of WriteMessage.