controller

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: May 8, 2018 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ErrExecHook          = "ErrExecHook"
	ReasonProcessStarted = "ProcessStarted"
	ReasonPhaseComplete  = "ExecHook"

	MessageErrExecHook    = "Error executing hook: %s"
	MessageProcessStarted = "Subprocess %q started"
	MessagePhaseComplete  = "Completed phase %q"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Controller

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

func NewController

func NewController(opts Options) *Controller

func (*Controller) IsPeer

func (g *Controller) IsPeer(pilot *v1alpha1.Pilot) (bool, error)

func (*Controller) IsThisPilot

func (g *Controller) IsThisPilot(pilot *v1alpha1.Pilot) bool

IsThisPilot will return true if 'pilot' corresponds to the Pilot resource for this pilot.

func (*Controller) Run

func (g *Controller) Run(stopCh <-chan struct{}) error

func (*Controller) ThisPilot

func (g *Controller) ThisPilot() (*v1alpha1.Pilot, error)

ThisPilot will return a reference to 'this' Pilot resource. The returned resource may or may not be up to date, and it may or may not still exist in the target API server.

func (*Controller) WaitForCacheSync

func (g *Controller) WaitForCacheSync(stopCh <-chan struct{}) error

type Options

type Options struct {
	PilotName, PilotNamespace string
	SyncFunc                  func(*v1alpha1.Pilot) error
	KubeClientset             kubernetes.Interface
	Clientset                 clientset.Interface
	PilotInformer             informersv1alpha1.PilotInformer
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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