hookexecutor

Documentation

Index

• Variables
• func FromJson(json []byte) (runtime.Object, error)
• func FromYaml(yaml []byte) (runtime.Object, error)
• func Watch(watcher watch.Interface, desiredStateChecker func(runtime.Object) bool, ...) (bool, error)
• type Decode
• type Executor
  • func PostInstallExecutor(kubeClient kubernetes.Interface) Executor
  • func PreDeleteExecutor(kubeClient kubernetes.Interface) Executor
  • func SanityExecutor(kubeClient kubernetes.Interface) Executor

Variables

var KubeDecoder *decoder = &decoder{decode: kubescheme.Codecs.UniversalDeserializer().Decode}

Functions

func FromJson

func FromJson(json []byte) (runtime.Object, error)

func FromYaml

func FromYaml(yaml []byte) (runtime.Object, error)

func Watch

func Watch(watcher watch.Interface, desiredStateChecker func(runtime.Object) bool, timeout ...time.Duration) (bool, error)

desiredStateChecker: check if the resource meet the desired state, if it is nil, means that the caller expects the resource to be deleted.

Types

type Decode

type Decode func(data []byte, defaults *schema.GroupVersionKind, into runtime.Object) (runtime.Object, *schema.GroupVersionKind, error)

type Executor

type Executor interface {
	Execute() error
}

func PostInstallExecutor

func PostInstallExecutor(kubeClient kubernetes.Interface) Executor

func PreDeleteExecutor

func PreDeleteExecutor(kubeClient kubernetes.Interface) Executor

func SanityExecutor

func SanityExecutor(kubeClient kubernetes.Interface) Executor