mock_owner

package
v0.0.0-...-1d14c1d Latest Latest
Warning

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

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

Documentation

Overview

Package mock_owner is a generated GoMock package.

Package mock_owner is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockOwner 

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

MockOwner is a mock of Owner interface.

func NewMockOwner 

func NewMockOwner(ctrl *gomock.Controller) *MockOwner

NewMockOwner creates a new mock instance.

func (*MockOwner) AsyncStop 

func (m *MockOwner) AsyncStop()

AsyncStop mocks base method.

func (*MockOwner) CreateChangefeed 

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

CreateChangefeed mocks base method.

func (*MockOwner) DrainCapture 

func (m *MockOwner) DrainCapture(query *scheduler.Query, done chan<- error)

DrainCapture mocks base method.

func (*MockOwner) EXPECT 

func (m *MockOwner) EXPECT() *MockOwnerMockRecorder

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

func (*MockOwner) EnqueueJob 

func (m *MockOwner) EnqueueJob(adminJob model.AdminJob, done chan<- error)

EnqueueJob mocks base method.

func (*MockOwner) Query 

func (m *MockOwner) Query(query *owner.Query, done chan<- error)

Query mocks base method.

func (*MockOwner) RebalanceTables 

func (m *MockOwner) RebalanceTables(cfID model.ChangeFeedID, done chan<- error)

RebalanceTables mocks base method.

func (*MockOwner) ScheduleTable 

func (m *MockOwner) ScheduleTable(cfID model.ChangeFeedID, toCapture model.CaptureID, tableID model.TableID, done chan<- error)

ScheduleTable mocks base method.

func (*MockOwner) UpdateChangefeed 

func (m *MockOwner) UpdateChangefeed(ctx context.Context, changeFeedInfo *model.ChangeFeedInfo) error

UpdateChangefeed mocks base method.

func (*MockOwner) UpdateChangefeedAndUpstream 

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

UpdateChangefeedAndUpstream mocks base method.

func (*MockOwner) WriteDebugInfo 

func (m *MockOwner) WriteDebugInfo(w io.Writer, done chan<- error)

WriteDebugInfo mocks base method.

type MockOwnerMockRecorder 

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

MockOwnerMockRecorder is the mock recorder for MockOwner.

func (*MockOwnerMockRecorder) AsyncStop 

func (mr *MockOwnerMockRecorder) AsyncStop() *gomock.Call

AsyncStop indicates an expected call of AsyncStop.

func (*MockOwnerMockRecorder) CreateChangefeed 

func (mr *MockOwnerMockRecorder) CreateChangefeed(arg0, arg1, arg2 interface{}) *gomock.Call

CreateChangefeed indicates an expected call of CreateChangefeed.

func (*MockOwnerMockRecorder) DrainCapture 

func (mr *MockOwnerMockRecorder) DrainCapture(query, done interface{}) *gomock.Call

DrainCapture indicates an expected call of DrainCapture.

func (*MockOwnerMockRecorder) EnqueueJob 

func (mr *MockOwnerMockRecorder) EnqueueJob(adminJob, done interface{}) *gomock.Call

EnqueueJob indicates an expected call of EnqueueJob.

func (*MockOwnerMockRecorder) Query 

func (mr *MockOwnerMockRecorder) Query(query, done interface{}) *gomock.Call

Query indicates an expected call of Query.

func (*MockOwnerMockRecorder) RebalanceTables 

func (mr *MockOwnerMockRecorder) RebalanceTables(cfID, done interface{}) *gomock.Call

RebalanceTables indicates an expected call of RebalanceTables.

func (*MockOwnerMockRecorder) ScheduleTable 

func (mr *MockOwnerMockRecorder) ScheduleTable(cfID, toCapture, tableID, done interface{}) *gomock.Call

ScheduleTable indicates an expected call of ScheduleTable.

func (*MockOwnerMockRecorder) UpdateChangefeed 

func (mr *MockOwnerMockRecorder) UpdateChangefeed(ctx, changeFeedInfo interface{}) *gomock.Call

UpdateChangefeed indicates an expected call of UpdateChangefeed.

func (*MockOwnerMockRecorder) UpdateChangefeedAndUpstream 

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

UpdateChangefeedAndUpstream indicates an expected call of UpdateChangefeedAndUpstream.

func (*MockOwnerMockRecorder) WriteDebugInfo 

func (mr *MockOwnerMockRecorder) WriteDebugInfo(w, done interface{}) *gomock.Call

WriteDebugInfo indicates an expected call of WriteDebugInfo.

type MockStatusProvider 

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

MockStatusProvider is a mock of StatusProvider interface.

func NewMockStatusProvider 

func NewMockStatusProvider(ctrl *gomock.Controller) *MockStatusProvider

NewMockStatusProvider creates a new mock instance.

func (*MockStatusProvider) EXPECT 

func (m *MockStatusProvider) EXPECT() *MockStatusProviderMockRecorder

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

func (*MockStatusProvider) GetAllChangeFeedCheckpointTs 

func (m *MockStatusProvider) GetAllChangeFeedCheckpointTs(ctx context.Context) (map[model.ChangeFeedID]uint64, error)

GetAllChangeFeedCheckpointTs mocks base method.

func (*MockStatusProvider) GetAllChangeFeedInfo 

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

GetAllChangeFeedInfo mocks base method.

func (*MockStatusProvider) GetAllTaskStatuses 

func (m *MockStatusProvider) GetAllTaskStatuses(ctx context.Context, changefeedID model.ChangeFeedID) (map[model.CaptureID]*model.TaskStatus, error)

GetAllTaskStatuses mocks base method.

func (*MockStatusProvider) GetCaptures 

func (m *MockStatusProvider) GetCaptures(ctx context.Context) ([]*model.CaptureInfo, error)

GetCaptures mocks base method.

func (*MockStatusProvider) GetChangeFeedInfo 

func (m *MockStatusProvider) GetChangeFeedInfo(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedInfo, error)

GetChangeFeedInfo mocks base method.

func (*MockStatusProvider) GetChangeFeedStatus 

func (m *MockStatusProvider) GetChangeFeedStatus(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedStatusForAPI, error)

GetChangeFeedStatus mocks base method.

func (*MockStatusProvider) GetChangeFeedSyncedStatus 

func (m *MockStatusProvider) GetChangeFeedSyncedStatus(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedSyncedStatusForAPI, error)

GetChangeFeedSyncedStatus mocks base method.

func (*MockStatusProvider) GetProcessors 

func (m *MockStatusProvider) GetProcessors(ctx context.Context) ([]*model.ProcInfoSnap, error)

GetProcessors mocks base method.

func (*MockStatusProvider) IsChangefeedExists 

func (m *MockStatusProvider) IsChangefeedExists(ctx context.Context, id model.ChangeFeedID) (bool, error)

IsChangefeedExists mocks base method.

func (*MockStatusProvider) IsHealthy 

func (m *MockStatusProvider) IsHealthy(ctx context.Context) (bool, error)

IsHealthy mocks base method.

type MockStatusProviderMockRecorder 

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

MockStatusProviderMockRecorder is the mock recorder for MockStatusProvider.

func (*MockStatusProviderMockRecorder) GetAllChangeFeedCheckpointTs 

func (mr *MockStatusProviderMockRecorder) GetAllChangeFeedCheckpointTs(ctx interface{}) *gomock.Call

GetAllChangeFeedCheckpointTs indicates an expected call of GetAllChangeFeedCheckpointTs.

func (*MockStatusProviderMockRecorder) GetAllChangeFeedInfo 

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

GetAllChangeFeedInfo indicates an expected call of GetAllChangeFeedInfo.

func (*MockStatusProviderMockRecorder) GetAllTaskStatuses 

func (mr *MockStatusProviderMockRecorder) GetAllTaskStatuses(ctx, changefeedID interface{}) *gomock.Call

GetAllTaskStatuses indicates an expected call of GetAllTaskStatuses.

func (*MockStatusProviderMockRecorder) GetCaptures 

func (mr *MockStatusProviderMockRecorder) GetCaptures(ctx interface{}) *gomock.Call

GetCaptures indicates an expected call of GetCaptures.

func (*MockStatusProviderMockRecorder) GetChangeFeedInfo 

func (mr *MockStatusProviderMockRecorder) GetChangeFeedInfo(ctx, changefeedID interface{}) *gomock.Call

GetChangeFeedInfo indicates an expected call of GetChangeFeedInfo.

func (*MockStatusProviderMockRecorder) GetChangeFeedStatus 

func (mr *MockStatusProviderMockRecorder) GetChangeFeedStatus(ctx, changefeedID interface{}) *gomock.Call

GetChangeFeedStatus indicates an expected call of GetChangeFeedStatus.

func (*MockStatusProviderMockRecorder) GetChangeFeedSyncedStatus 

func (mr *MockStatusProviderMockRecorder) GetChangeFeedSyncedStatus(ctx, changefeedID interface{}) *gomock.Call

GetChangeFeedSyncedStatus indicates an expected call of GetChangeFeedSyncedStatus.

func (*MockStatusProviderMockRecorder) GetProcessors 

func (mr *MockStatusProviderMockRecorder) GetProcessors(ctx interface{}) *gomock.Call

GetProcessors indicates an expected call of GetProcessors.

func (*MockStatusProviderMockRecorder) IsChangefeedExists 

func (mr *MockStatusProviderMockRecorder) IsChangefeedExists(ctx, id interface{}) *gomock.Call

IsChangefeedExists indicates an expected call of IsChangefeedExists.

func (*MockStatusProviderMockRecorder) IsHealthy 

func (mr *MockStatusProviderMockRecorder) IsHealthy(ctx interface{}) *gomock.Call

IsHealthy indicates an expected call of IsHealthy.

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.