hookexecutor

package
v2.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2019 License: Apache-2.0 Imports: 21 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL