mock_etcd

package
v0.0.0-...-7f57e1f Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mock_etcd is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockCDCEtcdClient 

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

MockCDCEtcdClient is a mock of CDCEtcdClient interface.

func NewMockCDCEtcdClient 

func NewMockCDCEtcdClient(ctrl *gomock.Controller) *MockCDCEtcdClient

NewMockCDCEtcdClient creates a new mock instance.

func (*MockCDCEtcdClient) CheckMultipleCDCClusterExist 

func (m *MockCDCEtcdClient) CheckMultipleCDCClusterExist(ctx context.Context) error

CheckMultipleCDCClusterExist mocks base method.

func (*MockCDCEtcdClient) CreateChangefeedInfo 

func (m *MockCDCEtcdClient) CreateChangefeedInfo(arg0 context.Context, arg1 *model.UpstreamInfo, arg2 *model.ChangeFeedInfo) error

CreateChangefeedInfo mocks base method.

func (*MockCDCEtcdClient) DeleteCaptureInfo 

func (m *MockCDCEtcdClient) DeleteCaptureInfo(arg0 context.Context, arg1 model.CaptureID) error

DeleteCaptureInfo mocks base method.

func (*MockCDCEtcdClient) EXPECT 

func (m *MockCDCEtcdClient) EXPECT() *MockCDCEtcdClientMockRecorder

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

func (*MockCDCEtcdClient) GetAllCDCInfo 

func (m *MockCDCEtcdClient) GetAllCDCInfo(ctx context.Context) ([]*mvccpb.KeyValue, error)

GetAllCDCInfo mocks base method.

func (*MockCDCEtcdClient) GetAllChangeFeedInfo 

func (m *MockCDCEtcdClient) GetAllChangeFeedInfo(ctx context.Context) (map[model.ChangeFeedID]*model.ChangeFeedInfo, error)

GetAllChangeFeedInfo mocks base method.

func (*MockCDCEtcdClient) GetCaptures 

func (m *MockCDCEtcdClient) GetCaptures(arg0 context.Context) (int64, []*model.CaptureInfo, error)

GetCaptures mocks base method.

func (*MockCDCEtcdClient) GetChangeFeedInfo 

func (m *MockCDCEtcdClient) GetChangeFeedInfo(ctx context.Context, id model.ChangeFeedID) (*model.ChangeFeedInfo, error)

GetChangeFeedInfo mocks base method.

func (*MockCDCEtcdClient) GetChangeFeedStatus 

func (m *MockCDCEtcdClient) GetChangeFeedStatus(ctx context.Context, id model.ChangeFeedID) (*model.ChangeFeedStatus, int64, error)

GetChangeFeedStatus mocks base method.

func (*MockCDCEtcdClient) GetClusterID 

func (m *MockCDCEtcdClient) GetClusterID() string

GetClusterID mocks base method.

func (*MockCDCEtcdClient) GetEnsureGCServiceID 

func (m *MockCDCEtcdClient) GetEnsureGCServiceID(tag string) string

GetEnsureGCServiceID mocks base method.

func (*MockCDCEtcdClient) GetEtcdClient 

func (m *MockCDCEtcdClient) GetEtcdClient() *etcd.Client

GetEtcdClient mocks base method.

func (*MockCDCEtcdClient) GetGCServiceID 

func (m *MockCDCEtcdClient) GetGCServiceID() string

GetGCServiceID mocks base method.

func (*MockCDCEtcdClient) GetOwnerID 

func (m *MockCDCEtcdClient) GetOwnerID(arg0 context.Context) (model.CaptureID, error)

GetOwnerID mocks base method.

func (*MockCDCEtcdClient) GetOwnerRevision 

func (m *MockCDCEtcdClient) GetOwnerRevision(arg0 context.Context, arg1 model.CaptureID) (int64, error)

GetOwnerRevision mocks base method.

func (*MockCDCEtcdClient) GetUpstreamInfo 

func (m *MockCDCEtcdClient) GetUpstreamInfo(ctx context.Context, upstreamID model.UpstreamID, namespace string) (*model.UpstreamInfo, error)

GetUpstreamInfo mocks base method.

func (*MockCDCEtcdClient) PutCaptureInfo 

func (m *MockCDCEtcdClient) PutCaptureInfo(arg0 context.Context, arg1 *model.CaptureInfo, arg2 clientv3.LeaseID) error

PutCaptureInfo mocks base method.

func (*MockCDCEtcdClient) SaveChangeFeedInfo 

func (m *MockCDCEtcdClient) SaveChangeFeedInfo(ctx context.Context, info *model.ChangeFeedInfo, changeFeedID model.ChangeFeedID) error

SaveChangeFeedInfo mocks base method.

func (*MockCDCEtcdClient) UpdateChangefeedAndUpstream 

func (m *MockCDCEtcdClient) UpdateChangefeedAndUpstream(ctx context.Context, upstreamInfo *model.UpstreamInfo, changeFeedInfo *model.ChangeFeedInfo) error

UpdateChangefeedAndUpstream mocks base method.

type MockCDCEtcdClientMockRecorder 

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

MockCDCEtcdClientMockRecorder is the mock recorder for MockCDCEtcdClient.

func (*MockCDCEtcdClientMockRecorder) CheckMultipleCDCClusterExist 

func (mr *MockCDCEtcdClientMockRecorder) CheckMultipleCDCClusterExist(ctx interface{}) *gomock.Call

CheckMultipleCDCClusterExist indicates an expected call of CheckMultipleCDCClusterExist.

func (*MockCDCEtcdClientMockRecorder) CreateChangefeedInfo 

func (mr *MockCDCEtcdClientMockRecorder) CreateChangefeedInfo(arg0, arg1, arg2 interface{}) *gomock.Call

CreateChangefeedInfo indicates an expected call of CreateChangefeedInfo.

func (*MockCDCEtcdClientMockRecorder) DeleteCaptureInfo 

func (mr *MockCDCEtcdClientMockRecorder) DeleteCaptureInfo(arg0, arg1 interface{}) *gomock.Call

DeleteCaptureInfo indicates an expected call of DeleteCaptureInfo.

func (*MockCDCEtcdClientMockRecorder) GetAllCDCInfo 

func (mr *MockCDCEtcdClientMockRecorder) GetAllCDCInfo(ctx interface{}) *gomock.Call

GetAllCDCInfo indicates an expected call of GetAllCDCInfo.

func (*MockCDCEtcdClientMockRecorder) GetAllChangeFeedInfo 

func (mr *MockCDCEtcdClientMockRecorder) GetAllChangeFeedInfo(ctx interface{}) *gomock.Call

GetAllChangeFeedInfo indicates an expected call of GetAllChangeFeedInfo.

func (*MockCDCEtcdClientMockRecorder) GetCaptures 

func (mr *MockCDCEtcdClientMockRecorder) GetCaptures(arg0 interface{}) *gomock.Call

GetCaptures indicates an expected call of GetCaptures.

func (*MockCDCEtcdClientMockRecorder) GetChangeFeedInfo 

func (mr *MockCDCEtcdClientMockRecorder) GetChangeFeedInfo(ctx, id interface{}) *gomock.Call

GetChangeFeedInfo indicates an expected call of GetChangeFeedInfo.

func (*MockCDCEtcdClientMockRecorder) GetChangeFeedStatus 

func (mr *MockCDCEtcdClientMockRecorder) GetChangeFeedStatus(ctx, id interface{}) *gomock.Call

GetChangeFeedStatus indicates an expected call of GetChangeFeedStatus.

func (*MockCDCEtcdClientMockRecorder) GetClusterID 

func (mr *MockCDCEtcdClientMockRecorder) GetClusterID() *gomock.Call

GetClusterID indicates an expected call of GetClusterID.

func (*MockCDCEtcdClientMockRecorder) GetEnsureGCServiceID 

func (mr *MockCDCEtcdClientMockRecorder) GetEnsureGCServiceID(tag interface{}) *gomock.Call

GetEnsureGCServiceID indicates an expected call of GetEnsureGCServiceID.

func (*MockCDCEtcdClientMockRecorder) GetEtcdClient 

func (mr *MockCDCEtcdClientMockRecorder) GetEtcdClient() *gomock.Call

GetEtcdClient indicates an expected call of GetEtcdClient.

func (*MockCDCEtcdClientMockRecorder) GetGCServiceID 

func (mr *MockCDCEtcdClientMockRecorder) GetGCServiceID() *gomock.Call

GetGCServiceID indicates an expected call of GetGCServiceID.

func (*MockCDCEtcdClientMockRecorder) GetOwnerID 

func (mr *MockCDCEtcdClientMockRecorder) GetOwnerID(arg0 interface{}) *gomock.Call

GetOwnerID indicates an expected call of GetOwnerID.

func (*MockCDCEtcdClientMockRecorder) GetOwnerRevision 

func (mr *MockCDCEtcdClientMockRecorder) GetOwnerRevision(arg0, arg1 interface{}) *gomock.Call

GetOwnerRevision indicates an expected call of GetOwnerRevision.

func (*MockCDCEtcdClientMockRecorder) GetUpstreamInfo 

func (mr *MockCDCEtcdClientMockRecorder) GetUpstreamInfo(ctx, upstreamID, namespace interface{}) *gomock.Call

GetUpstreamInfo indicates an expected call of GetUpstreamInfo.

func (*MockCDCEtcdClientMockRecorder) PutCaptureInfo 

func (mr *MockCDCEtcdClientMockRecorder) PutCaptureInfo(arg0, arg1, arg2 interface{}) *gomock.Call

PutCaptureInfo indicates an expected call of PutCaptureInfo.

func (*MockCDCEtcdClientMockRecorder) SaveChangeFeedInfo 

func (mr *MockCDCEtcdClientMockRecorder) SaveChangeFeedInfo(ctx, info, changeFeedID interface{}) *gomock.Call

SaveChangeFeedInfo indicates an expected call of SaveChangeFeedInfo.

func (*MockCDCEtcdClientMockRecorder) UpdateChangefeedAndUpstream 

func (mr *MockCDCEtcdClientMockRecorder) UpdateChangefeedAndUpstream(ctx, upstreamInfo, changeFeedInfo interface{}) *gomock.Call

UpdateChangefeedAndUpstream indicates an expected call of UpdateChangefeedAndUpstream.

type MockOwnerCaptureInfoClient 

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

MockOwnerCaptureInfoClient is a mock of OwnerCaptureInfoClient interface.

func NewMockOwnerCaptureInfoClient 

func NewMockOwnerCaptureInfoClient(ctrl *gomock.Controller) *MockOwnerCaptureInfoClient

NewMockOwnerCaptureInfoClient creates a new mock instance.

func (*MockOwnerCaptureInfoClient) EXPECT 

func (m *MockOwnerCaptureInfoClient) EXPECT() *MockOwnerCaptureInfoClientMockRecorder

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

func (*MockOwnerCaptureInfoClient) GetCaptures 

func (m *MockOwnerCaptureInfoClient) GetCaptures(arg0 context.Context) (int64, []*model.CaptureInfo, error)

GetCaptures mocks base method.

func (*MockOwnerCaptureInfoClient) GetOwnerID 

func (m *MockOwnerCaptureInfoClient) GetOwnerID(arg0 context.Context) (model.CaptureID, error)

GetOwnerID mocks base method.

func (*MockOwnerCaptureInfoClient) GetOwnerRevision 

func (m *MockOwnerCaptureInfoClient) GetOwnerRevision(arg0 context.Context, arg1 model.CaptureID) (int64, error)

GetOwnerRevision mocks base method.

type MockOwnerCaptureInfoClientMockRecorder 

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

MockOwnerCaptureInfoClientMockRecorder is the mock recorder for MockOwnerCaptureInfoClient.

func (*MockOwnerCaptureInfoClientMockRecorder) GetCaptures 

func (mr *MockOwnerCaptureInfoClientMockRecorder) GetCaptures(arg0 interface{}) *gomock.Call

GetCaptures indicates an expected call of GetCaptures.

func (*MockOwnerCaptureInfoClientMockRecorder) GetOwnerID 

func (mr *MockOwnerCaptureInfoClientMockRecorder) GetOwnerID(arg0 interface{}) *gomock.Call

GetOwnerID indicates an expected call of GetOwnerID.

func (*MockOwnerCaptureInfoClientMockRecorder) GetOwnerRevision 

func (mr *MockOwnerCaptureInfoClientMockRecorder) GetOwnerRevision(arg0, arg1 interface{}) *gomock.Call

GetOwnerRevision indicates an expected call of GetOwnerRevision.

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.