controller

Documentation

Index

• Constants
• func Execute()
• func NewEventController(client kubernetes.Interface) cache.Controller
• func NewPodController(client kubernetes.Interface) cache.Controller
• func RegisterController(name string, fn ControllerBuilder)
• func Stop()
• type ControllerBuilder
• type EventController
  • func (ec *EventController) HasSynced() bool
  • func (ec *EventController) LastSyncResourceVersion() string
  • func (ec *EventController) OnAdd(obj interface{})
  • func (ec *EventController) OnDelete(obj interface{})
  • func (ec *EventController) OnUpdate(oldObj, newObj interface{})
  • func (ec *EventController) Run(stopCh <-chan struct{})
• type PodController
  • func (pc *PodController) HasSynced() bool
  • func (pc *PodController) LastSyncResourceVersion() string
  • func (pc *PodController) OnAdd(obj interface{})
  • func (pc *PodController) OnDelete(obj interface{})
  • func (pc *PodController) OnUpdate(_, newObj interface{})
  • func (pc *PodController) Run(stopCh <-chan struct{})

Constants

const DefaultResyncPeriod = 0

const MaxRetries = 5

Functions

func Execute

func Execute()

func NewEventController

func NewEventController(client kubernetes.Interface) cache.Controller

func NewPodController

func NewPodController(client kubernetes.Interface) cache.Controller

func RegisterController

func RegisterController(name string, fn ControllerBuilder)

func Stop

func Stop()

Types

type ControllerBuilder

type ControllerBuilder func(client kubernetes.Interface) cache.Controller

type EventController

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

func (*EventController) HasSynced

func (ec *EventController) HasSynced() bool

func (*EventController) LastSyncResourceVersion

func (ec *EventController) LastSyncResourceVersion() string

func (*EventController) OnAdd

func (ec *EventController) OnAdd(obj interface{})

func (*EventController) OnDelete

func (ec *EventController) OnDelete(obj interface{})

func (*EventController) OnUpdate

func (ec *EventController) OnUpdate(oldObj, newObj interface{})

func (*EventController) Run

func (ec *EventController) Run(stopCh <-chan struct{})

type PodController

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

func (*PodController) HasSynced

func (pc *PodController) HasSynced() bool

func (*PodController) LastSyncResourceVersion

func (pc *PodController) LastSyncResourceVersion() string

func (*PodController) OnAdd

func (pc *PodController) OnAdd(obj interface{})

func (*PodController) OnDelete

func (pc *PodController) OnDelete(obj interface{})

func (*PodController) OnUpdate

func (pc *PodController) OnUpdate(_, newObj interface{})

func (*PodController) Run

func (pc *PodController) Run(stopCh <-chan struct{})