// Code generated by MockGen. DO NOT EDIT.
// Source: github.com/tidbcloud/dataflow-service/idl/pbgen/proto/dataflow (interfaces: ConnectorServiceClient)
//
// Generated by this command:
//
//	mockgen -destination connector_client_mock.go -package=dataflowcli github.com/tidbcloud/dataflow-service/idl/pbgen/proto/dataflow ConnectorServiceClient
//

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

import (
	context "context"
	reflect "reflect"

	dataflow "github.com/tidbcloud/dataflow-service/idl/pbgen/proto/dataflow"
	gomock "go.uber.org/mock/gomock"
	grpc "google.golang.org/grpc"
	emptypb "google.golang.org/protobuf/types/known/emptypb"
	structpb "google.golang.org/protobuf/types/known/structpb"
)

// MockConnectorServiceClient is a mock of ConnectorServiceClient interface.
type MockConnectorServiceClient struct {
	ctrl     *gomock.Controller
	recorder *MockConnectorServiceClientMockRecorder
	isgomock struct{}
}

// MockConnectorServiceClientMockRecorder is the mock recorder for MockConnectorServiceClient.
type MockConnectorServiceClientMockRecorder struct {
	mock *MockConnectorServiceClient
}

// NewMockConnectorServiceClient creates a new mock instance.
func NewMockConnectorServiceClient(ctrl *gomock.Controller) *MockConnectorServiceClient {
	mock := &MockConnectorServiceClient{ctrl: ctrl}
	mock.recorder = &MockConnectorServiceClientMockRecorder{mock}
	return mock
}

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

// CalChangefeedFee mocks base method.
func (m *MockConnectorServiceClient) CalChangefeedFee(ctx context.Context, in *dataflow.CalChangefeedFeeReq, opts ...grpc.CallOption) (*dataflow.CalChangefeedFeeResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "CalChangefeedFee", varargs...)
	ret0, _ := ret[0].(*dataflow.CalChangefeedFeeResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CalChangefeedFee indicates an expected call of CalChangefeedFee.
func (mr *MockConnectorServiceClientMockRecorder) CalChangefeedFee(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CalChangefeedFee", reflect.TypeOf((*MockConnectorServiceClient)(nil).CalChangefeedFee), varargs...)
}

// CreateConnector mocks base method.
func (m *MockConnectorServiceClient) CreateConnector(ctx context.Context, in *dataflow.ConnectorCreateReq, opts ...grpc.CallOption) (*dataflow.ConnectorID, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "CreateConnector", varargs...)
	ret0, _ := ret[0].(*dataflow.ConnectorID)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CreateConnector indicates an expected call of CreateConnector.
func (mr *MockConnectorServiceClientMockRecorder) CreateConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).CreateConnector), varargs...)
}

// CreatePrivateLink mocks base method.
func (m *MockConnectorServiceClient) CreatePrivateLink(ctx context.Context, in *dataflow.CreateChangefeedPrivateLinkReq, opts ...grpc.CallOption) (*dataflow.CreateChangefeedPrivateLinkResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "CreatePrivateLink", varargs...)
	ret0, _ := ret[0].(*dataflow.CreateChangefeedPrivateLinkResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CreatePrivateLink indicates an expected call of CreatePrivateLink.
func (mr *MockConnectorServiceClientMockRecorder) CreatePrivateLink(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreatePrivateLink", reflect.TypeOf((*MockConnectorServiceClient)(nil).CreatePrivateLink), varargs...)
}

// DeleteConnector mocks base method.
func (m *MockConnectorServiceClient) DeleteConnector(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "DeleteConnector", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DeleteConnector indicates an expected call of DeleteConnector.
func (mr *MockConnectorServiceClientMockRecorder) DeleteConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).DeleteConnector), varargs...)
}

// DescribeAdminProfile mocks base method.
func (m *MockConnectorServiceClient) DescribeAdminProfile(ctx context.Context, in *dataflow.ClusterIdReq, opts ...grpc.CallOption) (*dataflow.AdminProfileResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "DescribeAdminProfile", varargs...)
	ret0, _ := ret[0].(*dataflow.AdminProfileResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DescribeAdminProfile indicates an expected call of DescribeAdminProfile.
func (mr *MockConnectorServiceClientMockRecorder) DescribeAdminProfile(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeAdminProfile", reflect.TypeOf((*MockConnectorServiceClient)(nil).DescribeAdminProfile), varargs...)
}

// DescribeSchemaTable mocks base method.
func (m *MockConnectorServiceClient) DescribeSchemaTable(ctx context.Context, in *dataflow.DescribeSchemaTableReq, opts ...grpc.CallOption) (*dataflow.DescribeSchemaTableResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "DescribeSchemaTable", varargs...)
	ret0, _ := ret[0].(*dataflow.DescribeSchemaTableResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DescribeSchemaTable indicates an expected call of DescribeSchemaTable.
func (mr *MockConnectorServiceClientMockRecorder) DescribeSchemaTable(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DescribeSchemaTable", reflect.TypeOf((*MockConnectorServiceClient)(nil).DescribeSchemaTable), varargs...)
}

// EditConnector mocks base method.
func (m *MockConnectorServiceClient) EditConnector(ctx context.Context, in *dataflow.ConnectorEditReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "EditConnector", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// EditConnector indicates an expected call of EditConnector.
func (mr *MockConnectorServiceClientMockRecorder) EditConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "EditConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).EditConnector), varargs...)
}

// GeneratePrivateLinkAdvertisedPatternGroup mocks base method.
func (m *MockConnectorServiceClient) GeneratePrivateLinkAdvertisedPatternGroup(ctx context.Context, in *dataflow.GenerateAdvertisedPatternReq, opts ...grpc.CallOption) (*dataflow.GenerateAdvertisedPatternResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GeneratePrivateLinkAdvertisedPatternGroup", varargs...)
	ret0, _ := ret[0].(*dataflow.GenerateAdvertisedPatternResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GeneratePrivateLinkAdvertisedPatternGroup indicates an expected call of GeneratePrivateLinkAdvertisedPatternGroup.
func (mr *MockConnectorServiceClientMockRecorder) GeneratePrivateLinkAdvertisedPatternGroup(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GeneratePrivateLinkAdvertisedPatternGroup", reflect.TypeOf((*MockConnectorServiceClient)(nil).GeneratePrivateLinkAdvertisedPatternGroup), varargs...)
}

// GetChangefeedDetail mocks base method.
func (m *MockConnectorServiceClient) GetChangefeedDetail(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*structpb.Struct, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetChangefeedDetail", varargs...)
	ret0, _ := ret[0].(*structpb.Struct)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetChangefeedDetail indicates an expected call of GetChangefeedDetail.
func (mr *MockConnectorServiceClientMockRecorder) GetChangefeedDetail(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetChangefeedDetail", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetChangefeedDetail), varargs...)
}

// GetClusterTCU mocks base method.
func (m *MockConnectorServiceClient) GetClusterTCU(ctx context.Context, in *dataflow.GetClusterTCUReq, opts ...grpc.CallOption) (*dataflow.GetClusterTCUResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetClusterTCU", varargs...)
	ret0, _ := ret[0].(*dataflow.GetClusterTCUResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetClusterTCU indicates an expected call of GetClusterTCU.
func (mr *MockConnectorServiceClientMockRecorder) GetClusterTCU(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterTCU", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetClusterTCU), varargs...)
}

// GetClusterTCUForAdmin mocks base method.
func (m *MockConnectorServiceClient) GetClusterTCUForAdmin(ctx context.Context, in *dataflow.GetClusterTCUReq, opts ...grpc.CallOption) (*dataflow.GetClusterTCUResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetClusterTCUForAdmin", varargs...)
	ret0, _ := ret[0].(*dataflow.GetClusterTCUResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetClusterTCUForAdmin indicates an expected call of GetClusterTCUForAdmin.
func (mr *MockConnectorServiceClientMockRecorder) GetClusterTCUForAdmin(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetClusterTCUForAdmin", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetClusterTCUForAdmin), varargs...)
}

// GetConnector mocks base method.
func (m *MockConnectorServiceClient) GetConnector(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*dataflow.Connector, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetConnector", varargs...)
	ret0, _ := ret[0].(*dataflow.Connector)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetConnector indicates an expected call of GetConnector.
func (mr *MockConnectorServiceClientMockRecorder) GetConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetConnector), varargs...)
}

// GetPrivateLink mocks base method.
func (m *MockConnectorServiceClient) GetPrivateLink(ctx context.Context, in *dataflow.GetChangefeedPrivateLinkReq, opts ...grpc.CallOption) (*dataflow.GetChangefeedPrivateLinkResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetPrivateLink", varargs...)
	ret0, _ := ret[0].(*dataflow.GetChangefeedPrivateLinkResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetPrivateLink indicates an expected call of GetPrivateLink.
func (mr *MockConnectorServiceClientMockRecorder) GetPrivateLink(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetPrivateLink", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetPrivateLink), varargs...)
}

// GetPrivateLinkAuthInfo mocks base method.
func (m *MockConnectorServiceClient) GetPrivateLinkAuthInfo(ctx context.Context, in *dataflow.GetPrivateLinkAuthInfoReq, opts ...grpc.CallOption) (*dataflow.GetPrivateLinkAuthInfoResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetPrivateLinkAuthInfo", varargs...)
	ret0, _ := ret[0].(*dataflow.GetPrivateLinkAuthInfoResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetPrivateLinkAuthInfo indicates an expected call of GetPrivateLinkAuthInfo.
func (mr *MockConnectorServiceClientMockRecorder) GetPrivateLinkAuthInfo(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetPrivateLinkAuthInfo", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetPrivateLinkAuthInfo), varargs...)
}

// GetPrivateLinkAvailableZones mocks base method.
func (m *MockConnectorServiceClient) GetPrivateLinkAvailableZones(ctx context.Context, in *dataflow.GetPrivateLinkAvailableZoneReq, opts ...grpc.CallOption) (*dataflow.GetPrivateLinkAvailableZoneResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetPrivateLinkAvailableZones", varargs...)
	ret0, _ := ret[0].(*dataflow.GetPrivateLinkAvailableZoneResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetPrivateLinkAvailableZones indicates an expected call of GetPrivateLinkAvailableZones.
func (mr *MockConnectorServiceClientMockRecorder) GetPrivateLinkAvailableZones(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetPrivateLinkAvailableZones", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetPrivateLinkAvailableZones), varargs...)
}

// GetTiCDCCluster mocks base method.
func (m *MockConnectorServiceClient) GetTiCDCCluster(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*structpb.Struct, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "GetTiCDCCluster", varargs...)
	ret0, _ := ret[0].(*structpb.Struct)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetTiCDCCluster indicates an expected call of GetTiCDCCluster.
func (mr *MockConnectorServiceClientMockRecorder) GetTiCDCCluster(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetTiCDCCluster", reflect.TypeOf((*MockConnectorServiceClient)(nil).GetTiCDCCluster), varargs...)
}

// ListConnectorEnabledFeatures mocks base method.
func (m *MockConnectorServiceClient) ListConnectorEnabledFeatures(ctx context.Context, in *dataflow.ListConnectorEnabledFeaturesReq, opts ...grpc.CallOption) (*dataflow.ListConnectorEnabledFeaturesResp, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "ListConnectorEnabledFeatures", varargs...)
	ret0, _ := ret[0].(*dataflow.ListConnectorEnabledFeaturesResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListConnectorEnabledFeatures indicates an expected call of ListConnectorEnabledFeatures.
func (mr *MockConnectorServiceClientMockRecorder) ListConnectorEnabledFeatures(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListConnectorEnabledFeatures", reflect.TypeOf((*MockConnectorServiceClient)(nil).ListConnectorEnabledFeatures), varargs...)
}

// ListConnectors mocks base method.
func (m *MockConnectorServiceClient) ListConnectors(ctx context.Context, in *dataflow.ConnectorListReq, opts ...grpc.CallOption) (*dataflow.Connectors, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "ListConnectors", varargs...)
	ret0, _ := ret[0].(*dataflow.Connectors)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListConnectors indicates an expected call of ListConnectors.
func (mr *MockConnectorServiceClientMockRecorder) ListConnectors(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListConnectors", reflect.TypeOf((*MockConnectorServiceClient)(nil).ListConnectors), varargs...)
}

// ListTiCDCClusters mocks base method.
func (m *MockConnectorServiceClient) ListTiCDCClusters(ctx context.Context, in *dataflow.ClusterIdReq, opts ...grpc.CallOption) (*structpb.Struct, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "ListTiCDCClusters", varargs...)
	ret0, _ := ret[0].(*structpb.Struct)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListTiCDCClusters indicates an expected call of ListTiCDCClusters.
func (mr *MockConnectorServiceClientMockRecorder) ListTiCDCClusters(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListTiCDCClusters", reflect.TypeOf((*MockConnectorServiceClient)(nil).ListTiCDCClusters), varargs...)
}

// ScaleChangefeed mocks base method.
func (m *MockConnectorServiceClient) ScaleChangefeed(ctx context.Context, in *dataflow.ChangefeedScaleReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "ScaleChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ScaleChangefeed indicates an expected call of ScaleChangefeed.
func (mr *MockConnectorServiceClientMockRecorder) ScaleChangefeed(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ScaleChangefeed", reflect.TypeOf((*MockConnectorServiceClient)(nil).ScaleChangefeed), varargs...)
}

// StartConnector mocks base method.
func (m *MockConnectorServiceClient) StartConnector(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "StartConnector", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// StartConnector indicates an expected call of StartConnector.
func (mr *MockConnectorServiceClientMockRecorder) StartConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).StartConnector), varargs...)
}

// StopConnector mocks base method.
func (m *MockConnectorServiceClient) StopConnector(ctx context.Context, in *dataflow.ConnectorID, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "StopConnector", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// StopConnector indicates an expected call of StopConnector.
func (mr *MockConnectorServiceClientMockRecorder) StopConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StopConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).StopConnector), varargs...)
}

// TestConnector mocks base method.
func (m *MockConnectorServiceClient) TestConnector(ctx context.Context, in *dataflow.ConnectorCreateReq, opts ...grpc.CallOption) (*emptypb.Empty, error) {
	m.ctrl.T.Helper()
	varargs := []any{ctx, in}
	for _, a := range opts {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "TestConnector", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// TestConnector indicates an expected call of TestConnector.
func (mr *MockConnectorServiceClientMockRecorder) TestConnector(ctx, in any, opts ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	varargs := append([]any{ctx, in}, opts...)
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "TestConnector", reflect.TypeOf((*MockConnectorServiceClient)(nil).TestConnector), varargs...)
}