kubernetes

Documentation

Index

• func CurrentContext() (string, error)
• func GetClientset() (kubernetes.Interface, error)
• func IsRetryableAPIError(err error) bool
• func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error
• func WaitForDeploymentToStabilize(c kubernetes.Interface, ns, name string, timeout time.Duration) error
• func WaitForPodReady(pods corev1.PodInterface, podName string) 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
• func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, ...) error
• type LogAggregator
  • func NewLogAggregator(out io.Writer) *LogAggregator
  • func (a *LogAggregator) IsMuted() bool
  • func (a *LogAggregator) Mute()
  • func (a *LogAggregator) RegisterImage(image string, color int)
  • func (a *LogAggregator) Start(ctx context.Context, client corev1.CoreV1Interface) error
  • func (a *LogAggregator) Unmute()
• type PodStore
  • func NewPodStore(c kubernetes.Interface, namespace string, label labels.Selector, ...) *PodStore
  • func (s *PodStore) List() []*v1.Pod
  • func (s *PodStore) Stop()

Functions

func CurrentContext

func CurrentContext() (string, error)

func GetClientset

func GetClientset() (kubernetes.Interface, error)

func IsRetryableAPIError

func IsRetryableAPIError(err error) bool

func StartPods

func StartPods(c kubernetes.Interface, namespace string, pod v1.Pod, waitForRunning bool) error

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.

func WaitForPodReady

func WaitForPodReady(pods corev1.PodInterface, podName string) error

func WaitForPodsWithLabelRunning

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

Wait up to 10 minutes 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.

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)

func WaitForServiceEndpointsNum

func WaitForServiceEndpointsNum(c kubernetes.Interface, namespace, serviceName string, expectNum int, interval, timeout time.Duration) error

WaitForServiceEndpointsNum waits until the amount of endpoints that implement service to expectNum.

Types

type LogAggregator

type LogAggregator struct {
	// contains filtered or unexported fields
}

LogAggregator aggregates the logs for all the deployed pods.

func NewLogAggregator

func NewLogAggregator(out io.Writer) *LogAggregator

NewLogAggregator creates a new LogAggregator for a given output.

func (*LogAggregator) IsMuted

func (a *LogAggregator) IsMuted() bool

IsMuted says if the logs are to be muted.

func (*LogAggregator) Mute

func (a *LogAggregator) Mute()

Mute mutes the logs.

func (*LogAggregator) RegisterImage

func (a *LogAggregator) RegisterImage(image string, color int)

RegisterImage register an image for which pods need to be logged.

func (*LogAggregator) Start

func (a *LogAggregator) Start(ctx context.Context, client corev1.CoreV1Interface) error

func (*LogAggregator) Unmute

func (a *LogAggregator) Unmute()

Unmute unmute the logs.

type PodStore

type PodStore struct {
	cache.Store

	Reflector *cache.Reflector
	// contains filtered or unexported fields
}

func NewPodStore

func NewPodStore(c kubernetes.Interface, namespace string, label labels.Selector, field fields.Selector) *PodStore

nolint: interfacer

func (*PodStore) List

func (s *PodStore) List() []*v1.Pod

func (*PodStore) Stop

func (s *PodStore) Stop()