k8s

Apr 9, 2019

Changes in this version

+ func GetIngress(t *testing.T, options *KubectlOptions, ingressName string) *extensionsv1beta1.Ingress

+ func GetIngressE(t *testing.T, options *KubectlOptions, ingressName string) (*extensionsv1beta1.Ingress, error)

+ func IsIngressAvailable(ingress *extensionsv1beta1.Ingress) bool

+ func ListIngresses(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) []extensionsv1beta1.Ingress

+ func ListIngressesE(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) ([]extensionsv1beta1.Ingress, error)

+ func WaitUntilIngressAvailable(t *testing.T, options *KubectlOptions, ingressName string, retries int, ...)

+ type IngressNotAvailable struct

+ func (err IngressNotAvailable) Error() string

Mar 1, 2019

Changes in this version

+ func GetClusterRole(t *testing.T, options *KubectlOptions, roleName string) *rbacv1.ClusterRole

+ func GetClusterRoleE(t *testing.T, options *KubectlOptions, roleName string) (*rbacv1.ClusterRole, error)

+ func GetRole(t *testing.T, options *KubectlOptions, roleName string) *rbacv1.Role

+ func GetRoleE(t *testing.T, options *KubectlOptions, roleName string) (*rbacv1.Role, error)

Feb 20, 2019

Changes in this version

+ func GetAvailablePort(t *testing.T) int

+ func GetAvailablePortE(t *testing.T) (int, error)

+ func ListPods(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) []corev1.Pod

+ func ListPodsE(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) ([]corev1.Pod, error)

+ func ListServices(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) []corev1.Service

+ func ListServicesE(t *testing.T, options *KubectlOptions, filters metav1.ListOptions) ([]corev1.Service, error)

+ func WaitUntilNumPodsCreated(t *testing.T, options *KubectlOptions, filters metav1.ListOptions, ...)

+ func WaitUntilNumPodsCreatedE(t *testing.T, options *KubectlOptions, filters metav1.ListOptions, ...) error

+ type DesiredNumberOfPodsNotCreated struct

+ DesiredCount int

+ Filter metav1.ListOptions

+ func (err DesiredNumberOfPodsNotCreated) Error() string

+ type KubeResourceType int

+ const ResourceTypePod

+ const ResourceTypeService

+ func (resourceType KubeResourceType) String() string

type KubectlOptions

+ func (kubectlOptions *KubectlOptions) GetConfigPath(t *testing.T) (string, error)

+ type Tunnel struct

+ func NewTunnel(kubectlOptions *KubectlOptions, resourceType KubeResourceType, ...) *Tunnel

+ func (tunnel *Tunnel) Close()

+ func (tunnel *Tunnel) Endpoint() string

+ func (tunnel *Tunnel) ForwardPort(t *testing.T)

+ func (tunnel *Tunnel) ForwardPortE(t *testing.T) error

+ type UnknownKubeResourceType struct

+ ResourceType KubeResourceType

+ func (err UnknownKubeResourceType) Error() string

Feb 5, 2019

Changes in this version

+ func AddConfigContextForServiceAccountE(t *testing.T, kubectlOptions *KubectlOptions, contextName string, ...) error

+ func CanIDo(t *testing.T, options *KubectlOptions, action authv1.ResourceAttributes) bool

+ func CanIDoE(t *testing.T, options *KubectlOptions, action authv1.ResourceAttributes) (bool, error)

+ func CopyHomeKubeConfigToTemp(t *testing.T) string

+ func CopyHomeKubeConfigToTempE(t *testing.T) (string, error)

+ func GetServiceAccountAuthToken(t *testing.T, kubectlOptions *KubectlOptions, serviceAccountName string) string

+ func GetServiceAccountAuthTokenE(t *testing.T, kubectlOptions *KubectlOptions, serviceAccountName string) (string, error)

+ func UpsertConfigContext(config *api.Config, contextName string, clusterName string, userName string)

+ type ServiceAccountTokenNotAvailable struct

+ Name string

+ func (err ServiceAccountTokenNotAvailable) Error() string

Jan 17, 2019

Changes in this version

+ func CreateServiceAccount(t *testing.T, options *KubectlOptions, serviceAccountName string)

+ func CreateServiceAccountE(t *testing.T, options *KubectlOptions, serviceAccountName string) error

+ func GetSecret(t *testing.T, options *KubectlOptions, secretName string) *corev1.Secret

+ func GetSecretE(t *testing.T, options *KubectlOptions, secretName string) (*corev1.Secret, error)

+ func GetServiceAccount(t *testing.T, options *KubectlOptions, serviceAccountName string) *corev1.ServiceAccount

+ func GetServiceAccountE(t *testing.T, options *KubectlOptions, serviceAccountName string) (*corev1.ServiceAccount, error)

Jan 11, 2019

Changes in this version

+ func GetPod(t *testing.T, options *KubectlOptions, podName string) *corev1.Pod

+ func GetPodE(t *testing.T, options *KubectlOptions, podName string) (*corev1.Pod, error)

+ func IsPodAvailable(pod *corev1.Pod) bool

+ func WaitUntilPodAvailable(t *testing.T, options *KubectlOptions, podName string, retries int, ...)

+ func WaitUntilPodAvailableE(t *testing.T, options *KubectlOptions, podName string, retries int, ...) error

+ type PodNotAvailable struct

+ func NewPodNotAvailableError(pod *corev1.Pod) PodNotAvailable

+ func (err PodNotAvailable) Error() string

Dec 12, 2018

Changes in this version

+ func CreateNamespace(t *testing.T, options *KubectlOptions, namespaceName string)

+ func CreateNamespaceE(t *testing.T, options *KubectlOptions, namespaceName string) error

+ func DeleteNamespace(t *testing.T, options *KubectlOptions, namespaceName string)

+ func DeleteNamespaceE(t *testing.T, options *KubectlOptions, namespaceName string) error

+ func GetKubernetesClientFromOptionsE(t *testing.T, options *KubectlOptions) (*kubernetes.Clientset, error)

+ func GetNamespace(t *testing.T, options *KubectlOptions, namespaceName string) corev1.Namespace

+ func GetNamespaceE(t *testing.T, options *KubectlOptions, namespaceName string) (corev1.Namespace, error)

+ func GetService(t *testing.T, options *KubectlOptions, serviceName string) *corev1.Service

+ func GetServiceE(t *testing.T, options *KubectlOptions, serviceName string) (*corev1.Service, error)

+ func GetServiceEndpoint(t *testing.T, service *corev1.Service, servicePort int) string

+ func GetServiceEndpointE(t *testing.T, service *corev1.Service, servicePort int) (string, error)

+ func IsServiceAvailable(service *corev1.Service) bool

+ func KubectlApply(t *testing.T, options *KubectlOptions, configPath string)

+ func KubectlApplyE(t *testing.T, options *KubectlOptions, configPath string) error

+ func KubectlApplyFromString(t *testing.T, options *KubectlOptions, configData string)

+ func KubectlApplyFromStringE(t *testing.T, options *KubectlOptions, configData string) error

+ func KubectlDelete(t *testing.T, options *KubectlOptions, configPath string)

+ func KubectlDeleteE(t *testing.T, options *KubectlOptions, configPath string) error

+ func KubectlDeleteFromString(t *testing.T, options *KubectlOptions, configData string)

+ func KubectlDeleteFromStringE(t *testing.T, options *KubectlOptions, configData string) error

+ func LoadApiClientConfigE(configPath string, contextName string) (*restclient.Config, error)

+ func RunKubectl(t *testing.T, options *KubectlOptions, args ...string)

+ func RunKubectlAndGetOutputE(t *testing.T, options *KubectlOptions, args ...string) (string, error)

+ func RunKubectlE(t *testing.T, options *KubectlOptions, args ...string) error

+ func StoreConfigToTempFile(t *testing.T, configData string) string

+ func StoreConfigToTempFileE(t *testing.T, configData string) (string, error)

+ func WaitUntilServiceAvailable(t *testing.T, options *KubectlOptions, serviceName string, retries int, ...)

+ type KubectlOptions struct

+ ConfigPath string

+ ContextName string

+ Env map[string]string

+ Namespace string

+ func NewKubectlOptions(contextName string, configPath string) *KubectlOptions

+ 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 ServiceNotAvailable struct

+ func NewServiceNotAvailableError(service *corev1.Service) ServiceNotAvailable

+ func (err ServiceNotAvailable) 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

Nov 30, 2018

Changes in this version

+ func KubeConfigPathFromHomeDirE() (string, error)

Nov 11, 2018

Changes in this version

+ func AreAllNodesReady(t *testing.T) bool

+ func AreAllNodesReadyE(t *testing.T) (bool, error)

+ func DeleteConfigContextE(t *testing.T, contextName string) error

+ func DeleteConfigContextWithPathE(t *testing.T, kubeConfigPath string, contextName string) error

+ func GetKubeConfigPathE(t *testing.T) (string, error)

+ func GetKubernetesClientE(t *testing.T) (*kubernetes.Clientset, error)

+ func GetNodes(t *testing.T) []corev1.Node

+ func GetNodesE(t *testing.T) ([]corev1.Node, error)

+ func GetReadyNodes(t *testing.T) []corev1.Node

+ func GetReadyNodesE(t *testing.T) ([]corev1.Node, error)

+ func IsNodeReady(node corev1.Node) bool

+ func LoadConfigFromPath(path string) clientcmd.ClientConfig

+ func RemoveOrphanedClusterAndAuthInfoConfig(config *api.Config)

+ func WaitUntilAllNodesReady(t *testing.T, retries int, sleepBetweenRetries time.Duration)

+ func WaitUntilAllNodesReadyE(t *testing.T, retries int, sleepBetweenRetries time.Duration) error