k8s

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	JobSelectorKey = "job"
	// Poll is how often to Poll pods, nodes and claims.
	PollInterval = 2 * time.Second
	PollTimeout  = 15 * time.Minute
)

Variables

This section is empty.

Functions

func AddAnnotationToPersistentVolume added in v1.10.0 

func AddAnnotationToPersistentVolume(ctx context.Context, client TestClient, namespace string, persistentVolume, key string) (*corev1.PersistentVolume, error)

func AddAnnotationToPod added in v1.10.0 

func AddAnnotationToPod(ctx context.Context, client TestClient, namespace, podName string, ann map[string]string) (*corev1.Pod, error)

func AddLabelToCRD added in v1.10.0 

func AddLabelToCRD(ctx context.Context, crd, label string) error

func AddLabelToPod added in v1.9.0 

func AddLabelToPod(ctx context.Context, podName, namespace, label string) error

func AddLabelToPv added in v1.9.0 

func AddLabelToPv(ctx context.Context, pv, label string) error

func AddLabelToPvc added in v1.9.0 

func AddLabelToPvc(ctx context.Context, pvc, namespace, label string) error

func CRDCountShouldBe added in v1.10.0 

func CRDCountShouldBe(ctx context.Context, name string, count int) error

func CRDShouldExist added in v1.10.0 

func CRDShouldExist(ctx context.Context, name string) error

func CRDShouldNotExist added in v1.10.0 

func CRDShouldNotExist(ctx context.Context, name string) error

func CleanupClusterRole 

func CleanupClusterRole(ctx context.Context, client TestClient, nsBaseName string) error

func CleanupClusterRoleBinding 

func CleanupClusterRoleBinding(ctx context.Context, client TestClient, nsBaseName string) error

func CleanupNamespaces 

func CleanupNamespaces(ctx context.Context, client TestClient, nsBaseName string) error

func CleanupNamespacesWithPoll 

func CleanupNamespacesWithPoll(ctx context.Context, client TestClient, nsBaseName string) error

func CreateConfigMap 

func CreateConfigMap(c clientset.Interface, ns, name string, labels, data map[string]string) (*v1.ConfigMap, error)

func CreateDeploy added in v1.11.0 

func CreateDeploy(c clientset.Interface, ns string, deployment *apps.Deployment) error

func CreateDeployment 

func CreateDeployment(c clientset.Interface, ns string, deployment *apps.Deployment) (*apps.Deployment, error)

func CreateFileToPod added in v1.10.0 

func CreateFileToPod(ctx context.Context, namespace, podName, volume, filename, content string) error

func CreateNamespace 

func CreateNamespace(ctx context.Context, client TestClient, namespace string) error

func CreateNamespaceWithAnnotation 

func CreateNamespaceWithAnnotation(ctx context.Context, client TestClient, namespace string, annotation map[string]string) error

func CreateNamespaceWithLabel 

func CreateNamespaceWithLabel(ctx context.Context, client TestClient, namespace string, label map[string]string) error

func CreatePVC added in v1.10.0 

func CreatePVC(client TestClient, ns, name, sc string, ann map[string]string) (*corev1.PersistentVolumeClaim, error)

func CreatePersistentVolume added in v1.10.0 

func CreatePersistentVolume(client TestClient, name string) (*corev1.PersistentVolume, error)

func CreatePod added in v1.10.0 

func CreatePod(client TestClient, ns, name, sc, pvcName string, volumeNameList []string, pvcAnn, ann map[string]string) (*corev1.Pod, error)

func CreateRBACWithBindingSA 

func CreateRBACWithBindingSA(ctx context.Context, client TestClient, namespace string, serviceaccount string, clusterrole string, clusterrolebinding string) error

func CreateSecret 

func CreateSecret(c clientset.Interface, ns, name string, labels map[string]string) (*v1.Secret, error)

func CreateSecretFromFiles 

func CreateSecretFromFiles(ctx context.Context, client TestClient, namespace string, name string, files map[string]string) error

func CreateService added in v1.11.0 

func CreateService(ctx context.Context, client TestClient, namespace string,
	service string, labels map[string]string, serviceSpec *corev1.ServiceSpec) error

func CreateServiceAccount 

func CreateServiceAccount(ctx context.Context, client TestClient, namespace string, serviceaccount string) error

func DeleteNamespace 

func DeleteNamespace(ctx context.Context, client TestClient, namespace string, wait bool) error

func DeleteVeleroDs added in v1.10.0 

func DeleteVeleroDs(ctx context.Context) error

func EnsureClusterExists 

func EnsureClusterExists(ctx context.Context) error

ensureClusterExists returns whether or not a kubernetes cluster exists for tests to be run on.

func GetAPIVersions added in v1.10.0 

func GetAPIVersions(client *TestClient, name string) ([]string, error)

func GetAllService added in v1.11.0 

func GetAllService(ctx context.Context) (string, error)

func GetCRD added in v1.10.0 

func GetCRD(ctx context.Context, name string) ([]string, error)

func GetClusterRole 

func GetClusterRole(ctx context.Context, client TestClient, role string) (*v1.ClusterRole, error)

func GetClusterRoleBinding 

func GetClusterRoleBinding(ctx context.Context, client TestClient, rolebinding string) (*v1.ClusterRoleBinding, error)

func GetConfigmap 

func GetConfigmap(c clientset.Interface, ns, secretName string) (*v1.ConfigMap, error)

func GetDeployment 

func GetDeployment(c clientset.Interface, ns, name string) (*apps.Deployment, error)

func GetNamespace 

func GetNamespace(ctx context.Context, client TestClient, namespace string) (*corev1api.Namespace, error)

func GetPVByPodName added in v1.10.0 

func GetPVByPodName(client TestClient, namespace, podName string) (string, error)

func GetPVC added in v1.10.0 

func GetPVC(ctx context.Context, client TestClient, namespace string, pvcName string) (*corev1.PersistentVolumeClaim, error)

func GetPersistentVolume added in v1.9.0 

func GetPersistentVolume(ctx context.Context, client TestClient, namespace string, persistentVolume string) (*corev1.PersistentVolume, error)

func GetPod added in v1.10.0 

func GetPod(ctx context.Context, client TestClient, namespace string, pod string) (*corev1.Pod, error)

func GetPvByPvc added in v1.9.0 

func GetPvByPvc(ctx context.Context, namespace, pvc string) ([]string, error)

func GetPvcByPodName added in v1.9.0 

func GetPvcByPodName(ctx context.Context, namespace, podName string) ([]string, error)

func GetSecret 

func GetSecret(c clientset.Interface, ns, secretName string) (*v1.Secret, error)

func GetService added in v1.11.0 

func GetService(ctx context.Context, client TestClient, namespace string, service string) (*corev1.Service, error)

func GetServiceAccount 

func GetServiceAccount(ctx context.Context, client TestClient, namespace string, serviceAccount string) (*corev1.ServiceAccount, error)

func GetWorkerNodes added in v1.11.0 

func GetWorkerNodes(ctx context.Context) ([]string, error)

func InstallStorageClass added in v1.11.0 

func InstallStorageClass(ctx context.Context, yaml string) error

func KubectlApplyByFile added in v1.9.0 

func KubectlApplyByFile(ctx context.Context, file string) error

func KubectlConfigUseContext added in v1.10.0 

func KubectlConfigUseContext(ctx context.Context, kubectlContext string) error

func KubectlGetDsJson added in v1.10.0 

func KubectlGetDsJson(veleroNamespace string) (string, error)

func KubectlGetInfo added in v1.10.0 

func KubectlGetInfo(cmdName string, arg []string)

func NamespaceShouldNotExist added in v1.10.0 

func NamespaceShouldNotExist(ctx context.Context, client TestClient, namespace string) error

func NewDeployment 

func NewDeployment(name, ns string, replicas int32, labels map[string]string, containers []v1.Container) *apps.Deployment

newDeployment returns a RollingUpdate Deployment with a fake container image

func PatchServiceAccountWithImagePullSecret 

func PatchServiceAccountWithImagePullSecret(ctx context.Context, client TestClient, namespace, serviceAccount, dockerCredentialFile string) error

func ReadFileFromPodVolume added in v1.10.0 

func ReadFileFromPodVolume(ctx context.Context, namespace, podName, volume, filename string) (string, error)

func WaitAllSelectedNSDeleted 

func WaitAllSelectedNSDeleted(ctx context.Context, client TestClient, label string) error

func WaitForCRDEstablished added in v1.10.0 

func WaitForCRDEstablished(crdName string) error

func WaitForConfigMapComplete 

func WaitForConfigMapComplete(c clientset.Interface, ns, configmapName string) error

WaitForConfigMapComplete uses c to wait for completions to complete for the Job jobName in namespace ns.

func WaitForConfigmapDelete 

func WaitForConfigmapDelete(c clientset.Interface, ns, name string) error

func WaitForPods 

func WaitForPods(ctx context.Context, client TestClient, namespace string, pods []string) error

WaitForPods waits until all of the pods have gone to PodRunning state

func WaitForReadyDeployment 

func WaitForReadyDeployment(c clientset.Interface, ns, name string) error

WaitForReadyDeployment waits for number of ready replicas to equal number of replicas.

func WaitForSecretDelete 

func WaitForSecretDelete(c clientset.Interface, ns, name string) error

func WaitForSecretsComplete 

func WaitForSecretsComplete(c clientset.Interface, ns, secretName string) error

WaitForSecretsComplete uses c to wait for completions to complete for the Job jobName in namespace ns.

func WaitForServiceDelete added in v1.11.0 

func WaitForServiceDelete(client TestClient, ns, name string, deleteFirst bool) error

func WaitUntilServiceAccountCreated 

func WaitUntilServiceAccountCreated(ctx context.Context, client TestClient, namespace, serviceAccount string, timeout time.Duration) error

Types

type TestClient 

type TestClient struct {
	Kubebuilder kbclient.Client

	// clientGo returns a client-go API client.
	//
	// Deprecated, TODO(2.0): presuming all controllers and resources are converted to the
	// controller runtime framework by v2.0, it is the intent to remove all
	// client-go API clients. Please use the controller runtime to make API calls for tests.
	ClientGo kubernetes.Interface
	// contains filtered or unexported fields
}

func InitTestClient 

func InitTestClient(kubecontext string) (TestClient, error)

func NewTestClient 

func NewTestClient(kubecontext string) (TestClient, error)

NewTestClient returns a set of ready-to-use API clients.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.