kapi

Documentation

Index

• Variables
• func Client(context string) (*kubernetes.Clientset, error)
• func ClientConfig(context string) (*rest.Config, error)
• func IsRetryableAPIError(err error) bool
• func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error
• func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector, ...) 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 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 WaitForPodsWithLabelRunning

func WaitForPodsWithLabelRunning(c kubernetes.Interface, ns string, label labels.Selector, timeOut ...time.Duration) error

WaitForPodsWithLabelRunning waits for all matching pods to become Running 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)