specs

Nov 19, 2024

Changes in this version

+ const EnableMetadataPrefetchAndFakeVolumePrefix

+ const EnableMetadataPrefetchAndInvalidMountOptionsVolumePrefix

+ const EnableMetadataPrefetchPrefix

+ const EnableMetadataPrefetchPrefixForceNewBucketPrefix

type TestPod

+ func (t *TestPod) VerifyMetadataPrefetchNotPresent()

+ func (t *TestPod) VerifyMetadataPrefetchPresence()

Nov 13, 2024

Changes in this version

+ const EnableFileCacheAndMetricsPrefix

+ const EnableFileCacheForceNewBucketAndMetricsPrefix

Sep 26, 2024

Changes in this version

type GCSFuseCSITestDriver

+ EnableHierarchicalNamespace bool

type TestPod

+ func (t *TestPod) SetupVolumeForHNS(name string)

Sep 17, 2024

Changes in this version

+ const EnableFileCacheForceNewBucketPrefix

+ func DeployIstioServiceEntry(namespace string)

+ func DeployIstioSidecar(namespace string)

type TestPod

+ func (t *TestPod) GetCSIDriverNodePodIP(ctx context.Context) string

+ func (t *TestPod) GetPodName() string

+ func (t *TestPod) SetLabels(labels map[string]string)

+ func (t *TestPod) WaitForFailedContainerError(ctx context.Context, msg string)

Aug 6, 2024

Changes in this version

+ func GetGCSFuseVersion(ctx context.Context, client clientset.Interface) string

+ func InitGCSFuseCSITestDriver(c clientset.Interface, m metadata.Service, bl string, skipGcpSaTest bool) storageframework.TestDriver

+ type GCSFuseCSITestDriver struct

+ func (n *GCSFuseCSITestDriver) CreateVolume(ctx context.Context, config *storageframework.PerTestConfig, ...) storageframework.TestVolume

+ func (n *GCSFuseCSITestDriver) GetCSIDriverName(_ *storageframework.PerTestConfig) string

+ func (n *GCSFuseCSITestDriver) GetDriverInfo() *storageframework.DriverInfo

+ func (n *GCSFuseCSITestDriver) GetDynamicProvisionStorageClass(ctx context.Context, config *storageframework.PerTestConfig, _ string) *storagev1.StorageClass

+ func (n *GCSFuseCSITestDriver) GetPersistentVolumeSource(readOnly bool, _ string, volume storageframework.TestVolume) (*corev1.PersistentVolumeSource, *corev1.VolumeNodeAffinity)

+ func (n *GCSFuseCSITestDriver) GetVolume(config *storageframework.PerTestConfig, _ int) (map[string]string, bool, bool)

+ func (n *GCSFuseCSITestDriver) PrepareTest(ctx context.Context, f *e2eframework.Framework) *storageframework.PerTestConfig

+ func (n *GCSFuseCSITestDriver) RemoveIAMPolicy(ctx context.Context, bucket *storage.ServiceBucket, ...)

+ func (n *GCSFuseCSITestDriver) SetIAMPolicy(ctx context.Context, bucket *storage.ServiceBucket, ...)

+ func (n *GCSFuseCSITestDriver) SkipUnsupportedTest(pattern storageframework.TestPattern)

May 29, 2024

Changes in this version

+ const SkipCSIBucketAccessCheckAndFakeVolumePrefix

+ const SkipCSIBucketAccessCheckAndImplicitDirsVolumePrefix

+ const SkipCSIBucketAccessCheckAndInvalidMountOptionsVolumePrefix

+ const SkipCSIBucketAccessCheckAndInvalidVolumePrefix

+ const SkipCSIBucketAccessCheckAndNonRootVolumePrefix

+ const SkipCSIBucketAccessCheckPrefix

Apr 26, 2024

Changes in this version

type TestPod

+ func (t *TestPod) CheckSidecarNeverTerminatedAfterAWhile(ctx context.Context, isNativeSidecar bool)

Mar 18, 2024

Changes in this version

+ const EnableFileCachePrefix

+ const EnableFileCacheWithLargeCapacityPrefix

+ const GolangImage

+ func CreateTestFileWithSizeInBucket(fileName, bucketName string, fileSize int)

type TestPod

+ func (t *TestPod) SetInitContainerWithCommand(cmd string)

+ func (t *TestPod) SetIstioSidecar(isNativeSidecar bool)

+ func (t *TestPod) SetupTmpVolumeMount(mountPath string)

+ func (t *TestPod) SetupVolumeForInitContainer(name, mountPath string, readOnly bool, subPath string)

+ func (t *TestPod) VerifyInjectionOrder(gcsFuseNativeSidecar, istioNativeSidecar bool)

+ func (t *TestPod) WaitForLog(ctx context.Context, container string, expectedString string, ...)

Feb 17, 2024

Changes in this version

+ const DisableFileCachePrefix

+ func CreateTestFileInBucket(fileName, bucketName string)

type TestPod

+ func (t *TestPod) SetupCacheVolumeMount(mountPath string)

Feb 14, 2024

Changes in this version

+ const PollInterval

+ const PollTimeout

type TestJob

+ func (t *TestJob) WaitForAllJobPodsGone(ctx context.Context, timeout time.Duration)

type TestPod

+ func (t *TestPod) CheckSidecarNeverTerminated(ctx context.Context)

+ func (t *TestPod) WaitForFail(ctx context.Context, timeout time.Duration)

Feb 6, 2024

Changes in this version

type TestDeployment

+ func (t *TestDeployment) Scale(ctx context.Context, replica int)

+ func (t *TestDeployment) SetReplicas(replica int)

+ func (t *TestDeployment) WaitForRunningAndReadyWithTimeout(ctx context.Context, timeout time.Duration)

type TestJob

+ func (t *TestJob) WaitForJobFailed()

type TestPod

+ func (t *TestPod) SetGracePeriod(s int)

+ func (t *TestPod) WaitForPodNotFoundInNamespace(ctx context.Context, timeout time.Duration)

Jan 23, 2024

Changes in this version

+ type TestPVC struct

+ PVC *v1.PersistentVolumeClaim

+ func NewTestPVC(c clientset.Interface, ns *v1.Namespace, ...) *TestPVC

+ func (t *TestPVC) Cleanup(ctx context.Context)

+ func (t *TestPVC) Create(ctx context.Context)

Dec 20, 2023

Changes in this version

+ const LastPublishedSidecarContainerImage

type TestPod

+ func (t *TestPod) SetCustomSidecarContainerImage()

+ func (t *TestPod) VerifyCustomSidecarContainerImage()

Nov 9, 2023

Changes in this version

+ func WaitForWorkloadReady(ctx context.Context, c clientset.Interface, namespace string, ...)

type TestDeployment

+ func (t *TestDeployment) WaitForRunningAndReady(ctx context.Context)

+ type TestStatefulSet struct

+ func NewTestStatefulSet(c clientset.Interface, ns *v1.Namespace, tPod *TestPod) *TestStatefulSet

+ func (t *TestStatefulSet) Cleanup(ctx context.Context)

+ func (t *TestStatefulSet) Create(ctx context.Context)

+ func (t *TestStatefulSet) WaitForRunningAndReady(ctx context.Context)

Sep 27, 2023

Changes in this version

+ func CreateEmptyFileInBucket(fileName, bucketName string)

+ func CreateImplicitDirInBucket(dirPath, bucketName string)

type TestPod

+ func (t *TestPod) SetupVolumeWithSubPath(volumeResource *storageframework.VolumeResource, name, mountPath string, ...)

Jun 23, 2023

Changes in this version

+ const GoogleCloudCliImage

+ const SubfolderInBucketPrefix

+ const UbuntuImage

type TestGCPServiceAccount

+ func (t *TestGCPServiceAccount) AddIAMPolicyBinding(ctx context.Context, ns *v1.Namespace)

+ func (t *TestGCPServiceAccount) GetEmail() string

type TestPod

+ func (t *TestPod) SetImage(image string)

+ func (t *TestPod) SetNodeAffinity(nodeName string, sameNode bool)

+ func (t *TestPod) SetResource(cpuLimit, memoryLimit string)

+ func (t *TestPod) VerifyExecInPodSucceedWithFullOutput(f *framework.Framework, containerName, shExec string)

May 15, 2023

Changes in this version

+ const InvalidVolume

+ const InvalidVolumePrefix

type TestPod

+ func (t *TestPod) SetRestartPolicy(rp v1.RestartPolicy)

+ func (t *TestPod) WaitFoSuccess()

Mar 31, 2023

Changes in this version

+ const ForceNewBucketPrefix

+ const ImplicitDirsPath

+ const ImplicitDirsVolumePrefix

+ const MultipleBucketsPrefix

+ const SameBucketDifferentDirPrefix

+ type TestDeployment struct

+ func NewTestDeployment(c clientset.Interface, ns *v1.Namespace, tPod *TestPod) *TestDeployment

+ func (t *TestDeployment) Cleanup()

+ func (t *TestDeployment) Create()

+ func (t *TestDeployment) GetPod() *v1.Pod

+ func (t *TestDeployment) WaitForComplete()

+ type TestJob struct

+ func NewTestJob(c clientset.Interface, ns *v1.Namespace, tPod *TestPod) *TestJob

+ func (t *TestJob) Cleanup()

+ func (t *TestJob) Create()

+ func (t *TestJob) WaitForJobPodsSucceeded()

type TestPod

+ func (t *TestPod) GetNode() string

+ func (t *TestPod) SetPod(pod *v1.Pod)

+ func (t *TestPod) WaitForUnschedulable()

Mar 16, 2023

Changes in this version

+ const FakeVolumePrefix

+ const InvalidMountOptionsVolumePrefix

+ const K8sSecretName

+ const K8sServiceAccountName

+ const NonRootVolumePrefix

+ const TesterContainerName

+ type TestGCPProjectIAMPolicyBinding struct

+ func NewTestGCPProjectIAMPolicyBinding(projectID, member, role, condition string) *TestGCPProjectIAMPolicyBinding

+ func (t *TestGCPProjectIAMPolicyBinding) Cleanup()

+ func (t *TestGCPProjectIAMPolicyBinding) Create()

+ type TestGCPServiceAccount struct

+ func NewTestGCPServiceAccount(name, projectID string) *TestGCPServiceAccount

+ func (t *TestGCPServiceAccount) Cleanup()

+ func (t *TestGCPServiceAccount) Create()

+ type TestGCPServiceAccountIAMPolicyBinding struct

+ func NewTestGCPServiceAccountIAMPolicyBinding(ns *v1.Namespace, serviceAccount *iam.ServiceAccount) *TestGCPServiceAccountIAMPolicyBinding

+ func (t *TestGCPServiceAccountIAMPolicyBinding) Cleanup()

+ func (t *TestGCPServiceAccountIAMPolicyBinding) Create()

+ type TestKubernetesServiceAccount struct

+ func NewTestKubernetesServiceAccount(c clientset.Interface, ns *v1.Namespace, name, gcpSAName string) *TestKubernetesServiceAccount

+ func (t *TestKubernetesServiceAccount) Cleanup()

+ func (t *TestKubernetesServiceAccount) Create()

+ type TestPod struct

+ func NewTestPod(c clientset.Interface, ns *v1.Namespace) *TestPod

+ func (t *TestPod) Cleanup()

+ func (t *TestPod) Create()

+ func (t *TestPod) SetAnnotations(annotations map[string]string)

+ func (t *TestPod) SetCommand(cmd string)

+ func (t *TestPod) SetName(name string)

+ func (t *TestPod) SetNodeSelector(nodeSelector map[string]string)

+ func (t *TestPod) SetNonRootSecurityContext()

+ func (t *TestPod) SetServiceAccount(sa string)

+ func (t *TestPod) SetupVolume(volumeResource *storageframework.VolumeResource, name, mountPath string, ...)

+ func (t *TestPod) VerifyExecInPodFail(f *framework.Framework, containerName, shExec string, exitCode int)

+ func (t *TestPod) VerifyExecInPodSucceed(f *framework.Framework, containerName, shExec string)

+ func (t *TestPod) WaitForFailedMountError(msg string)

+ func (t *TestPod) WaitForFailure()

+ func (t *TestPod) WaitForRunning()

+ func (t *TestPod) WaitForSuccess()

+ type TestSecret struct

+ func NewTestSecret(c clientset.Interface, ns *v1.Namespace, name string, data map[string]string) *TestSecret

+ func (t *TestSecret) Cleanup()

+ func (t *TestSecret) Create()