mocks

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Oct 15, 2023 License: MPL-2.0 Imports: 12 Imported by: 0

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

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

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

CreateAPIKey mocks base method.

func (*MockAPIKeyRepository) EXPECT

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

LoadAPIKeysPaged mocks base method.

func (*MockAPIKeyRepository) RevokeAPIKeys

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

RevokeAPIKeys mocks base method.

func (*MockAPIKeyRepository) UpdateAPIKey

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

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) Delete added in v0.5.3

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

Delete mocks base method.

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.

func (*MockCache) Get added in v0.5.3

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

Get mocks base method.

func (*MockCache) Set added in v0.5.3

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

Set mocks base method.

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

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

func (*MockConfigurationRepository) LoadConfiguration added in v0.6.0

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

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

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

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

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

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) CopyRows added in v1.1.6

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

CopyRows mocks base method.

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

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

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

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

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

func (*MockExportRepository) ExportRecords added in v0.9.0

func (m *MockExportRepository) ExportRecords(ctx context.Context, tableName, projectID string, createdAt time.Time, w io.Writer) (int64, error)

ExportRecords mocks base method.

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

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) CreateJob added in v1.1.6

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

CreateJob mocks base method.

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

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

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

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

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

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

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

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

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

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 (m *MockPortalLinkRepository) CreatePortalLink(arg0 context.Context, arg1 *datastore.PortalLink) error

CreatePortalLink mocks base method.

func (*MockPortalLinkRepository) EXPECT added in v0.8.0

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

LoadPortalLinksPaged mocks base method.

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

RevokePortalLink mocks base method.

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 (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 (mr *MockPortalLinkRepositoryMockRecorder) RevokePortalLink(ctx, projectID, id interface{}) *gomock.Call

RevokePortalLink indicates an expected call of RevokePortalLink.

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

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

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

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

LoadProjects mocks base method.

func (*MockProjectRepository) UpdateProject added in v0.8.0

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

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.

func (*MockPubSub) Start added in v0.9.0

func (m *MockPubSub) Start()

Start mocks base method.

func (*MockPubSub) Stop added in v0.9.0

func (m *MockPubSub) Stop()

Stop mocks base method.

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.

func (*MockQueuer) Write

func (m *MockQueuer) Write(arg0 convoy.TaskName, arg1 convoy.QueueName, arg2 *queue.Job) error

Write 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

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

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

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

func (*MockSmtpClient) SendEmail added in v0.6.0

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

SendEmail mocks base method.

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

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

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

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

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

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

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

CreateUser mocks base method.

func (*MockUserRepository) EXPECT added in v0.6.0

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

LoadUsersPaged mocks base method.

func (*MockUserRepository) UpdateUser added in v0.6.0

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

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

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL