// Code generated by MockGen. DO NOT EDIT.
// Source: cdc/owner/status_provider.go

// Package mock_owner is a generated GoMock package.
package mock_owner

import (
	context "context"
	reflect "reflect"

	gomock "github.com/golang/mock/gomock"
	model "github.com/pingcap/tiflow/cdc/model"
)

// MockStatusProvider is a mock of StatusProvider interface.
type MockStatusProvider struct {
	ctrl     *gomock.Controller
	recorder *MockStatusProviderMockRecorder
}

// MockStatusProviderMockRecorder is the mock recorder for MockStatusProvider.
type MockStatusProviderMockRecorder struct {
	mock *MockStatusProvider
}

// NewMockStatusProvider creates a new mock instance.
func NewMockStatusProvider(ctrl *gomock.Controller) *MockStatusProvider {
	mock := &MockStatusProvider{ctrl: ctrl}
	mock.recorder = &MockStatusProviderMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockStatusProvider) EXPECT() *MockStatusProviderMockRecorder {
	return m.recorder
}

// GetAllChangeFeedCheckpointTs mocks base method.
func (m *MockStatusProvider) GetAllChangeFeedCheckpointTs(ctx context.Context) (map[model.ChangeFeedID]uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllChangeFeedCheckpointTs", ctx)
	ret0, _ := ret[0].(map[model.ChangeFeedID]uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllChangeFeedCheckpointTs indicates an expected call of GetAllChangeFeedCheckpointTs.
func (mr *MockStatusProviderMockRecorder) GetAllChangeFeedCheckpointTs(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllChangeFeedCheckpointTs", reflect.TypeOf((*MockStatusProvider)(nil).GetAllChangeFeedCheckpointTs), ctx)
}

// GetAllChangeFeedInfo mocks base method.
func (m *MockStatusProvider) GetAllChangeFeedInfo(ctx context.Context) (map[model.ChangeFeedID]*model.ChangeFeedInfo, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllChangeFeedInfo", ctx)
	ret0, _ := ret[0].(map[model.ChangeFeedID]*model.ChangeFeedInfo)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllChangeFeedInfo indicates an expected call of GetAllChangeFeedInfo.
func (mr *MockStatusProviderMockRecorder) GetAllChangeFeedInfo(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllChangeFeedInfo", reflect.TypeOf((*MockStatusProvider)(nil).GetAllChangeFeedInfo), ctx)
}

// GetAllTaskStatuses mocks base method.
func (m *MockStatusProvider) GetAllTaskStatuses(ctx context.Context, changefeedID model.ChangeFeedID) (map[model.CaptureID]*model.TaskStatus, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllTaskStatuses", ctx, changefeedID)
	ret0, _ := ret[0].(map[model.CaptureID]*model.TaskStatus)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllTaskStatuses indicates an expected call of GetAllTaskStatuses.
func (mr *MockStatusProviderMockRecorder) GetAllTaskStatuses(ctx, changefeedID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllTaskStatuses", reflect.TypeOf((*MockStatusProvider)(nil).GetAllTaskStatuses), ctx, changefeedID)
}

// GetCaptures mocks base method.
func (m *MockStatusProvider) GetCaptures(ctx context.Context) ([]*model.CaptureInfo, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetCaptures", ctx)
	ret0, _ := ret[0].([]*model.CaptureInfo)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetCaptures indicates an expected call of GetCaptures.
func (mr *MockStatusProviderMockRecorder) GetCaptures(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCaptures", reflect.TypeOf((*MockStatusProvider)(nil).GetCaptures), ctx)
}

// GetChangeFeedInfo mocks base method.
func (m *MockStatusProvider) GetChangeFeedInfo(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedInfo, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetChangeFeedInfo", ctx, changefeedID)
	ret0, _ := ret[0].(*model.ChangeFeedInfo)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetChangeFeedInfo indicates an expected call of GetChangeFeedInfo.
func (mr *MockStatusProviderMockRecorder) GetChangeFeedInfo(ctx, changefeedID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChangeFeedInfo", reflect.TypeOf((*MockStatusProvider)(nil).GetChangeFeedInfo), ctx, changefeedID)
}

// GetChangeFeedStatus mocks base method.
func (m *MockStatusProvider) GetChangeFeedStatus(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedStatusForAPI, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetChangeFeedStatus", ctx, changefeedID)
	ret0, _ := ret[0].(*model.ChangeFeedStatusForAPI)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetChangeFeedStatus indicates an expected call of GetChangeFeedStatus.
func (mr *MockStatusProviderMockRecorder) GetChangeFeedStatus(ctx, changefeedID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChangeFeedStatus", reflect.TypeOf((*MockStatusProvider)(nil).GetChangeFeedStatus), ctx, changefeedID)
}

// GetChangeFeedSyncedStatus mocks base method.
func (m *MockStatusProvider) GetChangeFeedSyncedStatus(ctx context.Context, changefeedID model.ChangeFeedID) (*model.ChangeFeedSyncedStatusForAPI, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetChangeFeedSyncedStatus", ctx, changefeedID)
	ret0, _ := ret[0].(*model.ChangeFeedSyncedStatusForAPI)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetChangeFeedSyncedStatus indicates an expected call of GetChangeFeedSyncedStatus.
func (mr *MockStatusProviderMockRecorder) GetChangeFeedSyncedStatus(ctx, changefeedID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChangeFeedSyncedStatus", reflect.TypeOf((*MockStatusProvider)(nil).GetChangeFeedSyncedStatus), ctx, changefeedID)
}

// GetProcessors mocks base method.
func (m *MockStatusProvider) GetProcessors(ctx context.Context) ([]*model.ProcInfoSnap, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetProcessors", ctx)
	ret0, _ := ret[0].([]*model.ProcInfoSnap)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetProcessors indicates an expected call of GetProcessors.
func (mr *MockStatusProviderMockRecorder) GetProcessors(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetProcessors", reflect.TypeOf((*MockStatusProvider)(nil).GetProcessors), ctx)
}

// IsChangefeedExists mocks base method.
func (m *MockStatusProvider) IsChangefeedExists(ctx context.Context, id model.ChangeFeedID) (bool, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "IsChangefeedExists", ctx, id)
	ret0, _ := ret[0].(bool)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// IsChangefeedExists indicates an expected call of IsChangefeedExists.
func (mr *MockStatusProviderMockRecorder) IsChangefeedExists(ctx, id interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "IsChangefeedExists", reflect.TypeOf((*MockStatusProvider)(nil).IsChangefeedExists), ctx, id)
}

// IsHealthy mocks base method.
func (m *MockStatusProvider) IsHealthy(ctx context.Context) (bool, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "IsHealthy", ctx)
	ret0, _ := ret[0].(bool)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// IsHealthy indicates an expected call of IsHealthy.
func (mr *MockStatusProviderMockRecorder) IsHealthy(ctx interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "IsHealthy", reflect.TypeOf((*MockStatusProvider)(nil).IsHealthy), ctx)
}