ingress

Documentation

Index

• Constants
• func HandleCfgMapAnnotations(k store.K8s, h haproxy.HAProxy, a annotations.Annotations)
• 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) Update(k store.K8s, h haproxy.HAProxy, a annotations.Annotations) (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 HandleCfgMapAnnotations

func HandleCfgMapAnnotations(k store.K8s, h haproxy.HAProxy, a annotations.Annotations)

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, a annotations.Annotations) *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) Update

func (i *Ingress) Update(k store.K8s, h haproxy.HAProxy, a annotations.Annotations) (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(ingresses []*store.Ingress, publishServiceAddresses []string)

func NewStatusIngressUpdater

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