csi

Jul 24, 2023

Changes in this version

type ApplicationCreator

+ func NewApplicationCreator(kubeCli kubernetes.Interface, k8sObjectReadyTimeout time.Duration) ApplicationCreator

type ArgumentValidator

+ func NewArgumentValidator(kubeCli kubernetes.Interface, dynCli dynamic.Interface) ArgumentValidator

type Cleaner

+ func NewCleaner(kubeCli kubernetes.Interface, dynCli dynamic.Interface) Cleaner

Jun 30, 2022

Changes in this version

+ const PVCKind

+ const PodKind

type ApplicationCreator

+ WaitForPVCReady func(ctx context.Context, namespace string, pvcName string) error

Oct 8, 2021

Changes in this version

type ArgumentValidator

+ FetchPV func(ctx context.Context, pvName string) (*v1.PersistentVolume, error)

+ ValidatePVC func(ctx context.Context, pvcName, namespace string) (*v1.PersistentVolumeClaim, error)

+ type PVCBrowseRunner struct

+ DynCli dynamic.Interface

+ KubeCli kubernetes.Interface

+ func (r *PVCBrowseRunner) RunPVCBrowse(ctx context.Context, args *types.PVCBrowseArgs) error

+ func (r *PVCBrowseRunner) RunPVCBrowseHelper(ctx context.Context, args *types.PVCBrowseArgs) error

+ type PVCBrowserStepper interface

+ Cleanup func(ctx context.Context, pvc *v1.PersistentVolumeClaim, pod *v1.Pod, ...)

+ CreateInspectorApplication func(ctx context.Context, args *types.PVCBrowseArgs, ...) (*v1.Pod, *v1.PersistentVolumeClaim, error)

+ PortForwardAPod func(ctx context.Context, pod *v1.Pod, localPort int) error

+ SnapshotPVC func(ctx context.Context, args *types.PVCBrowseArgs, snapshotName string) (*snapv1.VolumeSnapshot, error)

+ ValidateArgs func(ctx context.Context, args *types.PVCBrowseArgs) (*sv1.StorageClass, error)

+ type PortForwarder interface

+ FetchRestConfig func() (*rest.Config, error)

+ PortForwardAPod func(req *types.PortForwardAPodRequest) error

Dec 16, 2020

Changes in this version

+ const VolumeSnapshotResourcePlural

Dec 9, 2020

Changes in this version

+ const DefaultPodImage

+ const SnapGroupName

+ const VolSnapClassAlphaDriverKey

+ const VolSnapClassBetaDriverKey

+ const VolumeSnapshotClassResourcePlural

+ type ApiVersionFetcher interface

+ GetCSISnapshotGroupVersion func() (*metav1.GroupVersionForDiscovery, error)

+ type ApplicationCreator interface

+ CreatePVC func(ctx context.Context, args *types.CreatePVCArgs) (*v1.PersistentVolumeClaim, error)

+ CreatePod func(ctx context.Context, args *types.CreatePodArgs) (*v1.Pod, error)

+ WaitForPodReady func(ctx context.Context, namespace string, podName string) error

+ type ArgumentValidator interface

+ ValidateNamespace func(ctx context.Context, namespace string) error

+ ValidateStorageClass func(ctx context.Context, storageClass string) (*sv1.StorageClass, error)

+ ValidateVolumeSnapshotClass func(ctx context.Context, volumeSnapshotClass string, ...) (*unstructured.Unstructured, error)

+ type CSI interface

+ RunSnapshotRestore func(ctx context.Context, args *types.CSISnapshotRestoreArgs) (*types.CSISnapshotRestoreResults, error)

+ type Cleaner interface

+ DeletePVC func(ctx context.Context, pvcName string, namespace string) error

+ DeletePod func(ctx context.Context, podName string, namespace string) error

+ DeleteSnapshot func(ctx context.Context, snapshotName string, namespace string) error

+ type DataValidator interface

+ FetchPodData func(podName string, podNamespace string) (string, error)

+ type SnapshotCreator interface

+ CreateFromSourceCheck func(ctx context.Context, snapshotter kansnapshot.Snapshotter, ...) error

+ CreateSnapshot func(ctx context.Context, snapshotter kansnapshot.Snapshotter, ...) (*v1alpha1.VolumeSnapshot, error)

+ NewSnapshotter func() (kansnapshot.Snapshotter, error)

+ type SnapshotRestoreRunner struct

+ DynCli dynamic.Interface

+ KubeCli kubernetes.Interface

+ func (r *SnapshotRestoreRunner) RunSnapshotRestore(ctx context.Context, args *types.CSISnapshotRestoreArgs) (*types.CSISnapshotRestoreResults, error)

+ func (r *SnapshotRestoreRunner) RunSnapshotRestoreHelper(ctx context.Context, args *types.CSISnapshotRestoreArgs) (*types.CSISnapshotRestoreResults, error)

+ type SnapshotRestoreStepper interface

+ Cleanup func(ctx context.Context, results *types.CSISnapshotRestoreResults)

+ CreateApplication func(ctx context.Context, args *types.CSISnapshotRestoreArgs, data string) (*v1.Pod, *v1.PersistentVolumeClaim, error)

+ RestoreApplication func(ctx context.Context, args *types.CSISnapshotRestoreArgs, ...) (*v1.Pod, *v1.PersistentVolumeClaim, error)

+ SnapshotApplication func(ctx context.Context, args *types.CSISnapshotRestoreArgs, ...) (*v1alpha1.VolumeSnapshot, error)

+ ValidateArgs func(ctx context.Context, args *types.CSISnapshotRestoreArgs) error

+ ValidateData func(ctx context.Context, pod *v1.Pod, data string) error