Versions in this module Expand all Collapse all v1 v1.16.3 Nov 9, 2022 Changes in this version + 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 + func (info *BaseServiceInfo) ClusterIP() net.IP + func (info *BaseServiceInfo) ExternalIPStrings() []string + func (info *BaseServiceInfo) HealthCheckNodePort() int + func (info *BaseServiceInfo) LoadBalancerIPStrings() []string + func (info *BaseServiceInfo) LoadBalancerSourceRanges() []string + func (info *BaseServiceInfo) NodePort() int + func (info *BaseServiceInfo) OnlyNodeLocalEndpoints() bool + func (info *BaseServiceInfo) Port() int + func (info *BaseServiceInfo) Protocol() v1.Protocol + func (info *BaseServiceInfo) SessionAffinityType() v1.ServiceAffinity + func (info *BaseServiceInfo) StickyMaxAgeSeconds() int + 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) EndpointSliceUpdate(endpointSlice *discovery.EndpointSlice, removeSlice bool) bool + func (ect *EndpointChangeTracker) Update(previous, current *v1.Endpoints) bool + type EndpointSliceCache struct + func NewEndpointSliceCache(hostname string, isIPv6Mode *bool, recorder record.EventRecorder, ...) *EndpointSliceCache + func (cache *EndpointSliceCache) Delete(endpointSlice *discovery.EndpointSlice) + func (cache *EndpointSliceCache) EndpointsMap(serviceNN types.NamespacedName) EndpointsMap + func (cache *EndpointSliceCache) Update(endpointSlice *discovery.EndpointSlice) + type EndpointsMap map[ServicePortName][]Endpoint + func (em EndpointsMap) Update(changes *EndpointChangeTracker) (result UpdateEndpointMapResult) + type Provider 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 + ClusterIP func() net.IP + ExternalIPStrings func() []string + HealthCheckNodePort func() int + LoadBalancerIPStrings func() []string + LoadBalancerSourceRanges func() []string + NodePort func() int + OnlyNodeLocalEndpoints func() bool + Port func() int + Protocol func() v1.Protocol + SessionAffinityType func() v1.ServiceAffinity + StickyMaxAgeSeconds func() int + String func() string + type ServicePortName struct + Port string + func (spn ServicePortName) String() string + type UpdateEndpointMapResult struct + HCEndpointsLocalIPSize map[types.NamespacedName]int + LastChangeTriggerTimes map[types.NamespacedName][]time.Time + StaleEndpoints []ServiceEndpoint + StaleServiceNames []ServicePortName + type UpdateServiceMapResult struct + HCServiceNodePorts map[types.NamespacedName]uint16 + UDPStaleClusterIP sets.String + func UpdateServiceMap(serviceMap ServiceMap, changes *ServiceChangeTracker) (result UpdateServiceMapResult)
Go to main page