Documentation
¶
Overview ¶
Package mock_controller is a generated GoMock package.
Index ¶
- type MockController
- func (m *MockController) AsyncStop()
- func (m *MockController) CreateChangefeed(arg0 context.Context, arg1 *model.UpstreamInfo, arg2 *model.ChangeFeedInfo) error
- func (m *MockController) EXPECT() *MockControllerMockRecorder
- func (m *MockController) GetAllChangeFeedCheckpointTs(ctx context.Context) (map[model.ChangeFeedID]uint64, error)
- func (m *MockController) GetAllChangeFeedInfo(ctx context.Context) (map[model.ChangeFeedID]*model.ChangeFeedInfo, error)
- func (m *MockController) GetCaptures(ctx context.Context) ([]*model.CaptureInfo, error)
- func (m *MockController) GetChangefeedOwnerCaptureInfo(id model.ChangeFeedID) *model.CaptureInfo
- func (m *MockController) GetProcessors(ctx context.Context) ([]*model.ProcInfoSnap, error)
- func (m *MockController) IsChangefeedExists(ctx context.Context, id model.ChangeFeedID) (bool, error)
- type MockControllerMockRecorder
- func (mr *MockControllerMockRecorder) AsyncStop() *gomock.Call
- func (mr *MockControllerMockRecorder) CreateChangefeed(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetAllChangeFeedCheckpointTs(ctx interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetAllChangeFeedInfo(ctx interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetCaptures(ctx interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetChangefeedOwnerCaptureInfo(id interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) GetProcessors(ctx interface{}) *gomock.Call
- func (mr *MockControllerMockRecorder) IsChangefeedExists(ctx, id interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockController ¶
type MockController struct {
// contains filtered or unexported fields
}
MockController is a mock of Controller interface.
func NewMockController ¶
func NewMockController(ctrl *gomock.Controller) *MockController
NewMockController creates a new mock instance.
func (*MockController) AsyncStop ¶
func (m *MockController) AsyncStop()
AsyncStop mocks base method.
func (*MockController) CreateChangefeed ¶
func (m *MockController) CreateChangefeed(arg0 context.Context, arg1 *model.UpstreamInfo, arg2 *model.ChangeFeedInfo) error
CreateChangefeed mocks base method.
func (*MockController) EXPECT ¶
func (m *MockController) EXPECT() *MockControllerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockController) GetAllChangeFeedCheckpointTs ¶
func (m *MockController) GetAllChangeFeedCheckpointTs(ctx context.Context) (map[model.ChangeFeedID]uint64, error)
GetAllChangeFeedCheckpointTs mocks base method.
func (*MockController) GetAllChangeFeedInfo ¶
func (m *MockController) GetAllChangeFeedInfo(ctx context.Context) (map[model.ChangeFeedID]*model.ChangeFeedInfo, error)
GetAllChangeFeedInfo mocks base method.
func (*MockController) GetCaptures ¶
func (m *MockController) GetCaptures(ctx context.Context) ([]*model.CaptureInfo, error)
GetCaptures mocks base method.
func (*MockController) GetChangefeedOwnerCaptureInfo ¶
func (m *MockController) GetChangefeedOwnerCaptureInfo(id model.ChangeFeedID) *model.CaptureInfo
GetChangefeedOwnerCaptureInfo mocks base method.
func (*MockController) GetProcessors ¶
func (m *MockController) GetProcessors(ctx context.Context) ([]*model.ProcInfoSnap, error)
GetProcessors mocks base method.
func (*MockController) IsChangefeedExists ¶
func (m *MockController) IsChangefeedExists(ctx context.Context, id model.ChangeFeedID) (bool, error)
IsChangefeedExists mocks base method.
type MockControllerMockRecorder ¶
type MockControllerMockRecorder struct {
// contains filtered or unexported fields
}
MockControllerMockRecorder is the mock recorder for MockController.
func (*MockControllerMockRecorder) AsyncStop ¶
func (mr *MockControllerMockRecorder) AsyncStop() *gomock.Call
AsyncStop indicates an expected call of AsyncStop.
func (*MockControllerMockRecorder) CreateChangefeed ¶
func (mr *MockControllerMockRecorder) CreateChangefeed(arg0, arg1, arg2 interface{}) *gomock.Call
CreateChangefeed indicates an expected call of CreateChangefeed.
func (*MockControllerMockRecorder) GetAllChangeFeedCheckpointTs ¶
func (mr *MockControllerMockRecorder) GetAllChangeFeedCheckpointTs(ctx interface{}) *gomock.Call
GetAllChangeFeedCheckpointTs indicates an expected call of GetAllChangeFeedCheckpointTs.
func (*MockControllerMockRecorder) GetAllChangeFeedInfo ¶
func (mr *MockControllerMockRecorder) GetAllChangeFeedInfo(ctx interface{}) *gomock.Call
GetAllChangeFeedInfo indicates an expected call of GetAllChangeFeedInfo.
func (*MockControllerMockRecorder) GetCaptures ¶
func (mr *MockControllerMockRecorder) GetCaptures(ctx interface{}) *gomock.Call
GetCaptures indicates an expected call of GetCaptures.
func (*MockControllerMockRecorder) GetChangefeedOwnerCaptureInfo ¶
func (mr *MockControllerMockRecorder) GetChangefeedOwnerCaptureInfo(id interface{}) *gomock.Call
GetChangefeedOwnerCaptureInfo indicates an expected call of GetChangefeedOwnerCaptureInfo.
func (*MockControllerMockRecorder) GetProcessors ¶
func (mr *MockControllerMockRecorder) GetProcessors(ctx interface{}) *gomock.Call
GetProcessors indicates an expected call of GetProcessors.
func (*MockControllerMockRecorder) IsChangefeedExists ¶
func (mr *MockControllerMockRecorder) IsChangefeedExists(ctx, id interface{}) *gomock.Call
IsChangefeedExists indicates an expected call of IsChangefeedExists.
Source Files