haproxy

package

v0.3.0 Latest Latest Go to latest Published: Mar 16, 2016 License: Apache-2.0 Imports: 16 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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(syncPeriod time.Duration, kubeClient *kubeclient.Client, disableHyperInternalService bool) (*Proxier, error)

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

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

OnEndpointsUpdate takes in a slice of updated endpoints.

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

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

func (proxier *Proxier) Sync()

Sync is called to immediately synchronize the proxier state to iptables

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.