haproxy

Documentation

Index

• type Proxier
  • func NewProxier(syncPeriod time.Duration, kubeClient *kubeclient.Client, ...) (*Proxier, error)
  • func (proxier *Proxier) OnEndpointsUpdate(allEndpoints []api.Endpoints)
  • func (proxier *Proxier) OnServiceUpdate(allServices []api.Service)
  • func (proxier *Proxier) Sync()
  • func (proxier *Proxier) SyncLoop()

Types

type Proxier

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

Proxier is an pod-buildin-haproxy proxy for connections between a localhost:lport and services that provide the actual backends.

func NewProxier

func NewProxier(syncPeriod time.Duration, kubeClient *kubeclient.Client, disableHyperInternalService bool) (*Proxier, error)

NewProxier returns a new Proxier given an pod-buildin-haproxy Interface instance.

func (*Proxier) OnEndpointsUpdate

func (proxier *Proxier) OnEndpointsUpdate(allEndpoints []api.Endpoints)

OnEndpointsUpdate takes in a slice of updated endpoints.

func (*Proxier) OnServiceUpdate

func (proxier *Proxier) OnServiceUpdate(allServices []api.Service)

OnServiceUpdate tracks the active set of service proxies. They will be synchronized using syncProxyRules()

func (*Proxier) Sync

func (proxier *Proxier) Sync()

Sync is called to immediately synchronize the proxier state to iptables

func (*Proxier) SyncLoop

func (proxier *Proxier) SyncLoop()

SyncLoop runs periodic work. This is expected to run as a goroutine or as the main loop of the app. It does not return.