Versions in this module Expand all Collapse all v1 v1.1.0 Mar 14, 2022 v1.0.0 Jun 3, 2021 v0 v0.9.0 Jun 23, 2020 Changes in this version + func GetLocalEndpointIPs(endpointsMap EndpointsMap) map[types.NamespacedName]sets.String + type BaseEndpointInfo struct + Endpoint string + IsLocal bool + func (info *BaseEndpointInfo) Equal(other Endpoint) bool + func (info *BaseEndpointInfo) GetIsLocal() bool + func (info *BaseEndpointInfo) IP() string + func (info *BaseEndpointInfo) Port() (int, error) + func (info *BaseEndpointInfo) String() string + type BaseServiceInfo struct + ClusterIP net.IP + ExternalIPs []string + HealthCheckNodePort int + LoadBalancerSourceRanges []string + LoadBalancerStatus v1.LoadBalancerStatus + NodePort int + OnlyNodeLocalEndpoints bool + Port int + Protocol v1.Protocol + SessionAffinityType v1.ServiceAffinity + StickyMaxAgeSeconds int + func (info *BaseServiceInfo) ClusterIPString() string + func (info *BaseServiceInfo) GetHealthCheckNodePort() int + func (info *BaseServiceInfo) GetProtocol() v1.Protocol + func (info *BaseServiceInfo) String() string + type Endpoint interface + Equal func(Endpoint) bool + GetIsLocal func() bool + IP func() string + Port func() (int, error) + String func() string + type EndpointChangeTracker struct + func NewEndpointChangeTracker(hostname string, makeEndpointInfo makeEndpointFunc, isIPv6Mode *bool, ...) *EndpointChangeTracker + func (ect *EndpointChangeTracker) Update(previous, current *v1.Endpoints) bool + type EndpointsMap map[ServicePortName][]Endpoint + func (em EndpointsMap) Merge(other EndpointsMap) + func (em EndpointsMap) Unmerge(other EndpointsMap) + type ProxyProvider interface + Sync func() + SyncLoop func() + type ServiceChangeTracker struct + func NewServiceChangeTracker(makeServiceInfo makeServicePortFunc, isIPv6Mode *bool, ...) *ServiceChangeTracker + func (sct *ServiceChangeTracker) Update(previous, current *v1.Service) bool + type ServiceEndpoint struct + Endpoint string + ServicePortName ServicePortName + type ServiceMap map[ServicePortName]ServicePort + type ServicePort interface + ClusterIPString func() string + GetHealthCheckNodePort func() int + GetProtocol func() v1.Protocol + String func() string + type ServicePortName struct + Port string + func (spn ServicePortName) String() string + type UpdateEndpointMapResult struct + HCEndpointsLocalIPSize map[types.NamespacedName]int + StaleEndpoints []ServiceEndpoint + StaleServiceNames []ServicePortName + func UpdateEndpointsMap(endpointsMap EndpointsMap, changes *EndpointChangeTracker) (result UpdateEndpointMapResult) + type UpdateServiceMapResult struct + HCServiceNodePorts map[types.NamespacedName]uint16 + UDPStaleClusterIP sets.String + func UpdateServiceMap(serviceMap ServiceMap, changes *ServiceChangeTracker) (result UpdateServiceMapResult)
Go to main page