kubernetes

Documentation

Index

• func HasKubernetesFileExtension(n string) bool
• func IsKubernetesManifest(file string) bool
• func ParseImagesFromKubernetesYaml(filepath string) ([]string, error)
• func TopLevelOwnerKey(ctx context.Context, obj metav1.Object, kind string) string
• func WaitForDeploymentToStabilize(ctx context.Context, c kubernetes.Interface, ns, name string, ...) error
• func WaitForPodInitialized(ctx context.Context, pods corev1.PodInterface, podName string) error
• func WaitForPodSucceeded(ctx context.Context, pods corev1.PodInterface, podName string, ...) error
• type ColorPicker
  • func NewColorPicker() ColorPicker
• type ImageList
  • func NewImageList() *ImageList
  • func (l *ImageList) Add(image string)
  • func (l *ImageList) Select(pod *v1.Pod) bool
• type PodEvent
• type PodSelector
• type PodWatcher
  • func NewPodWatcher(podSelector PodSelector) PodWatcher

Functions

func HasKubernetesFileExtension

func HasKubernetesFileExtension(n string) bool

HasKubernetesFileExtension is for determining if a file under a glob pattern is deployable file format. It makes no attempt to check whether or not the file is actually deployable or has the correct contents.

func IsKubernetesManifest

func IsKubernetesManifest(file string) bool

IsKubernetesManifest is for determining if a file is a valid Kubernetes manifest

func ParseImagesFromKubernetesYaml

func ParseImagesFromKubernetesYaml(filepath string) ([]string, error)

ParseImagesFromKubernetesYaml parses the kubernetes yamls, and if it finds at least one valid Kubernetes object, it will return the images referenced in them.

func TopLevelOwnerKey

func TopLevelOwnerKey(ctx context.Context, obj metav1.Object, kind string) string

TopLevelOwnerKey returns a key associated with the top level owner of a Kubernetes resource in the form Kind-Name

func WaitForDeploymentToStabilize

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

WaitForDeploymentToStabilize waits until the Deployment has a matching generation/replica count between spec and status.

func WaitForPodInitialized

func WaitForPodInitialized(ctx context.Context, pods corev1.PodInterface, podName string) error

WaitForPodInitialized waits until init containers have started running

func WaitForPodSucceeded

func WaitForPodSucceeded(ctx context.Context, pods corev1.PodInterface, podName string, timeout time.Duration) error

WaitForPodSucceeded waits until the Pod status is Succeeded.

Types

type ColorPicker

type ColorPicker interface {
	Pick(pod *v1.Pod) color.Color
	AddImage(image string)
}

ColorPicker is used to associate colors for with pods so that the container logs can be output to the terminal with a consistent color being used to identify logs from each pod.

func NewColorPicker

func NewColorPicker() ColorPicker

NewColorPicker creates a new ColorPicker. For each artifact, a color will be selected sequentially from `colorCodes`. If all colors are used, the first color will be used again. The formatter for the associated color will then be returned by `Pick` each time it is called for the artifact and can be used to write to out in that color.

type ImageList

type ImageList struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ImageList implements PodSelector based on a list of images names.

func NewImageList

func NewImageList() *ImageList

NewImageList creates a new ImageList.

func (*ImageList) Add

func (l *ImageList) Add(image string)

Add adds an image to the list.

func (*ImageList) Select

func (l *ImageList) Select(pod *v1.Pod) bool

Select returns true if one of the pod's images is in the list.

type PodEvent

type PodEvent struct {
	Type watch.EventType
	Pod  *v1.Pod
}

type PodSelector

type PodSelector interface {
	Select(pod *v1.Pod) bool
}

PodSelector is used to choose which pods to log.

type PodWatcher

type PodWatcher interface {
	Register(receiver chan<- PodEvent)
	Start(ns []string) (func(), error)
}

func NewPodWatcher

func NewPodWatcher(podSelector PodSelector) PodWatcher