controller

Documentation

Index

• type LoadBalancerController
  • func NewLoadBalancerController(ctx *context.ControllerContext, stopCh <-chan struct{}, logger klog.Logger) *LoadBalancerController
  • func (lbc *LoadBalancerController) EnsureDeleteV1Finalizers(toCleanup []*v1.Ingress, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) EnsureDeleteV2Finalizer(ing *v1.Ingress, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) GCBackends(toKeep []*v1.Ingress, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) GCv1LoadBalancers(toKeep []*v1.Ingress) error
  • func (lbc *LoadBalancerController) GCv2LoadBalancer(ing *v1.Ingress, scope meta.KeyType) error
  • func (lbc *LoadBalancerController) PostProcess(state interface{}, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) Run()
  • func (lbc *LoadBalancerController) Stop()
  • func (lbc *LoadBalancerController) SyncBackends(state interface{}, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) SyncLoadBalancer(state interface{}, ingLogger klog.Logger) error
  • func (lbc *LoadBalancerController) ToSvcPorts(ings []*v1.Ingress) []utils.ServicePort

Types

type LoadBalancerController

type LoadBalancerController struct {
	Translator *legacytranslator.Translator

	ZoneGetter *zonegetter.ZoneGetter
	// 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{},
	logger klog.Logger,
) *LoadBalancerController

NewLoadBalancerController creates a controller for gce loadbalancers.

func (*LoadBalancerController) EnsureDeleteV1Finalizers

func (lbc *LoadBalancerController) EnsureDeleteV1Finalizers(toCleanup []*v1.Ingress, ingLogger klog.Logger) error

EnsureDeleteV1Finalizers implements Controller.

func (*LoadBalancerController) EnsureDeleteV2Finalizer

func (lbc *LoadBalancerController) EnsureDeleteV2Finalizer(ing *v1.Ingress, ingLogger klog.Logger) error

EnsureDeleteV2Finalizer implements Controller.

func (*LoadBalancerController) GCBackends

func (lbc *LoadBalancerController) GCBackends(toKeep []*v1.Ingress, ingLogger klog.Logger) error

GCBackends implements Controller.

func (*LoadBalancerController) GCv1LoadBalancers

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

GCv1LoadBalancers implements Controller.

func (*LoadBalancerController) GCv2LoadBalancer

func (lbc *LoadBalancerController) GCv2LoadBalancer(ing *v1.Ingress, scope meta.KeyType) error

GCv2LoadBalancer implements Controller.

func (*LoadBalancerController) PostProcess

func (lbc *LoadBalancerController) PostProcess(state interface{}, ingLogger klog.Logger) error

PostProcess implements Controller.

func (*LoadBalancerController) Run

func (lbc *LoadBalancerController) Run()

Run starts the loadbalancer controller.

func (*LoadBalancerController) Stop

func (lbc *LoadBalancerController) Stop()

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

func (*LoadBalancerController) SyncBackends

func (lbc *LoadBalancerController) SyncBackends(state interface{}, ingLogger klog.Logger) error

SyncBackends implements Controller.

func (*LoadBalancerController) SyncLoadBalancer

func (lbc *LoadBalancerController) SyncLoadBalancer(state interface{}, ingLogger klog.Logger) error

SyncLoadBalancer implements Controller.

func (*LoadBalancerController) ToSvcPorts

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

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