util

func CheckUploadProgress(ctx context.Context, httpClient *safeClient.SafeClient, targetURL string) (int64, error)

func CreateDataImport(
	ctx context.Context,
	name, namespace, ttl string,
	publish, waitForFirstConsumer bool,
	pvcTpl *v1alpha1.PersistentVolumeClaimTemplateSpec,
	rtClient ctrlrtclient.Client,
) error

func DeleteDataImport(ctx context.Context, diName, namespace string, rtClient ctrlrtclient.Client) error

func GetDataImport(ctx context.Context, diName, namespace string, rtClient ctrlrtclient.Client) (*v1alpha1.DataImport, error)

func GetDataImportWithRestart(
	ctx context.Context,
	diName, namespace string,
	rtClient ctrlrtclient.Client,
) (*v1alpha1.DataImport, error)

func PrepareUpload(
	ctx context.Context,
	_ *slog.Logger,
	diName, namespace string,
	publish bool,
	sClient *safeClient.SafeClient,
) (string, string, *safeClient.SafeClient, error)