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

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

import (
	context "context"
	reflect "reflect"

	gomock "github.com/golang/mock/gomock"
	clusterproxy "github.com/tidbcloud/ticdc-service/pkg/clusterproxy"
	api "github.com/tidbcloud/ticdc-service/pkg/clusterproxy/api"
	client "github.com/tidbcloud/ticdc-service/pkg/clusterproxy/client"
)

// MockClusterProxy is a mock of ClusterProxy interface.
type MockClusterProxy struct {
	ctrl     *gomock.Controller
	recorder *MockClusterProxyMockRecorder
}

// MockClusterProxyMockRecorder is the mock recorder for MockClusterProxy.
type MockClusterProxyMockRecorder struct {
	mock *MockClusterProxy
}

// NewMockClusterProxy creates a new mock instance.
func NewMockClusterProxy(ctrl *gomock.Controller) *MockClusterProxy {
	mock := &MockClusterProxy{ctrl: ctrl}
	mock.recorder = &MockClusterProxyMockRecorder{mock}
	return mock
}

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

// ChangefeedClient mocks base method.
func (m *MockClusterProxy) 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 *MockClusterProxyMockRecorder) ChangefeedClient() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ChangefeedClient", reflect.TypeOf((*MockClusterProxy)(nil).ChangefeedClient))
}

// Client mocks base method.
func (m *MockClusterProxy) Client() client.Client {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "Client")
	ret0, _ := ret[0].(client.Client)
	return ret0
}

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

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

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

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

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

// MockModel is a mock of Model interface.
type MockModel struct {
	ctrl     *gomock.Controller
	recorder *MockModelMockRecorder
}

// MockModelMockRecorder is the mock recorder for MockModel.
type MockModelMockRecorder struct {
	mock *MockModel
}

// NewMockModel creates a new mock instance.
func NewMockModel(ctrl *gomock.Controller) *MockModel {
	mock := &MockModel{ctrl: ctrl}
	mock.recorder = &MockModelMockRecorder{mock}
	return mock
}

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

// GetClusterProxy mocks base method.
func (m *MockModel) GetClusterProxy(ctx context.Context, clusterId string, timeout int) (clusterproxy.ClusterProxy, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetClusterProxy", ctx, clusterId, timeout)
	ret0, _ := ret[0].(clusterproxy.ClusterProxy)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetClusterProxy indicates an expected call of GetClusterProxy.
func (mr *MockModelMockRecorder) GetClusterProxy(ctx, clusterId, timeout interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterProxy", reflect.TypeOf((*MockModel)(nil).GetClusterProxy), ctx, clusterId, timeout)
}