// Code generated by MockGen. DO NOT EDIT.
// Source: ./internal/domain/service/cdc_worker.go
//
// Generated by this command:
//
//	mockgen -source=./internal/domain/service/cdc_worker.go -destination ./internal/domain/service/mock_service/mock_cdc_worker.go -package mock_service
//

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

import (
	context "context"
	reflect "reflect"

	gomock "go.uber.org/mock/gomock"
)

// MockCDCWorker is a mock of CDCWorker interface.
type MockCDCWorker struct {
	ctrl     *gomock.Controller
	recorder *MockCDCWorkerMockRecorder
}

// MockCDCWorkerMockRecorder is the mock recorder for MockCDCWorker.
type MockCDCWorkerMockRecorder struct {
	mock *MockCDCWorker
}

// NewMockCDCWorker creates a new mock instance.
func NewMockCDCWorker(ctrl *gomock.Controller) *MockCDCWorker {
	mock := &MockCDCWorker{ctrl: ctrl}
	mock.recorder = &MockCDCWorkerMockRecorder{mock}
	return mock
}

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

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

// CleanChangefeeds indicates an expected call of CleanChangefeeds.
func (mr *MockCDCWorkerMockRecorder) CleanChangefeeds(ctx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CleanChangefeeds", reflect.TypeOf((*MockCDCWorker)(nil).CleanChangefeeds), ctx)
}

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

// SyncChangefeeds indicates an expected call of SyncChangefeeds.
func (mr *MockCDCWorkerMockRecorder) SyncChangefeeds(ctx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncChangefeeds", reflect.TypeOf((*MockCDCWorker)(nil).SyncChangefeeds), ctx)
}

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

// SyncCreatingChangefeedsAndCDCCluster indicates an expected call of SyncCreatingChangefeedsAndCDCCluster.
func (mr *MockCDCWorkerMockRecorder) SyncCreatingChangefeedsAndCDCCluster(ctx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SyncCreatingChangefeedsAndCDCCluster", reflect.TypeOf((*MockCDCWorker)(nil).SyncCreatingChangefeedsAndCDCCluster), ctx)
}