k8s

package

Go to main page

Versions in this module

v0

v0.13.206

Mar 8, 2019

v0.13.205

Mar 6, 2019

v0.13.204

Mar 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 CreateServiceAccount(t *testing.T, options *KubectlOptions, serviceAccountName string)

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

+ func GetAvailablePort(t *testing.T) int

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

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

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

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

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

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

+ func GetRoleE(t *testing.T, options *KubectlOptions, roleName string) (*rbacv1.Role, 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 GetServiceAccountAuthToken(t *testing.T, kubectlOptions *KubectlOptions, serviceAccountName string) string

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

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

+ func IsPodAvailable(pod *corev1.Pod) bool

+ 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 UpsertConfigContext(config *api.Config, contextName string, clusterName string, userName string)

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

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

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

+ func WaitUntilPodAvailableE(t *testing.T, options *KubectlOptions, podName string, retries int, ...) 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 PodNotAvailable struct

+ func NewPodNotAvailableError(pod *corev1.Pod) PodNotAvailable

+ func (err PodNotAvailable) Error() string

+ type ServiceAccountTokenNotAvailable struct

+ Name string

+ func (err ServiceAccountTokenNotAvailable) Error() string

+ 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

v0.13.201

Jan 11, 2019

v0.13.20

Dec 19, 2018

v0.13.19

Dec 18, 2018

v0.13.18

Dec 14, 2018

v0.13.17

Dec 13, 2018

v0.13.16

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

v0.13.15

Dec 6, 2018

v0.13.14

Nov 30, 2018

Changes in this version

+ func KubeConfigPathFromHomeDirE() (string, error)

v0.13.13

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL