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

// 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"
)

// MockOpsInternalServiceClient is a mock of OpsInternalServiceClient interface.
type MockOpsInternalServiceClient struct {
	ctrl     *gomock.Controller
	recorder *MockOpsInternalServiceClientMockRecorder
	isgomock struct{}
}

// MockOpsInternalServiceClientMockRecorder is the mock recorder for MockOpsInternalServiceClient.
type MockOpsInternalServiceClientMockRecorder struct {
	mock *MockOpsInternalServiceClient
}

// NewMockOpsInternalServiceClient creates a new mock instance.
func NewMockOpsInternalServiceClient(ctrl *gomock.Controller) *MockOpsInternalServiceClient {
	mock := &MockOpsInternalServiceClient{ctrl: ctrl}
	mock.recorder = &MockOpsInternalServiceClientMockRecorder{mock}
	return mock
}

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

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

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

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

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

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

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

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

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

// PauseChangefeed mocks base method.
func (m *MockOpsInternalServiceClient) PauseChangefeed(ctx context.Context, in *dataflow.PauseChangefeedRequest, 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 *MockOpsInternalServiceClientMockRecorder) 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((*MockOpsInternalServiceClient)(nil).PauseChangefeed), varargs...)
}

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

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

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

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

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

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

// ResumeChangefeed mocks base method.
func (m *MockOpsInternalServiceClient) ResumeChangefeed(ctx context.Context, in *dataflow.ResumeChangefeedRequest, 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 *MockOpsInternalServiceClientMockRecorder) 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((*MockOpsInternalServiceClient)(nil).ResumeChangefeed), varargs...)
}

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

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