controller

Documentation

Index

• type LoadBalancerController
  • func NewLoadBalancerController(ctx *context.ControllerContext, stopCh chan struct{}) *LoadBalancerController
  • func (lbc *LoadBalancerController) GCBackends(toKeep []*v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) GCLoadBalancers(toKeep []*v1beta1.Ingress) error
  • func (lbc *LoadBalancerController) Init()
  • func (lbc *LoadBalancerController) MaybeRemoveFinalizers(toCleanup []*v1beta1.Ingress) error
  • 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 *translator.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) GCBackends

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

GCBackends implements Controller.

func (*LoadBalancerController) GCLoadBalancers

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

GCLoadBalancers implements Controller.

func (*LoadBalancerController) Init

func (lbc *LoadBalancerController) Init()

func (*LoadBalancerController) MaybeRemoveFinalizers

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

MaybeRemoveFinalizers cleans up Finalizers if needed.

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 owned by this controller 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 a goroutine to process updates for the controller.

func (*NodeController) Shutdown

func (c *NodeController) Shutdown()

Shutdown shuts down the goroutine that processes node updates.