Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + const DefaultDummyDevice + const DefaultScheduler + const EntryInvalidErr + const KubeFireWallChain + const KubeForwardChain + const KubeLoadBalancerChain + const KubeMarkDropChain + const KubeMarkMasqChain + const KubeNodePortChain + const MinIPSetCheckVersion + func CanUseIPVSProxier(handle KernelHandler, ipsetver IPSetVersioner) (bool, error) + func CleanupLeftovers(ipvs utilipvs.Interface, ipt utiliptables.Interface, ipset utilipset.Interface, ...) (encounteredError bool) + func GetUniqueRSName(vs *utilipvs.VirtualServer, rs *utilipvs.RealServer) string + func NewDualStackProxier(ipt [2]utiliptables.Interface, ipvs utilipvs.Interface, ...) (proxy.Provider, error) + func NewMetaProxier(ipv4Proxier, ipv6Proxier proxy.Provider) proxy.Provider + type GracefulTerminationManager struct + func NewGracefulTerminationManager(ipvs utilipvs.Interface) *GracefulTerminationManager + func (m *GracefulTerminationManager) GracefulDeleteRS(vs *utilipvs.VirtualServer, rs *utilipvs.RealServer) error + func (m *GracefulTerminationManager) InTerminationList(uniqueRS string) bool + func (m *GracefulTerminationManager) MoveRSOutofGracefulDeleteList(uniqueRS string) error + func (m *GracefulTerminationManager) Run() + type IPGetter interface + NodeIPs func() ([]net.IP, error) + type IPSet struct + func NewIPSet(handle utilipset.Interface, name string, setType utilipset.Type, isIPv6 bool, ...) *IPSet + type IPSetVersioner interface + GetVersion func() (string, error) + type KernelHandler interface + GetKernelVersion func() (string, error) + GetModules func() ([]string, error) + type LinuxKernelHandler struct + func NewLinuxKernelHandler() *LinuxKernelHandler + func (handle *LinuxKernelHandler) GetKernelVersion() (string, error) + func (handle *LinuxKernelHandler) GetModules() ([]string, error) + type NetLinkHandle interface + DeleteDummyDevice func(devName string) error + EnsureAddressBind func(address, devName string) (exist bool, err error) + EnsureDummyDevice func(devName string) (exist bool, err error) + GetLocalAddresses func(dev, filterDev string) (sets.String, error) + ListBindAddress func(devName string) ([]string, error) + UnbindAddress func(address, devName string) error + func NewNetLinkHandle(ipv6 bool) NetLinkHandle + func NewNetLinkHandle(isIPv6 bool) NetLinkHandle + type Proxier struct + func NewProxier(ipt utiliptables.Interface, ipvs utilipvs.Interface, ipset utilipset.Interface, ...) (*Proxier, error) + func (proxier *Proxier) OnEndpointSliceAdd(endpointSlice *discovery.EndpointSlice) + func (proxier *Proxier) OnEndpointSliceDelete(endpointSlice *discovery.EndpointSlice) + func (proxier *Proxier) OnEndpointSliceUpdate(_, endpointSlice *discovery.EndpointSlice) + func (proxier *Proxier) OnEndpointSlicesSynced() + 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()
Go to main page