// Code generated by MockGen. DO NOT EDIT.
// Source: ./internal/domain/repo/cdc.go
//
// Generated by this command:
//
//	mockgen -source=./internal/domain/repo/cdc.go -destination ./internal/domain/repo/mock_repo/mock_cdc.go -package mock_repo
//

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

import (
	context "context"
	reflect "reflect"

	bizerr "github.com/tidbcloud/pkgv2/bizerr"
	constant "github.com/tidbcloud/serverless-service/internal/domain/constant"
	entity "github.com/tidbcloud/serverless-service/internal/domain/entity"
	gomock "go.uber.org/mock/gomock"
)

// MockChangefeedRepo is a mock of ChangefeedRepo interface.
type MockChangefeedRepo struct {
	ctrl     *gomock.Controller
	recorder *MockChangefeedRepoMockRecorder
	isgomock struct{}
}

// MockChangefeedRepoMockRecorder is the mock recorder for MockChangefeedRepo.
type MockChangefeedRepoMockRecorder struct {
	mock *MockChangefeedRepo
}

// NewMockChangefeedRepo creates a new mock instance.
func NewMockChangefeedRepo(ctrl *gomock.Controller) *MockChangefeedRepo {
	mock := &MockChangefeedRepo{ctrl: ctrl}
	mock.recorder = &MockChangefeedRepoMockRecorder{mock}
	return mock
}

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

// ChangeStateFromCreating mocks base method.
func (m *MockChangefeedRepo) ChangeStateFromCreating(ctx context.Context, cdc *entity.CDCChangefeed) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ChangeStateFromCreating", ctx, cdc)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

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

// CleanByRetention mocks base method.
func (m *MockChangefeedRepo) CleanByRetention(ctx context.Context, retentionDays int) (int64, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CleanByRetention", ctx, retentionDays)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// CountByFilter mocks base method.
func (m *MockChangefeedRepo) CountByFilter(ctx context.Context, filter entity.ListChangefeedsFilter) (int64, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CountByFilter", ctx, filter)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// Create mocks base method.
func (m *MockChangefeedRepo) Create(ctx context.Context, cdc *entity.CDCChangefeed) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Create", ctx, cdc)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// Delete mocks base method.
func (m *MockChangefeedRepo) Delete(ctx context.Context, clusterId, changefeedId string) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Delete", ctx, clusterId, changefeedId)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

// Delete indicates an expected call of Delete.
func (mr *MockChangefeedRepoMockRecorder) Delete(ctx, clusterId, changefeedId any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockChangefeedRepo)(nil).Delete), ctx, clusterId, changefeedId)
}

// GetByID mocks base method.
func (m *MockChangefeedRepo) GetByID(ctx context.Context, changefeedID string) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetByID", ctx, changefeedID)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// GetById mocks base method.
func (m *MockChangefeedRepo) GetById(ctx context.Context, clusterId, changefeedId string) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetById", ctx, clusterId, changefeedId)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

// GetById indicates an expected call of GetById.
func (mr *MockChangefeedRepoMockRecorder) GetById(ctx, clusterId, changefeedId any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetById", reflect.TypeOf((*MockChangefeedRepo)(nil).GetById), ctx, clusterId, changefeedId)
}

// GroupByClusterId mocks base method.
func (m *MockChangefeedRepo) GroupByClusterId(ctx context.Context) ([]*entity.ChangefeedCountByCluster, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GroupByClusterId", ctx)
	ret0, _ := ret[0].([]*entity.ChangefeedCountByCluster)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// GroupByState mocks base method.
func (m *MockChangefeedRepo) GroupByState(ctx context.Context) ([]*entity.ChangefeedStateCount, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GroupByState", ctx)
	ret0, _ := ret[0].([]*entity.ChangefeedStateCount)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// ListByFilter mocks base method.
func (m *MockChangefeedRepo) ListByFilter(ctx context.Context, filter entity.ListChangefeedsFilter) ([]*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListByFilter", ctx, filter)
	ret0, _ := ret[0].([]*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// Save mocks base method.
func (m *MockChangefeedRepo) Save(ctx context.Context, cdc *entity.CDCChangefeed) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Save", ctx, cdc)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// Start mocks base method.
func (m *MockChangefeedRepo) Start(ctx context.Context, clusterId, changefeedId string) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Start", ctx, clusterId, changefeedId)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

// Start indicates an expected call of Start.
func (mr *MockChangefeedRepoMockRecorder) Start(ctx, clusterId, changefeedId any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Start", reflect.TypeOf((*MockChangefeedRepo)(nil).Start), ctx, clusterId, changefeedId)
}

// Stop mocks base method.
func (m *MockChangefeedRepo) Stop(ctx context.Context, clusterId, changefeedId string) (*entity.CDCChangefeed, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Stop", ctx, clusterId, changefeedId)
	ret0, _ := ret[0].(*entity.CDCChangefeed)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

// Stop indicates an expected call of Stop.
func (mr *MockChangefeedRepoMockRecorder) Stop(ctx, clusterId, changefeedId any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Stop", reflect.TypeOf((*MockChangefeedRepo)(nil).Stop), ctx, clusterId, changefeedId)
}

// SyncState mocks base method.
func (m *MockChangefeedRepo) SyncState(ctx context.Context, changefeed *entity.CDCChangefeed) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SyncState", ctx, changefeed)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

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

// MockCDCClusterRepo is a mock of CDCClusterRepo interface.
type MockCDCClusterRepo struct {
	ctrl     *gomock.Controller
	recorder *MockCDCClusterRepoMockRecorder
	isgomock struct{}
}

// MockCDCClusterRepoMockRecorder is the mock recorder for MockCDCClusterRepo.
type MockCDCClusterRepoMockRecorder struct {
	mock *MockCDCClusterRepo
}

// NewMockCDCClusterRepo creates a new mock instance.
func NewMockCDCClusterRepo(ctrl *gomock.Controller) *MockCDCClusterRepo {
	mock := &MockCDCClusterRepo{ctrl: ctrl}
	mock.recorder = &MockCDCClusterRepoMockRecorder{mock}
	return mock
}

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

// CleanByRetention mocks base method.
func (m *MockCDCClusterRepo) CleanByRetention(ctx context.Context, retentionDays int) (int64, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CleanByRetention", ctx, retentionDays)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// Create mocks base method.
func (m *MockCDCClusterRepo) Create(ctx context.Context, cluster *entity.CDCCluster) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Create", ctx, cluster)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

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

// DecreaseChangefeed mocks base method.
func (m *MockCDCClusterRepo) DecreaseChangefeed(ctx context.Context, clusterId string) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DecreaseChangefeed", ctx, clusterId)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

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

// Delete mocks base method.
func (m *MockCDCClusterRepo) Delete(ctx context.Context, clusterId string) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Delete", ctx, clusterId)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

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

// GetById mocks base method.
func (m *MockCDCClusterRepo) GetById(ctx context.Context, clusterId string) (*entity.CDCCluster, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetById", ctx, clusterId)
	ret0, _ := ret[0].(*entity.CDCCluster)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// IncreaseOrCreateChangefeed mocks base method.
func (m *MockCDCClusterRepo) IncreaseOrCreateChangefeed(ctx context.Context, changefeed *entity.CDCChangefeed) (int64, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "IncreaseOrCreateChangefeed", ctx, changefeed)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// ListCDCWithoutChangefeed mocks base method.
func (m *MockCDCClusterRepo) ListCDCWithoutChangefeed(ctx context.Context) ([]*entity.CDCCluster, bizerr.BizError) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListCDCWithoutChangefeed", ctx)
	ret0, _ := ret[0].([]*entity.CDCCluster)
	ret1, _ := ret[1].(bizerr.BizError)
	return ret0, ret1
}

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

// SetClusterStatusId mocks base method.
func (m *MockCDCClusterRepo) SetClusterStatusId(ctx context.Context, clusterId string, statusId uint64) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetClusterStatusId", ctx, clusterId, statusId)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

// SetClusterStatusId indicates an expected call of SetClusterStatusId.
func (mr *MockCDCClusterRepoMockRecorder) SetClusterStatusId(ctx, clusterId, statusId any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetClusterStatusId", reflect.TypeOf((*MockCDCClusterRepo)(nil).SetClusterStatusId), ctx, clusterId, statusId)
}

// UpdateState mocks base method.
func (m *MockCDCClusterRepo) UpdateState(ctx context.Context, clusterId string, status constant.CDCClusterState) bizerr.BizError {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateState", ctx, clusterId, status)
	ret0, _ := ret[0].(bizerr.BizError)
	return ret0
}

// UpdateState indicates an expected call of UpdateState.
func (mr *MockCDCClusterRepoMockRecorder) UpdateState(ctx, clusterId, status any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateState", reflect.TypeOf((*MockCDCClusterRepo)(nil).UpdateState), ctx, clusterId, status)
}