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 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) func() *kapi.Pod

Functions

func NewPodWatch

func NewPodWatch(client kclient.Interface, namespace, name, resourceVersion string) func() *kapi.Pod

NewPodWatch creates a pod watching function which is backed by a FIFO/reflector pair. This avoids managing watches directly.

Types

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) 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) 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) func() *kapi.Pod