csi

func DeleteVolumeSnapshotContentIfAny ¶ added in v1.12.0

func DeleteVolumeSnapshotContentIfAny(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface, vscName string, log logrus.FieldLogger)

DeleteVolumeSnapshotContentIfAny deletes a VSC by name if it exists, and log an error when the deletion fails

func DeleteVolumeSnapshotIfAny ¶ added in v1.12.0

func DeleteVolumeSnapshotIfAny(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface, vsName string, vsNamespace string, log logrus.FieldLogger)

DeleteVolumeSnapshotIfAny deletes a VS by name if it exists, and log an error when the deletion fails

func EnsureDeleteVS ¶ added in v1.12.0

func EnsureDeleteVS(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface,
	vsName string, vsNamespace string, timeout time.Duration) error

EnsureDeleteVS asserts the existence of a VS by name, deletes it and waits for its disappearance and returns errors on any failure

func EnsureDeleteVSC ¶ added in v1.12.0

func EnsureDeleteVSC(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface,
	vscName string, timeout time.Duration) error

EnsureDeleteVSC asserts the existence of a VSC by name, deletes it and waits for its disappearance and returns errors on any failure

func GetVolumeSnapshotContentForVolumeSnapshot ¶ added in v1.12.0

func GetVolumeSnapshotContentForVolumeSnapshot(volSnap *snapshotv1api.VolumeSnapshot, snapshotClient snapshotter.SnapshotV1Interface) (*snapshotv1api.VolumeSnapshotContent, error)

GetVolumeSnapshotContentForVolumeSnapshot returns the volumesnapshotcontent object associated with the volumesnapshot

func RemoveVSCProtect ¶ added in v1.12.2

func RemoveVSCProtect(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface, vscName string, timeout time.Duration) error

func RetainVSC ¶ added in v1.12.0

func RetainVSC(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface,
	vsc *snapshotv1api.VolumeSnapshotContent) (*snapshotv1api.VolumeSnapshotContent, error)

RetainVSC updates the VSC's deletion policy to Retain and add a finalier and then return the update VSC

func ShouldSkipAction ¶ added in v1.13.0

func ShouldSkipAction(actionName string) bool

func WaitVolumeSnapshotReady ¶ added in v1.12.0

func WaitVolumeSnapshotReady(ctx context.Context, snapshotClient snapshotter.SnapshotV1Interface,
	volumeSnapshot string, volumeSnapshotNS string, timeout time.Duration, log logrus.FieldLogger) (*snapshotv1api.VolumeSnapshot, error)

WaitVolumeSnapshotReady waits a VS to become ready to use until the timeout reaches