- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for endpointMap (0.28 sec)
-
pkg/proxy/winkernel/proxier.go
svcInfo.cleanupAllPolicies(proxier.endpointsMap[*svcPortName], proxier.mapStaleLoadbalancers, true) } else { // If no service exists, just cleanup the remote endpoints klog.V(3).InfoS("Endpoints are orphaned, cleaning up") // Cleanup Endpoints references epInfos, exists := proxier.endpointsMap[*svcPortName] if exists { // Cleanup Endpoints references
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
endpointIP = strings.ReplaceAll(endpointIP, ":", ".") } // As above, we use "/" to separate parts of the name, and "__" to separate the // "service" part from the "endpoint" part. name := fmt.Sprintf("%s/%s/%s/%s__%s/%s", servicePortName.NamespacedName.Namespace, servicePortName.NamespacedName.Name, protocol, servicePortName.Port, endpointIP, endpointPort, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap endpointsMap proxy.EndpointsMap nodeLabels map[string]string // endpointSlicesSynced, and servicesSynced are set to true // when corresponding objects are synced after startup. This is used to avoid
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap endpointsMap proxy.EndpointsMap nodeLabels map[string]string // initialSync is a bool indicating if the proxier is syncing for the first time. // It is set to true when a new proxier is initialized and then set to false on all
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
} idx := New(Options{ Client: cl, SystemNamespace: systemNS, DomainSuffix: "company.com", ClusterID: clusterID, XDSUpdater: up, LookupNetwork: func(endpointIP string, labels labels.Instance) network.ID { return networkID }, }) cl.RunAndWait(test.NewStop(t)) t.Cleanup(func() { if t.Failed() { idx := idx.(*index)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0)