kapi

Documentation

Index

• Variables
• func Client(context string) (*kubernetes.Clientset, error)
• func ClientConfig(context string) (*rest.Config, error)
• func IsRetryableAPIError(err error) bool
• func KubectlBinaryPath(version string) string
• func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error
• func WaitForPods(c kubernetes.Interface, ns string, selector string, timeOut ...time.Duration) error
• func WaitForRCToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error
• func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, ...) error

Variables

var (
	// ReasonableMutateTime is how long to wait for basic object mutations, such as deletions, to show up
	ReasonableMutateTime = time.Minute * 2
	// ReasonableStartTime is how long to wait for pods to start
	ReasonableStartTime = time.Minute * 5
)

Functions

func Client

func Client(context string) (*kubernetes.Clientset, error)

Client gets the Kubernetes client for a kubectl context name

func ClientConfig

func ClientConfig(context string) (*rest.Config, error)

ClientConfig returns the client configuration for a kubectl context

func IsRetryableAPIError

func IsRetryableAPIError(err error) bool

IsRetryableAPIError returns if this error is retryable or not

func KubectlBinaryPath

func KubectlBinaryPath(version string) string

KubectlBinaryPath returns the path to kubectl on the node

func WaitForDeploymentToStabilize

func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForDeploymentToStabilize waits till the Deployment has a matching generation/replica count between spec and status. used by integration tests

func WaitForPods

func WaitForPods(c kubernetes.Interface, ns string, selector string, timeOut ...time.Duration) error

WaitForPods waits for all matching pods to become Running or finish successfully and at least one matching pod exists.

func WaitForRCToStabilize

func WaitForRCToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error

WaitForRCToStabilize waits till the RC has a matching generation/replica count between spec and status. used by integration tests

func WaitForService

func WaitForService(c kubernetes.Interface, namespace, name string, exist bool, interval, timeout time.Duration) error

WaitForService waits until the service appears (exist == true), or disappears (exist == false)