support

Documentation

Overview

Package support is a library of code useful to any strategy.

Index

• func NewPodWatch(client kclient.Interface, namespace, name, resourceVersion string, ...) func() *kapi.Pod
• type FirstContainerReady
  • func NewFirstContainerReady(kclient kclient.Interface, timeout time.Duration, interval time.Duration) *FirstContainerReady
  • func (c *FirstContainerReady) Accept(deployment *kapi.ReplicationController) error
• type HookExecutor
  • func (e *HookExecutor) Execute(hook *deployapi.LifecycleHook, deployment *kapi.ReplicationController, ...) error
• type HookExecutorPodClient
• type HookExecutorPodClientImpl
  • func (i *HookExecutorPodClientImpl) CreatePod(namespace string, pod *kapi.Pod) (*kapi.Pod, error)
  • func (i *HookExecutorPodClientImpl) PodWatch(namespace, name, resourceVersion string, stopChannel chan struct{}) func() *kapi.Pod

Functions

func NewPodWatch

func NewPodWatch(client kclient.Interface, namespace, name, resourceVersion string, stopChannel chan struct{}) func() *kapi.Pod

NewPodWatch creates a pod watching function which is backed by a FIFO/reflector pair. This avoids managing watches directly. A stop channel to close the watch's reflector is also returned. It is the caller's responsibility to defer closing the stop channel to prevent leaking resources.

Types

type FirstContainerReady

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

func NewFirstContainerReady

func NewFirstContainerReady(kclient kclient.Interface, timeout time.Duration, interval time.Duration) *FirstContainerReady

func (*FirstContainerReady) Accept

func (c *FirstContainerReady) Accept(deployment *kapi.ReplicationController) error

type HookExecutor

type HookExecutor struct {
	// PodClient provides access to pods.
	PodClient HookExecutorPodClient
}

HookExecutor executes a deployment lifecycle hook.

func (*HookExecutor) Execute

func (e *HookExecutor) Execute(hook *deployapi.LifecycleHook, deployment *kapi.ReplicationController, label string) error

Execute executes hook in the context of deployment. The label is used to distinguish the kind of hook (e.g. pre, post).

type HookExecutorPodClient

type HookExecutorPodClient interface {
	CreatePod(namespace string, pod *kapi.Pod) (*kapi.Pod, error)
	PodWatch(namespace, name, resourceVersion string, stopChannel chan struct{}) func() *kapi.Pod
}

HookExecutorPodClient abstracts access to pods.

type HookExecutorPodClientImpl

type HookExecutorPodClientImpl struct {
	CreatePodFunc func(namespace string, pod *kapi.Pod) (*kapi.Pod, error)
	PodWatchFunc  func(namespace, name, resourceVersion string, stopChannel chan struct{}) func() *kapi.Pod
}

HookExecutorPodClientImpl is a pluggable HookExecutorPodClient.

func (*HookExecutorPodClientImpl) CreatePod

func (i *HookExecutorPodClientImpl) CreatePod(namespace string, pod *kapi.Pod) (*kapi.Pod, error)

func (*HookExecutorPodClientImpl) PodWatch

func (i *HookExecutorPodClientImpl) PodWatch(namespace, name, resourceVersion string, stopChannel chan struct{}) func() *kapi.Pod