init

Documentation

Index

• func CRDManifests() ([]string, error)
• func CRDs() []runtime.Object
• func GetKUDOPodImage(client corev1.PodsGetter, namespace string) (string, error)
• func Install(client *kube.Client, opts Options, crdOnly bool) error
• func InstanceCrd() *apiextv1beta1.CustomResourceDefinition
• func ManagerManifests(opts Options) ([]string, error)
• func Prereq(opts Options) []runtime.Object
• func PrereqManifests(opts Options) ([]string, error)
• func WatchKUDOUntilReady(client kubernetes.Interface, opts Options, timeout int64) bool
• type Options
  • func NewOptions(v string) Options

Functions

func CRDManifests

func CRDManifests() ([]string, error)

CRDManifests provides a slice of strings for each CRD manifest

func CRDs

func CRDs() []runtime.Object

CRDs returns the slice of crd objects for KUDO

func GetKUDOPodImage

func GetKUDOPodImage(client corev1.PodsGetter, namespace string) (string, error)

GetKUDOPodImage fetches the image of KUDO pod running in the given namespace.

func Install

func Install(client *kube.Client, opts Options, crdOnly bool) error

Install uses Kubernetes client to install KUDO.

func InstanceCrd

func InstanceCrd() *apiextv1beta1.CustomResourceDefinition

InstanceCrd provides the Instance CRD manifest for printing

func ManagerManifests

func ManagerManifests(opts Options) ([]string, error)

ManagerManifests provides a slice of strings for the deployment and service manifest

func Prereq

func Prereq(opts Options) []runtime.Object

Prereq returns the slice of prerequisite objects for KUDO

func PrereqManifests

func PrereqManifests(opts Options) ([]string, error)

PrereqManifests provides a slice of strings for each pre requisite manifest

func WatchKUDOUntilReady

func WatchKUDOUntilReady(client kubernetes.Interface, opts Options, timeout int64) bool

WatchKUDOUntilReady waits for the KUDO pod to become available.

Returns true if it exists. If the timeout was reached and it could not find the pod, it returns false.

Types

type Options

type Options struct {
	// Version is the version of the manager `0.5.0` for example (must NOT include the `v` in `v0.5.0`)
	Version string
	// namespace to init into (default is kudo-system)
	Namespace string
	// TerminationGracePeriodSeconds defines the termination grace period for a pod
	TerminationGracePeriodSeconds int64
	// Image defines the image to be used
	Image string
}

Options is the configurable options to init

func NewOptions

func NewOptions(v string) Options

NewOptions provides an option struct with defaults