ingress

Documentation

Index

• Constants
• func UpdatePublishService(ingresses []*Ingress, api *kubernetes.Clientset, ...)
• type Ingress
  • func New(k store.K8s, resource *store.Ingress, class string, emptyClass bool) *Ingress
  • func (i *Ingress) HandleAnnotations(k store.K8s, cfg *configuration.ControllerCfg)
  • func (i *Ingress) Update(k store.K8s, cfg *configuration.ControllerCfg, api api.HAProxyClient) (reload bool)
  • func (i *Ingress) UpdateStatus(client *kubernetes.Clientset, addresses []string) (err error)
• type Sync
• type UpdateStatus
  • func NewStatusIngressUpdater(client *kubernetes.Clientset, k store.K8s, class string, emptyClass bool) UpdateStatus

Constants

const CONTROLLER = "haproxy.org/ingress-controller"

Functions

func UpdatePublishService

func UpdatePublishService(ingresses []*Ingress, api *kubernetes.Clientset, publishServiceAddresses []string)

Types

type Ingress

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

func New

func New(k store.K8s, resource *store.Ingress, class string, emptyClass bool) *Ingress

New returns an Ingress instance to handle the k8s ingress resource given in params. If the k8s ingress resource is not assigned to the controller (no matching IngressClass) then New will return nil

func (*Ingress) HandleAnnotations

func (i *Ingress) HandleAnnotations(k store.K8s, cfg *configuration.ControllerCfg)

HandleAnnotations processes ingress annotations to create HAProxy Rules and constructs corresponding list of RuleIDs. If Ingress Annotations are at the ConfigMap scope, HAProxy Rules will be applied globally without the need to map Rule IDs to specific ingress traffic.

func (*Ingress) Update

func (i *Ingress) Update(k store.K8s, cfg *configuration.ControllerCfg, api api.HAProxyClient) (reload bool)

Update processes a Kubernetes ingress resource and configures HAProxy accordingly by creating corresponding backend, route and HTTP rules.

func (*Ingress) UpdateStatus

func (i *Ingress) UpdateStatus(client *kubernetes.Clientset, addresses []string) (err error)

type Sync

type Sync struct {
	Service *corev1.Service
	Ingress *store.Ingress
}

type UpdateStatus

type UpdateStatus func(service store.Service, ingresses []*store.Ingress)

func NewStatusIngressUpdater

func NewStatusIngressUpdater(client *kubernetes.Clientset, k store.K8s, class string, emptyClass bool) UpdateStatus