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

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

// CreateChangefeed provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) CreateChangefeed(ctx context.Context, req *domain.CreateChangefeedReq) (*domain.CreateChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// DeleteChangefeed provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) DeleteChangefeed(ctx context.Context, req *domain.DeleteChangefeedReq) (*domain.DeleteChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

	if rf, ok := ret.Get(1).(func(context.Context, *domain.DeleteChangefeedReq) 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 *ChangefeedModel) GetChangefeedDetail(ctx context.Context, req *domain.GetChangefeedDetailReq) (*domain.GetChangefeedDetailResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

	if rf, ok := ret.Get(1).(func(context.Context, *domain.GetChangefeedDetailReq) 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 *ChangefeedModel) GetTiCDCCluster(ctx context.Context, req *domain.GetChangefeedClusterReq) (*domain.GetChangefeedClusterResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// ListChangefeeds provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) ListChangefeeds(ctx context.Context, req *domain.ListChangefeedsReq) (*domain.ListChangefeedsResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

	if rf, ok := ret.Get(1).(func(context.Context, *domain.ListChangefeedsReq) 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 *ChangefeedModel) 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
}

// MarkChangefeedDeleted provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) MarkChangefeedDeleted(ctx context.Context, req *domain.MarkChangefeedDeletedReq) (*domain.MarkChangefeedDeletedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// ModifyChangefeedConfig provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) ModifyChangefeedConfig(ctx context.Context, req *domain.ModifyChangefeedConfigReq) (*domain.ModifyChangefeedConfigResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// PauseChangefeed provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) PauseChangefeed(ctx context.Context, req *domain.PauseChangefeedReq) (*domain.PauseChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// QueryChangefeed provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) QueryChangefeed(ctx context.Context, req *domain.QueryChangefeedReq) (*domain.QueryChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// ResumeChangefeed provides a mock function with given fields: ctx, req
func (_m *ChangefeedModel) ResumeChangefeed(ctx context.Context, req *domain.ResumeChangefeedReq) (*domain.ResumeChangefeedResp, bizerr.BizError) {
	ret := _m.Called(ctx, req)

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

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

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

	return r0, r1
}

// NewChangefeedModel creates a new instance of ChangefeedModel. 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 NewChangefeedModel(t interface {
	mock.TestingT
	Cleanup(func())
}) *ChangefeedModel {
	mock := &ChangefeedModel{}
	mock.Mock.Test(t)

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

	return mock
}