// Code generated by MockGen. DO NOT EDIT.
// Source: ./thirdparty/dataflow/dataflow.go

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

import (
	context "context"
	reflect "reflect"

	gomock "github.com/golang/mock/gomock"
)

// MockDataflowHandler is a mock of DataflowHandler interface.
type MockDataflowHandler struct {
	ctrl     *gomock.Controller
	recorder *MockDataflowHandlerMockRecorder
}

// MockDataflowHandlerMockRecorder is the mock recorder for MockDataflowHandler.
type MockDataflowHandlerMockRecorder struct {
	mock *MockDataflowHandler
}

// NewMockDataflowHandler creates a new mock instance.
func NewMockDataflowHandler(ctrl *gomock.Controller) *MockDataflowHandler {
	mock := &MockDataflowHandler{ctrl: ctrl}
	mock.recorder = &MockDataflowHandlerMockRecorder{mock}
	return mock
}

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

// DeleteAllBackups mocks base method.
func (m *MockDataflowHandler) DeleteAllBackups(ctx context.Context, tenantID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllBackups", ctx, tenantID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllBackups indicates an expected call of DeleteAllBackups.
func (mr *MockDataflowHandlerMockRecorder) DeleteAllBackups(ctx, tenantID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllBackups", reflect.TypeOf((*MockDataflowHandler)(nil).DeleteAllBackups), ctx, tenantID)
}

// DeleteAllManualBackups mocks base method.
func (m *MockDataflowHandler) DeleteAllManualBackups(ctx context.Context, tenantID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllManualBackups", ctx, tenantID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllManualBackups indicates an expected call of DeleteAllManualBackups.
func (mr *MockDataflowHandlerMockRecorder) DeleteAllManualBackups(ctx, tenantID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllManualBackups", reflect.TypeOf((*MockDataflowHandler)(nil).DeleteAllManualBackups), ctx, tenantID)
}

// DeleteDeletedClusterBackups mocks base method.
func (m *MockDataflowHandler) DeleteDeletedClusterBackups(ctx context.Context, tenantID, projectID, clusterID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteDeletedClusterBackups", ctx, tenantID, projectID, clusterID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteDeletedClusterBackups indicates an expected call of DeleteDeletedClusterBackups.
func (mr *MockDataflowHandlerMockRecorder) DeleteDeletedClusterBackups(ctx, tenantID, projectID, clusterID interface{}) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteDeletedClusterBackups", reflect.TypeOf((*MockDataflowHandler)(nil).DeleteDeletedClusterBackups), ctx, tenantID, projectID, clusterID)
}