package dataflow

import (
	"context"
)

type DataflowHandler interface {
	DeleteDeletedClusterBackups(ctx context.Context, tenantID, projectID, clusterID uint64) error
	DeleteAllManualBackups(ctx context.Context, tenantID uint64) error
	DeleteAllBackups(ctx context.Context, tenantID uint64) error
}

var global DataflowHandler = &DataflowHandlerImpl{}

func GetHandler() DataflowHandler {
	return global
}

func SetHandler(handler DataflowHandler) {
	global = handler
}