Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PortMapKey (0.09 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top