Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 2015 Changes in this version + var ErrMissingEndpoints = errors.New("missing endpoints") + var ErrMissingServiceEntry = errors.New("missing service entry") + var ErrProxyOnLocalhost = fmt.Errorf("cannot proxy on localhost") + func IsProxyLocked(err error) bool + type LoadBalancer interface + CleanupStaleStickySessions func(service ServicePortName) + NewService func(service ServicePortName, sessionAffinityType api.ServiceAffinity, ...) error + NextEndpoint func(service ServicePortName, srcAddr net.Addr) (string, error) + type LoadBalancerRR struct + func NewLoadBalancerRR() *LoadBalancerRR + func (lb *LoadBalancerRR) CleanupStaleStickySessions(svcPort ServicePortName) + func (lb *LoadBalancerRR) NewService(svcPort ServicePortName, affinityType api.ServiceAffinity, ttlMinutes int) error + func (lb *LoadBalancerRR) NextEndpoint(svcPort ServicePortName, srcAddr net.Addr) (string, error) + func (lb *LoadBalancerRR) OnUpdate(allEndpoints []api.Endpoints) + type PortAllocator interface + AllocateNext func() (int, error) + Release func(int) + type Proxier struct + func NewProxier(loadBalancer LoadBalancer, listenIP net.IP, iptables iptables.Interface, ...) (*Proxier, error) + func (proxier *Proxier) OnUpdate(services []api.Service) + func (proxier *Proxier) SyncLoop() + type ServicePortName struct + Port string + func (spn ServicePortName) String() string
Go to main page