controller

Documentation

Index

• type LoadBalancerController
  • func NewLoadBalancerController(ctx *context.ControllerContext, stopCh chan struct{}) *LoadBalancerController
  • func (lbc *LoadBalancerController) EnsureDeleteV1Finalizers(toCleanup []*v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) EnsureDeleteV2Finalizer(ing *v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) GCBackends(toKeep []*v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) GCv1LoadBalancers(toKeep []*v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) GCv2LoadBalancer(ing *v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) Init()
  • func (lbc *LoadBalancerController) PostProcess(state interface{}) error
  • func (lbc *LoadBalancerController) Run()
  • func (lbc *LoadBalancerController) Stop(deleteAll bool) error
  • func (lbc *LoadBalancerController) SyncBackends(state interface{}) error
  • func (lbc *LoadBalancerController) SyncLoadBalancer(state interface{}) error
  • func (lbc *LoadBalancerController) ToSvcPorts(ings []*v1beta1.Ingress) []utils.ServicePort
• type NodeController
  • func NewNodeController(ctx *context.ControllerContext, instancePool instances.NodePool) *NodeController
  • func (c *NodeController) Run()
  • func (c *NodeController) Shutdown()

Types

type LoadBalancerController

type LoadBalancerController struct {
	Translator *legacytranslator.Translator
	// contains filtered or unexported fields
}

LoadBalancerController watches the kubernetes api and adds/removes services from the loadbalancer, via loadBalancerConfig.

func NewLoadBalancerController

func NewLoadBalancerController(
	ctx *context.ControllerContext,
	stopCh chan struct{}) *LoadBalancerController

NewLoadBalancerController creates a controller for gce loadbalancers.

func (*LoadBalancerController) EnsureDeleteV1Finalizers

func (lbc *LoadBalancerController) EnsureDeleteV1Finalizers(toCleanup []*v1beta1.Ingress) error

EnsureDeleteV1Finalizers implements Controller.

func (*LoadBalancerController) EnsureDeleteV2Finalizer

func (lbc *LoadBalancerController) EnsureDeleteV2Finalizer(ing *v1beta1.Ingress) error

EnsureDeleteV2Finalizer implements Controller.

func (*LoadBalancerController) GCBackends

func (lbc *LoadBalancerController) GCBackends(toKeep []*v1beta1.Ingress) error

GCBackends implements Controller.

func (*LoadBalancerController) GCv1LoadBalancers

func (lbc *LoadBalancerController) GCv1LoadBalancers(toKeep []*v1beta1.Ingress) error

GCv1LoadBalancers implements Controller.

func (*LoadBalancerController) GCv2LoadBalancer

func (lbc *LoadBalancerController) GCv2LoadBalancer(ing *v1beta1.Ingress) error

GCv2LoadBalancer implements Controller.

func (*LoadBalancerController) Init

func (lbc *LoadBalancerController) Init()

Init the controller.

func (*LoadBalancerController) PostProcess

func (lbc *LoadBalancerController) PostProcess(state interface{}) error

PostProcess implements Controller.

func (*LoadBalancerController) Run

func (lbc *LoadBalancerController) Run()

Run starts the loadbalancer controller.

func (*LoadBalancerController) Stop

func (lbc *LoadBalancerController) Stop(deleteAll bool) error

Stop stops the loadbalancer controller. It also deletes cluster resources if deleteAll is true.

func (*LoadBalancerController) SyncBackends

func (lbc *LoadBalancerController) SyncBackends(state interface{}) error

SyncBackends implements Controller.

func (*LoadBalancerController) SyncLoadBalancer

func (lbc *LoadBalancerController) SyncLoadBalancer(state interface{}) error

SyncLoadBalancer implements Controller.

func (*LoadBalancerController) ToSvcPorts

func (lbc *LoadBalancerController) ToSvcPorts(ings []*v1beta1.Ingress) []utils.ServicePort

ToSvcPorts returns a list of SVC ports given a list of ingresses. Note: This method is used for GC.

type NodeController

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

NodeController synchronizes the state of the nodes to the unmanaged instance groups.

func NewNodeController

func NewNodeController(ctx *context.ControllerContext, instancePool instances.NodePool) *NodeController

NewNodeController returns a new node update controller.

func (*NodeController) Run

func (c *NodeController) Run()

Run the queue to process updates for the controller. This must be run in a separate goroutine (method will block until queue shutdown).

func (*NodeController) Shutdown

func (c *NodeController) Shutdown()

Shutdown shuts down the goroutine that processes node updates.