// Code generated by MockGen. DO NOT EDIT.
// Source: pkg/clusterproxy/api/changefeed_api_v2.go

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

import (
	context "context"
	reflect "reflect"

	gomock "github.com/golang/mock/gomock"
	ticdc_servicev1 "github.com/tidbcloud/infra-provider/api/tidbcloud/ticdc-service/v1"
	api "github.com/tidbcloud/ticdc-service/pkg/clusterproxy/api"
)

// MockChangefeedClientGetter is a mock of ChangefeedClientGetter interface.
type MockChangefeedClientGetter struct {
	ctrl     *gomock.Controller
	recorder *MockChangefeedClientGetterMockRecorder
}

// MockChangefeedClientGetterMockRecorder is the mock recorder for MockChangefeedClientGetter.
type MockChangefeedClientGetterMockRecorder struct {
	mock *MockChangefeedClientGetter
}

// NewMockChangefeedClientGetter creates a new mock instance.
func NewMockChangefeedClientGetter(ctrl *gomock.Controller) *MockChangefeedClientGetter {
	mock := &MockChangefeedClientGetter{ctrl: ctrl}
	mock.recorder = &MockChangefeedClientGetterMockRecorder{mock}
	return mock
}

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

// ChangefeedClient mocks base method.
func (m *MockChangefeedClientGetter) ChangefeedClient() api.ChangefeedAPIV2 {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ChangefeedClient")
	ret0, _ := ret[0].(api.ChangefeedAPIV2)
	return ret0
}

// ChangefeedClient indicates an expected call of ChangefeedClient.
func (mr *MockChangefeedClientGetterMockRecorder) ChangefeedClient() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ChangefeedClient", reflect.TypeOf((*MockChangefeedClientGetter)(nil).ChangefeedClient))
}

// MockChangefeedAPIV2 is a mock of ChangefeedAPIV2 interface.
type MockChangefeedAPIV2 struct {
	ctrl     *gomock.Controller
	recorder *MockChangefeedAPIV2MockRecorder
}

// MockChangefeedAPIV2MockRecorder is the mock recorder for MockChangefeedAPIV2.
type MockChangefeedAPIV2MockRecorder struct {
	mock *MockChangefeedAPIV2
}

// NewMockChangefeedAPIV2 creates a new mock instance.
func NewMockChangefeedAPIV2(ctrl *gomock.Controller) *MockChangefeedAPIV2 {
	mock := &MockChangefeedAPIV2{ctrl: ctrl}
	mock.recorder = &MockChangefeedAPIV2MockRecorder{mock}
	return mock
}

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

// CreateChangefeedV2 mocks base method.
func (m *MockChangefeedAPIV2) CreateChangefeedV2(ctx context.Context, crName string, model *ticdc_servicev1.ChangefeedConfig) (*ticdc_servicev1.Changefeed, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CreateChangefeedV2", ctx, crName, model)
	ret0, _ := ret[0].(*ticdc_servicev1.Changefeed)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CreateChangefeedV2 indicates an expected call of CreateChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) CreateChangefeedV2(ctx, crName, model interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).CreateChangefeedV2), ctx, crName, model)
}

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

// DeleteChangefeedV2 indicates an expected call of DeleteChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) DeleteChangefeedV2(ctx, crName, taskID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).DeleteChangefeedV2), ctx, crName, taskID)
}

// GetChangefeedListV2 mocks base method.
func (m *MockChangefeedAPIV2) GetChangefeedListV2(ctx context.Context, crName string) (*ticdc_servicev1.ListChangefeedsResponse, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetChangefeedListV2", ctx, crName)
	ret0, _ := ret[0].(*ticdc_servicev1.ListChangefeedsResponse)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

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

// GetChangefeedV2 mocks base method.
func (m *MockChangefeedAPIV2) GetChangefeedV2(ctx context.Context, crName, taskID string) (*ticdc_servicev1.Changefeed, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetChangefeedV2", ctx, crName, taskID)
	ret0, _ := ret[0].(*ticdc_servicev1.Changefeed)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetChangefeedV2 indicates an expected call of GetChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) GetChangefeedV2(ctx, crName, taskID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).GetChangefeedV2), ctx, crName, taskID)
}

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

// PauseChangefeedV2 indicates an expected call of PauseChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) PauseChangefeedV2(ctx, crName, taskID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PauseChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).PauseChangefeedV2), ctx, crName, taskID)
}

// ResumeChangefeedV2 mocks base method.
func (m *MockChangefeedAPIV2) ResumeChangefeedV2(ctx context.Context, crName, taskID string, resumeConfig *ticdc_servicev1.ResumeChangefeedConfig) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ResumeChangefeedV2", ctx, crName, taskID, resumeConfig)
	ret0, _ := ret[0].(error)
	return ret0
}

// ResumeChangefeedV2 indicates an expected call of ResumeChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) ResumeChangefeedV2(ctx, crName, taskID, resumeConfig interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResumeChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).ResumeChangefeedV2), ctx, crName, taskID, resumeConfig)
}

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

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

// UpdateChangefeedV2 mocks base method.
func (m *MockChangefeedAPIV2) UpdateChangefeedV2(ctx context.Context, crName, taskID string, model *ticdc_servicev1.ChangefeedConfig) (*ticdc_servicev1.Changefeed, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateChangefeedV2", ctx, crName, taskID, model)
	ret0, _ := ret[0].(*ticdc_servicev1.Changefeed)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// UpdateChangefeedV2 indicates an expected call of UpdateChangefeedV2.
func (mr *MockChangefeedAPIV2MockRecorder) UpdateChangefeedV2(ctx, crName, taskID, model interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateChangefeedV2", reflect.TypeOf((*MockChangefeedAPIV2)(nil).UpdateChangefeedV2), ctx, crName, taskID, model)
}
