- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PortMapKey (0.2 sec)
-
pkg/controller/endpointslicemirroring/metrics/cache.go
func NewEndpointPortCache() *EndpointPortCache { return &EndpointPortCache{ items: map[endpointsliceutil.PortMapKey]EfficiencyInfo{}, } } // Set updates the EndpointPortCache to contain the provided EfficiencyInfo // for the provided PortMapKey. func (spc *EndpointPortCache) Set(pmKey endpointsliceutil.PortMapKey, eInfo EfficiencyInfo) { spc.items[pmKey] = eInfo }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/utils.go
netutils "k8s.io/utils/net" ) // addrTypePortMapKey is used to uniquely identify groups of endpoint ports and // address types. type addrTypePortMapKey string // newAddrTypePortMapKey generates a PortMapKey from endpoint ports. func newAddrTypePortMapKey(endpointPorts []discovery.EndpointPort, addrType discovery.AddressType) addrTypePortMapKey { pmk := fmt.Sprintf("%s-%s", addrType, endpointsliceutil.NewPortMapKey(endpointPorts))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 8.8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler.go
endpoints, existingSlicesByKey[portKey], desiredEndpoints, d.portsByKey[portKey], portKey.addressType()) slices.append(pmSlices) totals.add(pmTotals) epMetrics.Set(endpointsliceutil.PortMapKey(portKey), metrics.EfficiencyInfo{ Endpoints: numEndpoints, Slices: len(existingSlicesByKey[portKey]) + len(pmSlices.toCreate) - len(pmSlices.toDelete), }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 11 18:08:12 UTC 2023 - 13.1K bytes - Viewed (0)