structured

Documentation

Index

• func ClusterRbacIsFound(kubeClientset kubernetes.Interface, resourceType, name string) error
• func DaemonSetIsRunning(kubeClientset kubernetes.Interface, expBackoff wait.Backoff, ...) error
• func DeploymentIsRunning(kubeClientset kubernetes.Interface, name, namespace string) error
• func GetDaemonSet(kubeClientset kubernetes.Interface, name, namespace string) (*appsv1.DaemonSet, error)
• func GetDeployment(kubeClientset kubernetes.Interface, name, namespace string) (*appsv1.Deployment, error)
• func GetIngress(kubeClientset kubernetes.Interface, name, namespace string) (*networkingv1.Ingress, error)
• func GetIngressEndpoint(kubeClientset kubernetes.Interface, w common.WaiterConfig, ...) (string, error)
• func GetNodeList(kubeClientset kubernetes.Interface) (*corev1.NodeList, error)
• func GetPersistentVolume(kubeClientset kubernetes.Interface, name string) (*corev1.PersistentVolume, error)
• func GetPersistentVolumeList(kubeClientset kubernetes.Interface) (*corev1.PersistentVolumeList, error)
• func GetStatefulSetList(kubeClientset kubernetes.Interface, namespace string) (*appsv1.StatefulSetList, error)
• func IngressAvailable(kubeClientset kubernetes.Interface, w common.WaiterConfig, ...) error
• func ListNodes(kubeClientset kubernetes.Interface) error
• func NodesWithSelectorShouldBe(kubeClientset kubernetes.Interface, w common.WaiterConfig, expectedNodes int, ...) error
• func PersistentVolExists(kubeClientset kubernetes.Interface, name, expectedPhase string) error
• func ResourceInNamespace(kubeClientset kubernetes.Interface, resourceType, name, namespace string) error
• func ResourceNotInNamespace(kubeClientset kubernetes.Interface, resourceType, name, namespace string) error
• func ScaleDeployment(kubeClientset kubernetes.Interface, name, namespace string, replicas int32) error
• func SecretDelete(kubeClientset kubernetes.Interface, name, namespace string) error
• func SecretOperationFromEnvironmentVariable(kubeClientset kubernetes.Interface, ...) error
• func SendTrafficToIngress(kubeClientset kubernetes.Interface, w common.WaiterConfig, tps int, ...) error
• func ValidatePrometheusVolumeClaimTemplatesName(kubeClientset kubernetes.Interface, ...) error

Functions

func ClusterRbacIsFound

func ClusterRbacIsFound(kubeClientset kubernetes.Interface, resourceType, name string) error

func DaemonSetIsRunning

func DaemonSetIsRunning(kubeClientset kubernetes.Interface, expBackoff wait.Backoff, name, namespace string) error

func DeploymentIsRunning

func DeploymentIsRunning(kubeClientset kubernetes.Interface, name, namespace string) error

func GetDaemonSet

func GetDaemonSet(kubeClientset kubernetes.Interface, name, namespace string) (*appsv1.DaemonSet, error)

func GetDeployment

func GetDeployment(kubeClientset kubernetes.Interface, name, namespace string) (*appsv1.Deployment, error)

func GetIngress

func GetIngress(kubeClientset kubernetes.Interface, name, namespace string) (*networkingv1.Ingress, error)

func GetIngressEndpoint

func GetIngressEndpoint(kubeClientset kubernetes.Interface, w common.WaiterConfig, name, namespace string, port int, path string) (string, error)

TODO: remove use of service.beta.kubernetes.io/aws-load-balancer-subnets or make generic

func GetNodeList

func GetNodeList(kubeClientset kubernetes.Interface) (*corev1.NodeList, error)

func GetPersistentVolume

func GetPersistentVolume(kubeClientset kubernetes.Interface, name string) (*corev1.PersistentVolume, error)

func GetPersistentVolumeList

func GetPersistentVolumeList(kubeClientset kubernetes.Interface) (*corev1.PersistentVolumeList, error)

func GetStatefulSetList

func GetStatefulSetList(kubeClientset kubernetes.Interface, namespace string) (*appsv1.StatefulSetList, error)

func IngressAvailable

func IngressAvailable(kubeClientset kubernetes.Interface, w common.WaiterConfig, name, namespace string, port int, path string) error

func ListNodes

func ListNodes(kubeClientset kubernetes.Interface) error

func NodesWithSelectorShouldBe

func NodesWithSelectorShouldBe(kubeClientset kubernetes.Interface, w common.WaiterConfig, expectedNodes int, labelSelector, state string) error

func PersistentVolExists

func PersistentVolExists(kubeClientset kubernetes.Interface, name, expectedPhase string) error

func ResourceInNamespace

func ResourceInNamespace(kubeClientset kubernetes.Interface, resourceType, name, namespace string) error

func ResourceNotInNamespace

func ResourceNotInNamespace(kubeClientset kubernetes.Interface, resourceType, name, namespace string) error

func ScaleDeployment

func ScaleDeployment(kubeClientset kubernetes.Interface, name, namespace string, replicas int32) error

func SecretDelete

func SecretDelete(kubeClientset kubernetes.Interface, name, namespace string) error

func SecretOperationFromEnvironmentVariable

func SecretOperationFromEnvironmentVariable(kubeClientset kubernetes.Interface, operation, name, namespace, environmentVariable string) error

func SendTrafficToIngress

func SendTrafficToIngress(kubeClientset kubernetes.Interface, w common.WaiterConfig, tps int, name, namespace string, port int, path string, duration int, durationUnits string, expectedErrors int) error

func ValidatePrometheusVolumeClaimTemplatesName

func ValidatePrometheusVolumeClaimTemplatesName(kubeClientset kubernetes.Interface, statefulsetName, namespace, volumeClaimTemplatesName string) error