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

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

import (
	context "context"
	reflect "reflect"

	consoleapi "github.com/tidbcloud/dataflow-service-ng/idl/pbgen/proto/consoleapi"
	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"
)

// MockChangefeedServiceClient is a mock of ChangefeedServiceClient interface.
type MockChangefeedServiceClient struct {
	ctrl     *gomock.Controller
	recorder *MockChangefeedServiceClientMockRecorder
	isgomock struct{}
}

// MockChangefeedServiceClientMockRecorder is the mock recorder for MockChangefeedServiceClient.
type MockChangefeedServiceClientMockRecorder struct {
	mock *MockChangefeedServiceClient
}

// NewMockChangefeedServiceClient creates a new mock instance.
func NewMockChangefeedServiceClient(ctrl *gomock.Controller) *MockChangefeedServiceClient {
	mock := &MockChangefeedServiceClient{ctrl: ctrl}
	mock.recorder = &MockChangefeedServiceClientMockRecorder{mock}
	return mock
}

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

// CalChangefeedFee mocks base method.
func (m *MockChangefeedServiceClient) CalChangefeedFee(ctx context.Context, in *consoleapi.CalChangefeedFeeReq, opts ...grpc.CallOption) (*consoleapi.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].(*consoleapi.CalChangefeedFeeResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CalChangefeedFee indicates an expected call of CalChangefeedFee.
func (mr *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).CalChangefeedFee), varargs...)
}

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

// CreateChangefeed indicates an expected call of CreateChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) CreateChangefeed(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, "CreateChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).CreateChangefeed), varargs...)
}

// DeleteChangefeed mocks base method.
func (m *MockChangefeedServiceClient) DeleteChangefeed(ctx context.Context, in *consoleapi.ChangefeedID, 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, "DeleteChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DeleteChangefeed indicates an expected call of DeleteChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) DeleteChangefeed(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, "DeleteChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).DeleteChangefeed), varargs...)
}

// DescribeSchemaTable mocks base method.
func (m *MockChangefeedServiceClient) DescribeSchemaTable(ctx context.Context, in *consoleapi.DescribeSchemaTableReq, opts ...grpc.CallOption) (*consoleapi.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].(*consoleapi.DescribeSchemaTableResp)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DescribeSchemaTable indicates an expected call of DescribeSchemaTable.
func (mr *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).DescribeSchemaTable), varargs...)
}

// EditChangefeed mocks base method.
func (m *MockChangefeedServiceClient) EditChangefeed(ctx context.Context, in *consoleapi.ChangefeedEditReq, 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, "EditChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// EditChangefeed indicates an expected call of EditChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) EditChangefeed(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, "EditChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).EditChangefeed), varargs...)
}

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

// GetAdminProfile indicates an expected call of GetAdminProfile.
func (mr *MockChangefeedServiceClientMockRecorder) GetAdminProfile(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, "GetAdminProfile", reflect.TypeOf((*MockChangefeedServiceClient)(nil).GetAdminProfile), varargs...)
}

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

// GetChangefeed indicates an expected call of GetChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) GetChangefeed(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, "GetChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).GetChangefeed), varargs...)
}

// GetChangefeedDetail mocks base method.
func (m *MockChangefeedServiceClient) GetChangefeedDetail(ctx context.Context, in *consoleapi.ChangefeedID, 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 *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).GetChangefeedDetail), varargs...)
}

// GetTiCDCCluster mocks base method.
func (m *MockChangefeedServiceClient) GetTiCDCCluster(ctx context.Context, in *consoleapi.ChangefeedID, 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 *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).GetTiCDCCluster), varargs...)
}

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

// ListChangefeeds indicates an expected call of ListChangefeeds.
func (mr *MockChangefeedServiceClientMockRecorder) ListChangefeeds(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, "ListChangefeeds", reflect.TypeOf((*MockChangefeedServiceClient)(nil).ListChangefeeds), varargs...)
}

// ListTiCDCClusters mocks base method.
func (m *MockChangefeedServiceClient) ListTiCDCClusters(ctx context.Context, in *consoleapi.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 *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).ListTiCDCClusters), varargs...)
}

// PauseChangefeed mocks base method.
func (m *MockChangefeedServiceClient) PauseChangefeed(ctx context.Context, in *consoleapi.ChangefeedID, 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, "PauseChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// PauseChangefeed indicates an expected call of PauseChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) PauseChangefeed(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, "PauseChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).PauseChangefeed), varargs...)
}

// ResumeChangefeed mocks base method.
func (m *MockChangefeedServiceClient) ResumeChangefeed(ctx context.Context, in *consoleapi.ChangefeedID, 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, "ResumeChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ResumeChangefeed indicates an expected call of ResumeChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) ResumeChangefeed(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, "ResumeChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).ResumeChangefeed), varargs...)
}

// ScaleChangefeed mocks base method.
func (m *MockChangefeedServiceClient) ScaleChangefeed(ctx context.Context, in *consoleapi.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 *MockChangefeedServiceClientMockRecorder) 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((*MockChangefeedServiceClient)(nil).ScaleChangefeed), varargs...)
}

// TestChangefeed mocks base method.
func (m *MockChangefeedServiceClient) TestChangefeed(ctx context.Context, in *consoleapi.ChangefeedCreateReq, 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, "TestChangefeed", varargs...)
	ret0, _ := ret[0].(*emptypb.Empty)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// TestChangefeed indicates an expected call of TestChangefeed.
func (mr *MockChangefeedServiceClientMockRecorder) TestChangefeed(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, "TestChangefeed", reflect.TypeOf((*MockChangefeedServiceClient)(nil).TestChangefeed), varargs...)
}