controller

Documentation

Index

• Constants
• type Controller
  • func NewController(opts Options) *Controller
  • func (g *Controller) IsPeer(pilot *v1alpha1.Pilot) (bool, error)
  • func (g *Controller) IsThisPilot(pilot *v1alpha1.Pilot) bool
  • func (g *Controller) Run(stopCh <-chan struct{}) error
  • func (g *Controller) ThisPilot() (*v1alpha1.Pilot, error)
  • func (g *Controller) WaitForCacheSync(stopCh <-chan struct{}) error
• type Options

Constants

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

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

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
}