kube

Documentation

Index

• func EnsureNamespaceExistsAndIsReady(namespace *corev1api.Namespace, client corev1client.NamespaceInterface, ...) (bool, bool, error)
• func GetSecret(client kbclient.Client, namespace, name string) (*corev1api.Secret, error)
• func GetSecretKey(client kbclient.Client, namespace string, ...) ([]byte, error)
• func GetVolumeDirectory(pod *corev1api.Pod, volumeName string, ...) (string, error)
• func IsCRDReady(crd *unstructured.Unstructured) (bool, error)
• func IsV1Beta1CRDReady(crd *apiextv1beta1.CustomResourceDefinition) bool
• func IsV1CRDReady(crd *apiextv1.CustomResourceDefinition) bool
• func NamespaceAndName(objMeta metav1.Object) string
• func ParseResourceRequirements(cpuRequest, memRequest, cpuLimit, memLimit string) (corev1.ResourceRequirements, error)
• func ParseSecurityContext(runAsUser string, runAsGroup string, allowPrivilegeEscalation string) (corev1.SecurityContext, error)

Functions

func EnsureNamespaceExistsAndIsReady

func EnsureNamespaceExistsAndIsReady(namespace *corev1api.Namespace, client corev1client.NamespaceInterface, timeout time.Duration) (bool, bool, error)

EnsureNamespaceExistsAndIsReady attempts to create the provided Kubernetes namespace. It returns three values: a bool indicating whether or not the namespace is ready, a bool indicating whether or not the namespace was created and an error if the creation failed for a reason other than that the namespace already exists. Note that in the case where the namespace already exists and is not ready, this function will return (false, false, nil). If the namespace exists and is marked for deletion, this function will wait up to the timeout for it to fully delete.

func GetSecret

func GetSecret(client kbclient.Client, namespace, name string) (*corev1api.Secret, error)

func GetSecretKey

func GetSecretKey(client kbclient.Client, namespace string, selector *corev1api.SecretKeySelector) ([]byte, error)

func GetVolumeDirectory

func GetVolumeDirectory(pod *corev1api.Pod, volumeName string, pvcLister corev1listers.PersistentVolumeClaimLister, pvLister corev1listers.PersistentVolumeLister) (string, error)

GetVolumeDirectory gets the name of the directory on the host, under /var/lib/kubelet/pods/<podUID>/volumes/, where the specified volume lives. For volumes with a CSIVolumeSource, append "/mount" to the directory name.

func IsCRDReady

func IsCRDReady(crd *unstructured.Unstructured) (bool, error)

IsCRDReady triggers IsV1Beta1CRDReady/IsV1CRDReady according to the version of the input param

func IsV1Beta1CRDReady

func IsV1Beta1CRDReady(crd *apiextv1beta1.CustomResourceDefinition) bool

IsV1Beta1CRDReady checks a v1beta1 CRD to see if it's ready, with both the Established and NamesAccepted conditions.

func IsV1CRDReady

func IsV1CRDReady(crd *apiextv1.CustomResourceDefinition) bool

IsV1CRDReady checks a v1 CRD to see if it's ready, with both the Established and NamesAccepted conditions.

func NamespaceAndName

func NamespaceAndName(objMeta metav1.Object) string

NamespaceAndName returns a string in the format <namespace>/<name>

func ParseResourceRequirements

func ParseResourceRequirements(cpuRequest, memRequest, cpuLimit, memLimit string) (corev1.ResourceRequirements, error)

ParseResourceRequirements takes a set of CPU and memory requests and limit string values and returns a ResourceRequirements struct to be used in a Container. An error is returned if we cannot parse the request/limit.

func ParseSecurityContext

func ParseSecurityContext(runAsUser string, runAsGroup string, allowPrivilegeEscalation string) (corev1.SecurityContext, error)