controller

Documentation

Index

• func NewTaskQueue(syncFn func(string)) *taskQueue
• type LoadBalancerController
  • func NewLoadBalancerController(kubeClient *client.Client, resyncPeriod time.Duration, namespace string, ...) (*LoadBalancerController, error)
  • func (lbc *LoadBalancerController) Run()
• type StoreToConfigMapLister
  • func (s *StoreToConfigMapLister) List() (cfgm api.ConfigMapList, err error)
• type StoreToIngressLister
  • func (s *StoreToIngressLister) GetServiceIngress(svc *api.Service) (ings []extensions.Ingress, err error)
  • func (s *StoreToIngressLister) List() (ing extensions.IngressList, err error)

Functions

func NewTaskQueue

func NewTaskQueue(syncFn func(string)) *taskQueue

NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.

Types

type LoadBalancerController

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

LoadBalancerController watches Kubernetes API and reconfigures NGINX via NginxController when needed

func NewLoadBalancerController

func NewLoadBalancerController(kubeClient *client.Client, resyncPeriod time.Duration, namespace string, cnf *nginx.Configurator, nginxConfigMaps string) (*LoadBalancerController, error)

NewLoadBalancerController creates a controller

func (*LoadBalancerController) Run

func (lbc *LoadBalancerController) Run()

Run starts the loadbalancer controller

type StoreToConfigMapLister

type StoreToConfigMapLister struct {
	cache.Store
}

StoreToConfigMapLister makes a Store that lists ConfigMaps

func (*StoreToConfigMapLister) List

func (s *StoreToConfigMapLister) List() (cfgm api.ConfigMapList, err error)

List lists all Ingress' in the store.

type StoreToIngressLister

type StoreToIngressLister struct {
	cache.Store
}

StoreToIngressLister makes a Store that lists Ingress. TODO: Move this to cache/listers post 1.1.

func (*StoreToIngressLister) GetServiceIngress

func (s *StoreToIngressLister) GetServiceIngress(svc *api.Service) (ings []extensions.Ingress, err error)

GetServiceIngress gets all the Ingress' that have rules pointing to a service. Note that this ignores services without the right nodePorts.

func (*StoreToIngressLister) List

func (s *StoreToIngressLister) List() (ing extensions.IngressList, err error)

List lists all Ingress' in the store.