// Code generated by MockGen. DO NOT EDIT.
// Source: ./central/db/dbutil/cdc/interface.go

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

import (
	reflect "reflect"

	gomock "github.com/golang/mock/gomock"
	cdc "github.com/pingcap/dbaas/central/db/dbutil/cdc"
	entity "github.com/pingcap/dbaas/central/db/entity"
)

// MockCDCDaoFacade is a mock of CDCDaoFacade interface.
type MockCDCDaoFacade struct {
	ctrl     *gomock.Controller
	recorder *MockCDCDaoFacadeMockRecorder
}

// MockCDCDaoFacadeMockRecorder is the mock recorder for MockCDCDaoFacade.
type MockCDCDaoFacadeMockRecorder struct {
	mock *MockCDCDaoFacade
}

// NewMockCDCDaoFacade creates a new mock instance.
func NewMockCDCDaoFacade(ctrl *gomock.Controller) *MockCDCDaoFacade {
	mock := &MockCDCDaoFacade{ctrl: ctrl}
	mock.recorder = &MockCDCDaoFacadeMockRecorder{mock}
	return mock
}

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

// FindCDCTasks mocks base method.
func (m *MockCDCDaoFacade) FindCDCTasks(filter cdc.CdcFilter) ([]entity.CDCTask, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "FindCDCTasks", filter)
	ret0, _ := ret[0].([]entity.CDCTask)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// FindCDCTasks indicates an expected call of FindCDCTasks.
func (mr *MockCDCDaoFacadeMockRecorder) FindCDCTasks(filter interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FindCDCTasks", reflect.TypeOf((*MockCDCDaoFacade)(nil).FindCDCTasks), filter)
}

// GetCdcKafkaTask mocks base method.
func (m *MockCDCDaoFacade) GetCdcKafkaTask(taskID entity.ID) (*entity.CDCKafkaTask, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetCdcKafkaTask", taskID)
	ret0, _ := ret[0].(*entity.CDCKafkaTask)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetCdcKafkaTask indicates an expected call of GetCdcKafkaTask.
func (mr *MockCDCDaoFacadeMockRecorder) GetCdcKafkaTask(taskID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCdcKafkaTask", reflect.TypeOf((*MockCDCDaoFacade)(nil).GetCdcKafkaTask), taskID)
}

// GetCdcSqlTask mocks base method.
func (m *MockCDCDaoFacade) GetCdcSqlTask(taskID entity.ID) (*entity.CDCSQLTask, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetCdcSqlTask", taskID)
	ret0, _ := ret[0].(*entity.CDCSQLTask)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetCdcSqlTask indicates an expected call of GetCdcSqlTask.
func (mr *MockCDCDaoFacadeMockRecorder) GetCdcSqlTask(taskID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCdcSqlTask", reflect.TypeOf((*MockCDCDaoFacade)(nil).GetCdcSqlTask), taskID)
}

// GetCdcTaskByID mocks base method.
func (m *MockCDCDaoFacade) GetCdcTaskByID(taskID, clusterID, projectID entity.ID) (*entity.CDCTask, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetCdcTaskByID", taskID, clusterID, projectID)
	ret0, _ := ret[0].(*entity.CDCTask)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetCdcTaskByID indicates an expected call of GetCdcTaskByID.
func (mr *MockCDCDaoFacadeMockRecorder) GetCdcTaskByID(taskID, clusterID, projectID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetCdcTaskByID", reflect.TypeOf((*MockCDCDaoFacade)(nil).GetCdcTaskByID), taskID, clusterID, projectID)
}

// UpdateCdcTask mocks base method.
func (m *MockCDCDaoFacade) UpdateCdcTask(task entity.CDCTask, schemas []entity.CDCTaskDBSchemaField) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateCdcTask", task, schemas)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateCdcTask indicates an expected call of UpdateCdcTask.
func (mr *MockCDCDaoFacadeMockRecorder) UpdateCdcTask(task, schemas interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateCdcTask", reflect.TypeOf((*MockCDCDaoFacade)(nil).UpdateCdcTask), task, schemas)
}