// Code generated by mockery v2.53.3. DO NOT EDIT.

package mock

import (
	context "context"

	bizerr "github.com/tidbcloud/pkgv2/bizerr"

	domain "github.com/tidbcloud/dataflow-service-ng/app/models/domain"

	mock "github.com/stretchr/testify/mock"
)

// BizChangefeedModel is an autogenerated mock type for the BizChangefeedModel type
type BizChangefeedModel struct {
	mock.Mock
}

// ApplyStoppedBizChangefeedConfig provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ApplyStoppedBizChangefeedConfig(ctx context.Context, req *domain.ApplyStoppedBizChangefeedConfigReq) bizerr.BizError {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ApplyStoppedBizChangefeedConfig")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ApplyStoppedBizChangefeedConfigReq) bizerr.BizError); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// CalBizChangefeedFee provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) CalBizChangefeedFee(ctx context.Context, req *domain.CalBizChangefeedFeeReq) (*domain.CalBizChangefeedFeeResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for CalBizChangefeedFee")
	}

	var r0 *domain.CalBizChangefeedFeeResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.CalBizChangefeedFeeReq) (*domain.CalBizChangefeedFeeResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.CalBizChangefeedFeeReq) *domain.CalBizChangefeedFeeResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.CalBizChangefeedFeeResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.CalBizChangefeedFeeReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// CreateBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) CreateBizChangefeed(ctx context.Context, req *domain.CreateBizChangefeedReq) (*domain.CreateBizChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for CreateBizChangefeed")
	}

	var r0 *domain.CreateBizChangefeedResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.CreateBizChangefeedReq) (*domain.CreateBizChangefeedResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.CreateBizChangefeedReq) *domain.CreateBizChangefeedResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.CreateBizChangefeedResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.CreateBizChangefeedReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// DeleteBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) DeleteBizChangefeed(ctx context.Context, req *domain.DeleteBizChangefeedReq) (*domain.DeleteBizChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for DeleteBizChangefeed")
	}

	var r0 *domain.DeleteBizChangefeedResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DeleteBizChangefeedReq) (*domain.DeleteBizChangefeedResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DeleteBizChangefeedReq) *domain.DeleteBizChangefeedResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.DeleteBizChangefeedResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.DeleteBizChangefeedReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// DescribeAdminProfile provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) DescribeAdminProfile(ctx context.Context, req *domain.DescribeAdminProfileReq) (*domain.DescribeAdminProfileResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for DescribeAdminProfile")
	}

	var r0 *domain.DescribeAdminProfileResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DescribeAdminProfileReq) (*domain.DescribeAdminProfileResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DescribeAdminProfileReq) *domain.DescribeAdminProfileResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.DescribeAdminProfileResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.DescribeAdminProfileReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// DescribeSchemaTable provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) DescribeSchemaTable(ctx context.Context, req *domain.DescribeSchemaTableReq) (*domain.DescribeSchemaTableResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for DescribeSchemaTable")
	}

	var r0 *domain.DescribeSchemaTableResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DescribeSchemaTableReq) (*domain.DescribeSchemaTableResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.DescribeSchemaTableReq) *domain.DescribeSchemaTableResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.DescribeSchemaTableResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.DescribeSchemaTableReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// EditBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) EditBizChangefeed(ctx context.Context, req *domain.EditBizChangefeedReq) bizerr.BizError {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for EditBizChangefeed")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.EditBizChangefeedReq) bizerr.BizError); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// EditBizChangefeedForOps provides a mock function with given fields: ctx, bizChangefeedID
func (_m *BizChangefeedModel) EditBizChangefeedForOps(ctx context.Context, bizChangefeedID uint64) bizerr.BizError {
	ret := _m.Called(ctx, bizChangefeedID)

	if len(ret) == 0 {
		panic("no return value specified for EditBizChangefeedForOps")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, uint64) bizerr.BizError); ok {
		r0 = rf(ctx, bizChangefeedID)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// GetBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) GetBizChangefeed(ctx context.Context, req *domain.GetBizChangefeedReq) (*domain.GetBizChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for GetBizChangefeed")
	}

	var r0 *domain.GetBizChangefeedResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedReq) (*domain.GetBizChangefeedResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedReq) *domain.GetBizChangefeedResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.GetBizChangefeedResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.GetBizChangefeedReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// GetChangefeedDetail provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) GetChangefeedDetail(ctx context.Context, req *domain.GetBizChangefeedDetailReq) (*domain.GetBizChangefeedDetailResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for GetChangefeedDetail")
	}

	var r0 *domain.GetBizChangefeedDetailResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedDetailReq) (*domain.GetBizChangefeedDetailResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedDetailReq) *domain.GetBizChangefeedDetailResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.GetBizChangefeedDetailResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.GetBizChangefeedDetailReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// GetClusterBizChangefeedRCU provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) GetClusterBizChangefeedRCU(ctx context.Context, req *domain.GetClusterBizChangefeedRCUReq) (*domain.GetClusterBizChangefeedRCUResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for GetClusterBizChangefeedRCU")
	}

	var r0 *domain.GetClusterBizChangefeedRCUResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetClusterBizChangefeedRCUReq) (*domain.GetClusterBizChangefeedRCUResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetClusterBizChangefeedRCUReq) *domain.GetClusterBizChangefeedRCUResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.GetClusterBizChangefeedRCUResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.GetClusterBizChangefeedRCUReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// GetTiCDCCluster provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) GetTiCDCCluster(ctx context.Context, req *domain.GetBizChangefeedClusterReq) (*domain.GetBizChangefeedClusterResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for GetTiCDCCluster")
	}

	var r0 *domain.GetBizChangefeedClusterResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedClusterReq) (*domain.GetBizChangefeedClusterResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.GetBizChangefeedClusterReq) *domain.GetBizChangefeedClusterResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.GetBizChangefeedClusterResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.GetBizChangefeedClusterReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// ListBizChangefeedSpecifications provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ListBizChangefeedSpecifications(ctx context.Context, req *domain.ListBizChangefeedSpecificationsReq) (*domain.ListBizChangefeedSpecificationsResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ListBizChangefeedSpecifications")
	}

	var r0 *domain.ListBizChangefeedSpecificationsResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListBizChangefeedSpecificationsReq) (*domain.ListBizChangefeedSpecificationsResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListBizChangefeedSpecificationsReq) *domain.ListBizChangefeedSpecificationsResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.ListBizChangefeedSpecificationsResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.ListBizChangefeedSpecificationsReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// ListBizChangefeeds provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ListBizChangefeeds(ctx context.Context, req *domain.ListBizChangefeedsReq) (*domain.ListBizChangefeedsResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ListBizChangefeeds")
	}

	var r0 *domain.ListBizChangefeedsResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListBizChangefeedsReq) (*domain.ListBizChangefeedsResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListBizChangefeedsReq) *domain.ListBizChangefeedsResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.ListBizChangefeedsResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.ListBizChangefeedsReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// ListTiCDCClusters provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ListTiCDCClusters(ctx context.Context, req *domain.ListTiCDCClusterReq) (*domain.ListTiCDCClusterResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ListTiCDCClusters")
	}

	var r0 *domain.ListTiCDCClusterResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListTiCDCClusterReq) (*domain.ListTiCDCClusterResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ListTiCDCClusterReq) *domain.ListTiCDCClusterResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.ListTiCDCClusterResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.ListTiCDCClusterReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// PauseBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) PauseBizChangefeed(ctx context.Context, req *domain.PauseBizChangefeedReq) bizerr.BizError {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for PauseBizChangefeed")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.PauseBizChangefeedReq) bizerr.BizError); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// ResumeBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ResumeBizChangefeed(ctx context.Context, req *domain.ResumeBizChangefeedReq) bizerr.BizError {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ResumeBizChangefeed")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ResumeBizChangefeedReq) bizerr.BizError); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// ScaleBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) ScaleBizChangefeed(ctx context.Context, req *domain.ScaleBizChangefeedReq) (*domain.ScaleBizChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for ScaleBizChangefeed")
	}

	var r0 *domain.ScaleBizChangefeedResp
	var r1 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ScaleBizChangefeedReq) (*domain.ScaleBizChangefeedResp, bizerr.BizError)); ok {
		return rf(ctx, req)
	}
	if rf, ok := ret.Get(0).(func(context.Context, *domain.ScaleBizChangefeedReq) *domain.ScaleBizChangefeedResp); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(*domain.ScaleBizChangefeedResp)
		}
	}

	if rf, ok := ret.Get(1).(func(context.Context, *domain.ScaleBizChangefeedReq) bizerr.BizError); ok {
		r1 = rf(ctx, req)
	} else {
		if ret.Get(1) != nil {
			r1 = ret.Get(1).(bizerr.BizError)
		}
	}

	return r0, r1
}

// TestBizChangefeed provides a mock function with given fields: ctx, req
func (_m *BizChangefeedModel) TestBizChangefeed(ctx context.Context, req *domain.TestBizChangefeedReq) bizerr.BizError {
	ret := _m.Called(ctx, req)

	if len(ret) == 0 {
		panic("no return value specified for TestBizChangefeed")
	}

	var r0 bizerr.BizError
	if rf, ok := ret.Get(0).(func(context.Context, *domain.TestBizChangefeedReq) bizerr.BizError); ok {
		r0 = rf(ctx, req)
	} else {
		if ret.Get(0) != nil {
			r0 = ret.Get(0).(bizerr.BizError)
		}
	}

	return r0
}

// NewBizChangefeedModel creates a new instance of BizChangefeedModel. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
// The first argument is typically a *testing.T value.
func NewBizChangefeedModel(t interface {
	mock.TestingT
	Cleanup(func())
}) *BizChangefeedModel {
	mock := &BizChangefeedModel{}
	mock.Mock.Test(t)

	t.Cleanup(func() { mock.AssertExpectations(t) })

	return mock
}