Versions in this module Expand all Collapse all v1 v1.0.0 Oct 28, 2020 Changes in this version + func AddConfigContextForServiceAccountE(t testing.TestingT, kubectlOptions *KubectlOptions, contextName string, ...) error + func AreAllNodesReady(t testing.TestingT, options *KubectlOptions) bool + func AreAllNodesReadyE(t testing.TestingT, options *KubectlOptions) (bool, error) + func CanIDo(t testing.TestingT, options *KubectlOptions, action authv1.ResourceAttributes) bool + func CanIDoE(t testing.TestingT, options *KubectlOptions, action authv1.ResourceAttributes) (bool, error) + func CopyHomeKubeConfigToTemp(t testing.TestingT) string + func CopyHomeKubeConfigToTempE(t testing.TestingT) (string, error) + func CreateNamespace(t testing.TestingT, options *KubectlOptions, namespaceName string) + func CreateNamespaceE(t testing.TestingT, options *KubectlOptions, namespaceName string) error + func CreateServiceAccount(t testing.TestingT, options *KubectlOptions, serviceAccountName string) + func CreateServiceAccountE(t testing.TestingT, options *KubectlOptions, serviceAccountName string) error + func DeleteConfigContextE(t testing.TestingT, contextName string) error + func DeleteConfigContextWithPathE(t testing.TestingT, kubeConfigPath string, contextName string) error + func DeleteNamespace(t testing.TestingT, options *KubectlOptions, namespaceName string) + func DeleteNamespaceE(t testing.TestingT, options *KubectlOptions, namespaceName string) error + func FindNodeHostnameE(t testing.TestingT, node corev1.Node) (string, error) + func FindNodePortE(service *corev1.Service, servicePort int32) (int32, error) + func GetAvailablePort(t testing.TestingT) int + func GetAvailablePortE(t testing.TestingT) (int, error) + func GetClusterRole(t testing.TestingT, options *KubectlOptions, roleName string) *rbacv1.ClusterRole + func GetClusterRoleE(t testing.TestingT, options *KubectlOptions, roleName string) (*rbacv1.ClusterRole, error) + func GetDaemonSet(t testing.TestingT, options *KubectlOptions, daemonSetName string) *appsv1.DaemonSet + func GetDaemonSetE(t testing.TestingT, options *KubectlOptions, daemonSetName string) (*appsv1.DaemonSet, error) + func GetIngress(t testing.TestingT, options *KubectlOptions, ingressName string) *extensionsv1beta1.Ingress + func GetIngressE(t testing.TestingT, options *KubectlOptions, ingressName string) (*extensionsv1beta1.Ingress, error) + func GetKubeConfigPathE(t testing.TestingT) (string, error) + func GetKubernetesClientE(t testing.TestingT) (*kubernetes.Clientset, error) + func GetKubernetesClientFromOptionsE(t testing.TestingT, options *KubectlOptions) (*kubernetes.Clientset, error) + func GetNamespace(t testing.TestingT, options *KubectlOptions, namespaceName string) *corev1.Namespace + func GetNamespaceE(t testing.TestingT, options *KubectlOptions, namespaceName string) (*corev1.Namespace, error) + func GetNodes(t testing.TestingT, options *KubectlOptions) []corev1.Node + func GetNodesByFilterE(t testing.TestingT, options *KubectlOptions, filter metav1.ListOptions) ([]corev1.Node, error) + func GetNodesE(t testing.TestingT, options *KubectlOptions) ([]corev1.Node, error) + func GetPod(t testing.TestingT, options *KubectlOptions, podName string) *corev1.Pod + func GetPodE(t testing.TestingT, options *KubectlOptions, podName string) (*corev1.Pod, error) + func GetReadyNodes(t testing.TestingT, options *KubectlOptions) []corev1.Node + func GetReadyNodesE(t testing.TestingT, options *KubectlOptions) ([]corev1.Node, error) + func GetRole(t testing.TestingT, options *KubectlOptions, roleName string) *rbacv1.Role + func GetRoleE(t testing.TestingT, options *KubectlOptions, roleName string) (*rbacv1.Role, error) + func GetSecret(t testing.TestingT, options *KubectlOptions, secretName string) *corev1.Secret + func GetSecretE(t testing.TestingT, options *KubectlOptions, secretName string) (*corev1.Secret, error) + func GetService(t testing.TestingT, options *KubectlOptions, serviceName string) *corev1.Service + func GetServiceAccount(t testing.TestingT, options *KubectlOptions, serviceAccountName string) *corev1.ServiceAccount + func GetServiceAccountAuthToken(t testing.TestingT, kubectlOptions *KubectlOptions, serviceAccountName string) string + func GetServiceAccountAuthTokenE(t testing.TestingT, kubectlOptions *KubectlOptions, serviceAccountName string) (string, error) + func GetServiceAccountE(t testing.TestingT, options *KubectlOptions, serviceAccountName string) (*corev1.ServiceAccount, error) + func GetServiceE(t testing.TestingT, options *KubectlOptions, serviceName string) (*corev1.Service, error) + func GetServiceEndpoint(t testing.TestingT, options *KubectlOptions, service *corev1.Service, ...) string + func GetServiceEndpointE(t testing.TestingT, options *KubectlOptions, service *corev1.Service, ...) (string, error) + func IsIngressAvailable(ingress *extensionsv1beta1.Ingress) bool + func IsMinikubeE(t testing.TestingT, options *KubectlOptions) (bool, error) + func IsNodeReady(node corev1.Node) bool + func IsPodAvailable(pod *corev1.Pod) bool + func IsServiceAvailable(service *corev1.Service) bool + func KubeConfigPathFromHomeDirE() (string, error) + func KubectlApply(t testing.TestingT, options *KubectlOptions, configPath string) + func KubectlApplyE(t testing.TestingT, options *KubectlOptions, configPath string) error + func KubectlApplyFromString(t testing.TestingT, options *KubectlOptions, configData string) + func KubectlApplyFromStringE(t testing.TestingT, options *KubectlOptions, configData string) error + func KubectlDelete(t testing.TestingT, options *KubectlOptions, configPath string) + func KubectlDeleteE(t testing.TestingT, options *KubectlOptions, configPath string) error + func KubectlDeleteFromString(t testing.TestingT, options *KubectlOptions, configData string) + func KubectlDeleteFromStringE(t testing.TestingT, options *KubectlOptions, configData string) error + func ListDaemonSets(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) []appsv1.DaemonSet + func ListDaemonSetsE(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) ([]appsv1.DaemonSet, error) + func ListIngresses(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) []extensionsv1beta1.Ingress + func ListIngressesE(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) ([]extensionsv1beta1.Ingress, error) + func ListPods(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) []corev1.Pod + func ListPodsE(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) ([]corev1.Pod, error) + func ListServices(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) []corev1.Service + func ListServicesE(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions) ([]corev1.Service, error) + func LoadApiClientConfigE(configPath string, contextName string) (*restclient.Config, error) + func LoadConfigFromPath(path string) clientcmd.ClientConfig + func RemoveOrphanedClusterAndAuthInfoConfig(config *api.Config) + func RunKubectl(t testing.TestingT, options *KubectlOptions, args ...string) + func RunKubectlAndGetOutputE(t testing.TestingT, options *KubectlOptions, args ...string) (string, error) + func RunKubectlE(t testing.TestingT, options *KubectlOptions, args ...string) error + func StoreConfigToTempFile(t testing.TestingT, configData string) string + func StoreConfigToTempFileE(t testing.TestingT, configData string) (string, error) + func UpsertConfigContext(config *api.Config, contextName string, clusterName string, userName string) + func WaitUntilAllNodesReady(t testing.TestingT, options *KubectlOptions, retries int, ...) + func WaitUntilAllNodesReadyE(t testing.TestingT, options *KubectlOptions, retries int, ...) error + func WaitUntilIngressAvailable(t testing.TestingT, options *KubectlOptions, ingressName string, retries int, ...) + func WaitUntilNumPodsCreated(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions, ...) + func WaitUntilNumPodsCreatedE(t testing.TestingT, options *KubectlOptions, filters metav1.ListOptions, ...) error + func WaitUntilPodAvailable(t testing.TestingT, options *KubectlOptions, podName string, retries int, ...) + func WaitUntilPodAvailableE(t testing.TestingT, options *KubectlOptions, podName string, retries int, ...) error + func WaitUntilServiceAvailable(t testing.TestingT, options *KubectlOptions, serviceName string, retries int, ...) + type DesiredNumberOfPodsNotCreated struct + DesiredCount int + Filter metav1.ListOptions + func (err DesiredNumberOfPodsNotCreated) Error() string + type IngressNotAvailable struct + func (err IngressNotAvailable) Error() string + type KubeResourceType int + const ResourceTypePod + const ResourceTypeService + func (resourceType KubeResourceType) String() string + type KubectlOptions struct + ConfigPath string + ContextName string + Env map[string]string + Namespace string + func NewKubectlOptions(contextName string, configPath string, namespace string) *KubectlOptions + func (kubectlOptions *KubectlOptions) GetConfigPath(t testing.TestingT) (string, error) + type MalformedNodeID struct + func NewMalformedNodeIDError(node *corev1.Node) MalformedNodeID + func (err MalformedNodeID) Error() string + type NoNodesInKubernetes struct + func NewNoNodesInKubernetesError() NoNodesInKubernetes + func (err NoNodesInKubernetes) Error() string + type NodeHasNoHostname struct + func NewNodeHasNoHostnameError(node *corev1.Node) NodeHasNoHostname + func (err NodeHasNoHostname) Error() string + type PodNotAvailable struct + func NewPodNotAvailableError(pod *corev1.Pod) PodNotAvailable + func (err PodNotAvailable) Error() string + type ServiceAccountTokenNotAvailable struct + Name string + func (err ServiceAccountTokenNotAvailable) Error() string + type ServiceNotAvailable struct + func NewServiceNotAvailableError(service *corev1.Service) ServiceNotAvailable + func (err ServiceNotAvailable) Error() string + type Tunnel struct + func NewTunnel(kubectlOptions *KubectlOptions, resourceType KubeResourceType, ...) *Tunnel + func NewTunnelWithLogger(kubectlOptions *KubectlOptions, resourceType KubeResourceType, ...) *Tunnel + func (tunnel *Tunnel) Close() + func (tunnel *Tunnel) Endpoint() string + func (tunnel *Tunnel) ForwardPort(t testing.TestingT) + func (tunnel *Tunnel) ForwardPortE(t testing.TestingT) error + type UnknownKubeResourceType struct + ResourceType KubeResourceType + func (err UnknownKubeResourceType) Error() string + type UnknownServicePort struct + func NewUnknownServicePortError(service *corev1.Service, port int32) UnknownServicePort + func (err UnknownServicePort) Error() string + type UnknownServiceType struct + func NewUnknownServiceTypeError(service *corev1.Service) UnknownServiceType + func (err UnknownServiceType) Error() string
Go to main page