mock_owner

package

v0.0.0-...-be15534 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap/tiflow

Links

Open Source Insights

Documentation ¶

Overview ¶

Package mock_owner is a generated GoMock package.

Index ¶

type MockOwner
- func NewMockOwner(ctrl *gomock.Controller) *MockOwner
type MockOwnerMockRecorder
type MockStatusProvider
- func NewMockStatusProvider(ctrl *gomock.Controller) *MockStatusProvider
type MockStatusProviderMockRecorder

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) 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) 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) 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) IsChangefeedOwner ¶

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

IsChangefeedOwner 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) 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) IsChangefeedOwner ¶

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

IsChangefeedOwner indicates an expected call of IsChangefeedOwner.

func (*MockStatusProviderMockRecorder) IsHealthy ¶

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

IsHealthy indicates an expected call of IsHealthy.

Source Files ¶

View all Source files

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