...

Package storage

import "k8s.io/kubernetes/test/e2e/storage"
Overview
Index
Subdirectories

Overview ▾

Constants

const (
    // DirectoryLocalVolumeType is the default local volume type, aka a directory
    DirectoryLocalVolumeType localVolumeType = "dir"
    // DirectoryLinkLocalVolumeType is like DirectoryLocalVolumeType,
    // but it's a symbolic link to directory
    DirectoryLinkLocalVolumeType localVolumeType = "dir-link"
    // DirectoryBindMountedLocalVolumeType is like DirectoryLocalVolumeType
    // but bind mounted
    DirectoryBindMountedLocalVolumeType localVolumeType = "dir-bindmounted"
    // DirectoryLinkBindMountedLocalVolumeType is like DirectoryLocalVolumeType,
    // but it's a symbolic link to self bind mounted directory
    // Note that bind mounting at symbolic link actually mounts at directory it
    // links to.
    DirectoryLinkBindMountedLocalVolumeType localVolumeType = "dir-link-bindmounted"
    // TmpfsLocalVolumeType creates a tmpfs and mounts it
    TmpfsLocalVolumeType localVolumeType = "tmpfs"
    // GCELocalSSDVolumeType tests based on local ssd at /mnt/disks/by-uuid/
    GCELocalSSDVolumeType localVolumeType = "gce-localssd-scsi-fs"
    // BlockLocalVolumeType creates a local file, formats it, and maps it as a block device.
    BlockLocalVolumeType localVolumeType = "block"
    // BlockFsWithFormatLocalVolumeType creates a local file serving as the backing for block device,
    // formats it, and mounts it to use as FS mode local volume.
    BlockFsWithFormatLocalVolumeType localVolumeType = "blockfswithformat"
    // BlockFsWithoutFormatLocalVolumeType creates a local file serving as the backing for block device,
    // does not format it manually, and mounts it to use as FS mode local volume.
    BlockFsWithoutFormatLocalVolumeType localVolumeType = "blockfswithoutformat"
)

Variables

var (
    // BusyBoxImage is the image URI of BusyBox.
    BusyBoxImage = imageutils.GetE2EImage(imageutils.BusyBox)
)

func NewVolumeAttachment

func NewVolumeAttachment(vaName, pvName, nodeName string, status bool) *storagev1.VolumeAttachment

func PodsUseStaticPVsOrFail

func PodsUseStaticPVsOrFail(ctx context.Context, f *framework.Framework, podCount int, image string)

PodsUseStaticPVsOrFail Check that the pods using statically created PVs get scheduled to the same zone that the PV is in.

func SkipUnlessLocalSSDExists

func SkipUnlessLocalSSDExists(ctx context.Context, config *localTestConfig, ssdInterface, filesystemType string, node *v1.Node)

SkipUnlessLocalSSDExists takes in an ssdInterface (scsi/nvme) and a filesystemType (fs/block) and skips if a disk of that type does not exist on the node

func UpdatePVSize

func UpdatePVSize(ctx context.Context, pv *v1.PersistentVolume, size resource.Quantity, c clientset.Interface) (*v1.PersistentVolume, error)

Subdirectories

Name Synopsis
..
csi_mock
drivers
csi-test
driver Package driver is a generated GoMock package.
mock
cache
service
proxy
external
framework
podlogs Package podlogs enables live capturing of all events and log messages for some or all pods in a namespace as they get generated.
testsuites
utils