Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 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") + type LoadBalancer interface + CleanupStaleStickySessions func(service proxy.ServicePortName) + DeleteService func(service proxy.ServicePortName) + NewService func(service proxy.ServicePortName, sessionAffinityType v1.ServiceAffinity, ...) error + NextEndpoint func(service proxy.ServicePortName, srcAddr net.Addr, sessionAffinityReset bool) (string, error) + type LoadBalancerRR struct + func NewLoadBalancerRR() *LoadBalancerRR + func (lb *LoadBalancerRR) CleanupStaleStickySessions(svcPort proxy.ServicePortName) + func (lb *LoadBalancerRR) DeleteService(svcPort proxy.ServicePortName) + func (lb *LoadBalancerRR) NewService(svcPort proxy.ServicePortName, affinityType v1.ServiceAffinity, ttlSeconds int) error + func (lb *LoadBalancerRR) NextEndpoint(svcPort proxy.ServicePortName, srcAddr net.Addr, sessionAffinityReset bool) (string, error) + func (lb *LoadBalancerRR) OnEndpointsAdd(endpoints *v1.Endpoints) + func (lb *LoadBalancerRR) OnEndpointsDelete(endpoints *v1.Endpoints) + func (lb *LoadBalancerRR) OnEndpointsSynced() + func (lb *LoadBalancerRR) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints) + type Proxier struct + func NewProxier(loadBalancer LoadBalancer, listenIP net.IP, netsh netsh.Interface, ...) (*Proxier, error) + func (proxier *Proxier) OnEndpointsAdd(endpoints *v1.Endpoints) + func (proxier *Proxier) OnEndpointsDelete(endpoints *v1.Endpoints) + func (proxier *Proxier) OnEndpointsSynced() + func (proxier *Proxier) OnEndpointsUpdate(oldEndpoints, endpoints *v1.Endpoints) + func (proxier *Proxier) OnServiceAdd(service *v1.Service) + func (proxier *Proxier) OnServiceDelete(service *v1.Service) + func (proxier *Proxier) OnServiceSynced() + func (proxier *Proxier) OnServiceUpdate(oldService, service *v1.Service) + func (proxier *Proxier) Sync() + func (proxier *Proxier) SyncLoop() + type ServicePortPortalName struct + Port string + PortalIPName string + func (spn ServicePortPortalName) String() string
Go to main page