mock

package
v2.7.6 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockBucketService 

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

MockBucketService is a mock of BucketService interface.

func NewMockBucketService 

func NewMockBucketService(ctrl *gomock.Controller) *MockBucketService

NewMockBucketService creates a new mock instance.

func (*MockBucketService) EXPECT 

func (m *MockBucketService) EXPECT() *MockBucketServiceMockRecorder

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

func (*MockBucketService) FindBucketByID 

func (m *MockBucketService) FindBucketByID(arg0 context.Context, arg1 platform.ID) (*influxdb.Bucket, error)

FindBucketByID mocks base method.

func (*MockBucketService) RLock 

func (m *MockBucketService) RLock()

RLock mocks base method.

func (*MockBucketService) RUnlock 

func (m *MockBucketService) RUnlock()

RUnlock mocks base method.

type MockBucketServiceMockRecorder 

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

MockBucketServiceMockRecorder is the mock recorder for MockBucketService.

func (*MockBucketServiceMockRecorder) FindBucketByID 

func (mr *MockBucketServiceMockRecorder) FindBucketByID(arg0, arg1 interface{}) *gomock.Call

FindBucketByID indicates an expected call of FindBucketByID.

func (*MockBucketServiceMockRecorder) RLock 

func (mr *MockBucketServiceMockRecorder) RLock() *gomock.Call

RLock indicates an expected call of RLock.

func (*MockBucketServiceMockRecorder) RUnlock 

func (mr *MockBucketServiceMockRecorder) RUnlock() *gomock.Call

RUnlock indicates an expected call of RUnlock.

type MockDurableQueueManager 

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

MockDurableQueueManager is a mock of DurableQueueManager interface.

func NewMockDurableQueueManager 

func NewMockDurableQueueManager(ctrl *gomock.Controller) *MockDurableQueueManager

NewMockDurableQueueManager creates a new mock instance.

func (*MockDurableQueueManager) CloseAll 

func (m *MockDurableQueueManager) CloseAll() error

CloseAll mocks base method.

func (*MockDurableQueueManager) CurrentQueueSizes 

func (m *MockDurableQueueManager) CurrentQueueSizes(arg0 []platform.ID) (map[platform.ID]int64, error)

CurrentQueueSizes mocks base method.

func (*MockDurableQueueManager) DeleteQueue 

func (m *MockDurableQueueManager) DeleteQueue(arg0 platform.ID) error

DeleteQueue mocks base method.

func (*MockDurableQueueManager) EXPECT 

func (m *MockDurableQueueManager) EXPECT() *MockDurableQueueManagerMockRecorder

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

func (*MockDurableQueueManager) EnqueueData 

func (m *MockDurableQueueManager) EnqueueData(arg0 platform.ID, arg1 []byte, arg2 int) error

EnqueueData mocks base method.

func (*MockDurableQueueManager) GetReplications 

func (m *MockDurableQueueManager) GetReplications(arg0, arg1 platform.ID) []platform.ID

GetReplications mocks base method.

func (*MockDurableQueueManager) InitializeQueue 

func (m *MockDurableQueueManager) InitializeQueue(arg0 platform.ID, arg1 int64, arg2, arg3 platform.ID, arg4 int64) error

InitializeQueue mocks base method.

func (*MockDurableQueueManager) RemainingQueueSizes added in v2.7.0 

func (m *MockDurableQueueManager) RemainingQueueSizes(arg0 []platform.ID) (map[platform.ID]int64, error)

RemainingQueueSizes mocks base method.

func (*MockDurableQueueManager) StartReplicationQueues 

func (m *MockDurableQueueManager) StartReplicationQueues(arg0 map[platform.ID]*influxdb.TrackedReplication) error

StartReplicationQueues mocks base method.

func (*MockDurableQueueManager) UpdateMaxQueueSize 

func (m *MockDurableQueueManager) UpdateMaxQueueSize(arg0 platform.ID, arg1 int64) error

UpdateMaxQueueSize mocks base method.

type MockDurableQueueManagerMockRecorder 

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

MockDurableQueueManagerMockRecorder is the mock recorder for MockDurableQueueManager.

func (*MockDurableQueueManagerMockRecorder) CloseAll 

func (mr *MockDurableQueueManagerMockRecorder) CloseAll() *gomock.Call

CloseAll indicates an expected call of CloseAll.

func (*MockDurableQueueManagerMockRecorder) CurrentQueueSizes 

func (mr *MockDurableQueueManagerMockRecorder) CurrentQueueSizes(arg0 interface{}) *gomock.Call

CurrentQueueSizes indicates an expected call of CurrentQueueSizes.

func (*MockDurableQueueManagerMockRecorder) DeleteQueue 

func (mr *MockDurableQueueManagerMockRecorder) DeleteQueue(arg0 interface{}) *gomock.Call

DeleteQueue indicates an expected call of DeleteQueue.

func (*MockDurableQueueManagerMockRecorder) EnqueueData 

func (mr *MockDurableQueueManagerMockRecorder) EnqueueData(arg0, arg1, arg2 interface{}) *gomock.Call

EnqueueData indicates an expected call of EnqueueData.

func (*MockDurableQueueManagerMockRecorder) GetReplications 

func (mr *MockDurableQueueManagerMockRecorder) GetReplications(arg0, arg1 interface{}) *gomock.Call

GetReplications indicates an expected call of GetReplications.

func (*MockDurableQueueManagerMockRecorder) InitializeQueue 

func (mr *MockDurableQueueManagerMockRecorder) InitializeQueue(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call

InitializeQueue indicates an expected call of InitializeQueue.

func (*MockDurableQueueManagerMockRecorder) RemainingQueueSizes added in v2.7.0 

func (mr *MockDurableQueueManagerMockRecorder) RemainingQueueSizes(arg0 interface{}) *gomock.Call

RemainingQueueSizes indicates an expected call of RemainingQueueSizes.

func (*MockDurableQueueManagerMockRecorder) StartReplicationQueues 

func (mr *MockDurableQueueManagerMockRecorder) StartReplicationQueues(arg0 interface{}) *gomock.Call

StartReplicationQueues indicates an expected call of StartReplicationQueues.

func (*MockDurableQueueManagerMockRecorder) UpdateMaxQueueSize 

func (mr *MockDurableQueueManagerMockRecorder) UpdateMaxQueueSize(arg0, arg1 interface{}) *gomock.Call

UpdateMaxQueueSize indicates an expected call of UpdateMaxQueueSize.

type MockHttpConfigStore 

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

MockHttpConfigStore is a mock of HttpConfigStore interface.

func NewMockHttpConfigStore 

func NewMockHttpConfigStore(ctrl *gomock.Controller) *MockHttpConfigStore

NewMockHttpConfigStore creates a new mock instance.

func (*MockHttpConfigStore) EXPECT 

func (m *MockHttpConfigStore) EXPECT() *MockHttpConfigStoreMockRecorder

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

func (*MockHttpConfigStore) GetFullHTTPConfig 

func (m *MockHttpConfigStore) GetFullHTTPConfig(arg0 context.Context, arg1 platform.ID) (*influxdb.ReplicationHTTPConfig, error)

GetFullHTTPConfig mocks base method.

func (*MockHttpConfigStore) UpdateResponseInfo 

func (m *MockHttpConfigStore) UpdateResponseInfo(arg0 context.Context, arg1 platform.ID, arg2 int, arg3 string) error

UpdateResponseInfo mocks base method.

type MockHttpConfigStoreMockRecorder 

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

MockHttpConfigStoreMockRecorder is the mock recorder for MockHttpConfigStore.

func (*MockHttpConfigStoreMockRecorder) GetFullHTTPConfig 

func (mr *MockHttpConfigStoreMockRecorder) GetFullHTTPConfig(arg0, arg1 interface{}) *gomock.Call

GetFullHTTPConfig indicates an expected call of GetFullHTTPConfig.

func (*MockHttpConfigStoreMockRecorder) UpdateResponseInfo 

func (mr *MockHttpConfigStoreMockRecorder) UpdateResponseInfo(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UpdateResponseInfo indicates an expected call of UpdateResponseInfo.

type MockPointsWriter 

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

MockPointsWriter is a mock of PointsWriter interface.

func NewMockPointsWriter 

func NewMockPointsWriter(ctrl *gomock.Controller) *MockPointsWriter

NewMockPointsWriter creates a new mock instance.

func (*MockPointsWriter) EXPECT 

func (m *MockPointsWriter) EXPECT() *MockPointsWriterMockRecorder

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

func (*MockPointsWriter) WritePoints 

func (m *MockPointsWriter) WritePoints(arg0 context.Context, arg1, arg2 platform.ID, arg3 []models.Point) error

WritePoints mocks base method.

type MockPointsWriterMockRecorder 

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

MockPointsWriterMockRecorder is the mock recorder for MockPointsWriter.

func (*MockPointsWriterMockRecorder) WritePoints 

func (mr *MockPointsWriterMockRecorder) WritePoints(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

WritePoints indicates an expected call of WritePoints.

type MockReplicationService 

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

MockReplicationService is a mock of ReplicationService interface.

func NewMockReplicationService 

func NewMockReplicationService(ctrl *gomock.Controller) *MockReplicationService

NewMockReplicationService creates a new mock instance.

func (*MockReplicationService) CreateReplication 

func (m *MockReplicationService) CreateReplication(arg0 context.Context, arg1 influxdb.CreateReplicationRequest) (*influxdb.Replication, error)

CreateReplication mocks base method.

func (*MockReplicationService) DeleteReplication 

func (m *MockReplicationService) DeleteReplication(arg0 context.Context, arg1 platform.ID) error

DeleteReplication mocks base method.

func (*MockReplicationService) EXPECT 

func (m *MockReplicationService) EXPECT() *MockReplicationServiceMockRecorder

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

func (*MockReplicationService) GetReplication 

func (m *MockReplicationService) GetReplication(arg0 context.Context, arg1 platform.ID) (*influxdb.Replication, error)

GetReplication mocks base method.

func (*MockReplicationService) ListReplications 

func (m *MockReplicationService) ListReplications(arg0 context.Context, arg1 influxdb.ReplicationListFilter) (*influxdb.Replications, error)

ListReplications mocks base method.

func (*MockReplicationService) UpdateReplication 

func (m *MockReplicationService) UpdateReplication(arg0 context.Context, arg1 platform.ID, arg2 influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)

UpdateReplication mocks base method.

func (*MockReplicationService) ValidateNewReplication 

func (m *MockReplicationService) ValidateNewReplication(arg0 context.Context, arg1 influxdb.CreateReplicationRequest) error

ValidateNewReplication mocks base method.

func (*MockReplicationService) ValidateReplication 

func (m *MockReplicationService) ValidateReplication(arg0 context.Context, arg1 platform.ID) error

ValidateReplication mocks base method.

func (*MockReplicationService) ValidateUpdatedReplication 

func (m *MockReplicationService) ValidateUpdatedReplication(arg0 context.Context, arg1 platform.ID, arg2 influxdb.UpdateReplicationRequest) error

ValidateUpdatedReplication mocks base method.

type MockReplicationServiceMockRecorder 

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

MockReplicationServiceMockRecorder is the mock recorder for MockReplicationService.

func (*MockReplicationServiceMockRecorder) CreateReplication 

func (mr *MockReplicationServiceMockRecorder) CreateReplication(arg0, arg1 interface{}) *gomock.Call

CreateReplication indicates an expected call of CreateReplication.

func (*MockReplicationServiceMockRecorder) DeleteReplication 

func (mr *MockReplicationServiceMockRecorder) DeleteReplication(arg0, arg1 interface{}) *gomock.Call

DeleteReplication indicates an expected call of DeleteReplication.

func (*MockReplicationServiceMockRecorder) GetReplication 

func (mr *MockReplicationServiceMockRecorder) GetReplication(arg0, arg1 interface{}) *gomock.Call

GetReplication indicates an expected call of GetReplication.

func (*MockReplicationServiceMockRecorder) ListReplications 

func (mr *MockReplicationServiceMockRecorder) ListReplications(arg0, arg1 interface{}) *gomock.Call

ListReplications indicates an expected call of ListReplications.

func (*MockReplicationServiceMockRecorder) UpdateReplication 

func (mr *MockReplicationServiceMockRecorder) UpdateReplication(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateReplication indicates an expected call of UpdateReplication.

func (*MockReplicationServiceMockRecorder) ValidateNewReplication 

func (mr *MockReplicationServiceMockRecorder) ValidateNewReplication(arg0, arg1 interface{}) *gomock.Call

ValidateNewReplication indicates an expected call of ValidateNewReplication.

func (*MockReplicationServiceMockRecorder) ValidateReplication 

func (mr *MockReplicationServiceMockRecorder) ValidateReplication(arg0, arg1 interface{}) *gomock.Call

ValidateReplication indicates an expected call of ValidateReplication.

func (*MockReplicationServiceMockRecorder) ValidateUpdatedReplication 

func (mr *MockReplicationServiceMockRecorder) ValidateUpdatedReplication(arg0, arg1, arg2 interface{}) *gomock.Call

ValidateUpdatedReplication indicates an expected call of ValidateUpdatedReplication.

type MockReplicationValidator 

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

MockReplicationValidator is a mock of ReplicationValidator interface.

func NewMockReplicationValidator 

func NewMockReplicationValidator(ctrl *gomock.Controller) *MockReplicationValidator

NewMockReplicationValidator creates a new mock instance.

func (*MockReplicationValidator) EXPECT 

func (m *MockReplicationValidator) EXPECT() *MockReplicationValidatorMockRecorder

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

func (*MockReplicationValidator) ValidateReplication 

func (m *MockReplicationValidator) ValidateReplication(arg0 context.Context, arg1 *influxdb.ReplicationHTTPConfig) error

ValidateReplication mocks base method.

type MockReplicationValidatorMockRecorder 

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

MockReplicationValidatorMockRecorder is the mock recorder for MockReplicationValidator.

func (*MockReplicationValidatorMockRecorder) ValidateReplication 

func (mr *MockReplicationValidatorMockRecorder) ValidateReplication(arg0, arg1 interface{}) *gomock.Call

ValidateReplication indicates an expected call of ValidateReplication.

type MockServiceStore 

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

MockServiceStore is a mock of ServiceStore interface.

func NewMockServiceStore 

func NewMockServiceStore(ctrl *gomock.Controller) *MockServiceStore

NewMockServiceStore creates a new mock instance.

func (*MockServiceStore) CreateReplication 

func (m *MockServiceStore) CreateReplication(arg0 context.Context, arg1 platform.ID, arg2 influxdb.CreateReplicationRequest) (*influxdb.Replication, error)

CreateReplication mocks base method.

func (*MockServiceStore) DeleteBucketReplications 

func (m *MockServiceStore) DeleteBucketReplications(arg0 context.Context, arg1 platform.ID) ([]platform.ID, error)

DeleteBucketReplications mocks base method.

func (*MockServiceStore) DeleteReplication 

func (m *MockServiceStore) DeleteReplication(arg0 context.Context, arg1 platform.ID) error

DeleteReplication mocks base method.

func (*MockServiceStore) EXPECT 

func (m *MockServiceStore) EXPECT() *MockServiceStoreMockRecorder

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

func (*MockServiceStore) GetFullHTTPConfig 

func (m *MockServiceStore) GetFullHTTPConfig(arg0 context.Context, arg1 platform.ID) (*influxdb.ReplicationHTTPConfig, error)

GetFullHTTPConfig mocks base method.

func (*MockServiceStore) GetReplication 

func (m *MockServiceStore) GetReplication(arg0 context.Context, arg1 platform.ID) (*influxdb.Replication, error)

GetReplication mocks base method.

func (*MockServiceStore) ListReplications 

func (m *MockServiceStore) ListReplications(arg0 context.Context, arg1 influxdb.ReplicationListFilter) (*influxdb.Replications, error)

ListReplications mocks base method.

func (*MockServiceStore) Lock 

func (m *MockServiceStore) Lock()

Lock mocks base method.

func (*MockServiceStore) PopulateRemoteHTTPConfig 

func (m *MockServiceStore) PopulateRemoteHTTPConfig(arg0 context.Context, arg1 platform.ID, arg2 *influxdb.ReplicationHTTPConfig) error

PopulateRemoteHTTPConfig mocks base method.

func (*MockServiceStore) Unlock 

func (m *MockServiceStore) Unlock()

Unlock mocks base method.

func (*MockServiceStore) UpdateReplication 

func (m *MockServiceStore) UpdateReplication(arg0 context.Context, arg1 platform.ID, arg2 influxdb.UpdateReplicationRequest) (*influxdb.Replication, error)

UpdateReplication mocks base method.

type MockServiceStoreMockRecorder 

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

MockServiceStoreMockRecorder is the mock recorder for MockServiceStore.

func (*MockServiceStoreMockRecorder) CreateReplication 

func (mr *MockServiceStoreMockRecorder) CreateReplication(arg0, arg1, arg2 interface{}) *gomock.Call

CreateReplication indicates an expected call of CreateReplication.

func (*MockServiceStoreMockRecorder) DeleteBucketReplications 

func (mr *MockServiceStoreMockRecorder) DeleteBucketReplications(arg0, arg1 interface{}) *gomock.Call

DeleteBucketReplications indicates an expected call of DeleteBucketReplications.

func (*MockServiceStoreMockRecorder) DeleteReplication 

func (mr *MockServiceStoreMockRecorder) DeleteReplication(arg0, arg1 interface{}) *gomock.Call

DeleteReplication indicates an expected call of DeleteReplication.

func (*MockServiceStoreMockRecorder) GetFullHTTPConfig 

func (mr *MockServiceStoreMockRecorder) GetFullHTTPConfig(arg0, arg1 interface{}) *gomock.Call

GetFullHTTPConfig indicates an expected call of GetFullHTTPConfig.

func (*MockServiceStoreMockRecorder) GetReplication 

func (mr *MockServiceStoreMockRecorder) GetReplication(arg0, arg1 interface{}) *gomock.Call

GetReplication indicates an expected call of GetReplication.

func (*MockServiceStoreMockRecorder) ListReplications 

func (mr *MockServiceStoreMockRecorder) ListReplications(arg0, arg1 interface{}) *gomock.Call

ListReplications indicates an expected call of ListReplications.

func (*MockServiceStoreMockRecorder) Lock 

func (mr *MockServiceStoreMockRecorder) Lock() *gomock.Call

Lock indicates an expected call of Lock.

func (*MockServiceStoreMockRecorder) PopulateRemoteHTTPConfig 

func (mr *MockServiceStoreMockRecorder) PopulateRemoteHTTPConfig(arg0, arg1, arg2 interface{}) *gomock.Call

PopulateRemoteHTTPConfig indicates an expected call of PopulateRemoteHTTPConfig.

func (*MockServiceStoreMockRecorder) Unlock 

func (mr *MockServiceStoreMockRecorder) Unlock() *gomock.Call

Unlock indicates an expected call of Unlock.

func (*MockServiceStoreMockRecorder) UpdateReplication 

func (mr *MockServiceStoreMockRecorder) UpdateReplication(arg0, arg1, arg2 interface{}) *gomock.Call

UpdateReplication indicates an expected call of UpdateReplication.

Source Files

View all Source files

Jump to

Keyboard shortcuts

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