Help us shape the future of Go! Take the 2026 Go Developer Survey

mock

package
v2.10.0 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2026 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.