snapshotter

type VolumeSnapshotter ¶

type VolumeSnapshotter interface {
	CreateVolumeSnapshot(snapshot *crdv1.VolumeSnapshot)
	DeleteVolumeSnapshot(snapshot *crdv1.VolumeSnapshot)
	PromoteVolumeSnapshotToPV(snapshot *crdv1.VolumeSnapshot)
	UpdateVolumeSnapshot(snapshotName string) error
	UpdateVolumeSnapshotData(snapshotDataName string, status *[]crdv1.VolumeSnapshotDataCondition) error
}

VolumeSnapshotter does the "heavy lifting": it spawns goroutines that talk to the backend to actually perform the operations on the storage devices. It creates and deletes the snapshots and promotes snapshots to volumes (PV). The create and delete operations need to be idempotent and count with the fact the API object writes

func NewVolumeSnapshotter(
	restClient *rest.RESTClient,
	scheme *runtime.Scheme,
	clientset kubernetes.Interface,
	asw cache.ActualStateOfWorld,
	volumePlugins *map[string]volume.VolumePlugin) VolumeSnapshotter