Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for endpointInfos (0.24 sec)

  1. pkg/proxy/winkernel/hns.go

    	getAllEndpointsByNetwork(networkName string) (map[string]*endpointInfo, error)
    	getEndpointByID(id string) (*endpointInfo, error)
    	getEndpointByIpAddress(ip string, networkName string) (*endpointInfo, error)
    	getEndpointByName(id string) (*endpointInfo, error)
    	createEndpoint(ep *endpointInfo, networkName string) (*endpointInfo, error)
    	deleteEndpoint(hnsID string) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 21:21:12 UTC 2023
    - 15K bytes
    - Viewed (0)
  2. pkg/proxy/winkernel/hns_test.go

    	endpointB, err := Network.CreateEndpoint(endpointBSpec)
    	if err != nil {
    		t.Error(err)
    	}
    	endpointInfoB := &endpointInfo{
    		ip:    endpointB.IpConfigurations[0].IpAddress,
    		hnsID: endpointB.Id,
    	}
    	endpoints := []endpointInfo{*endpointInfoA, *endpointInfoB}
    	endpointsReverse := []endpointInfo{*endpointInfoB, *endpointInfoA}
    	h1, err := hashEndpoints(endpoints)
    	if err != nil {
    		t.Error(err)
    	} else if len(h1) < 1 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier_test.go

    			}}
    		}),
    	)
    
    	proxier.setInitialized(true)
    	proxier.syncProxyRules()
    
    	ep := proxier.endpointsMap[svcPortName][0]
    	epInfo, ok := ep.(*endpointInfo)
    	if !ok {
    		t.Errorf("Failed to cast endpointInfo %q", svcPortName.String())
    
    	} else {
    		if epInfo.hnsID != "EPID-3" {
    			t.Errorf("%v does not match %v", epInfo.hnsID, endpointGuid1)
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. pkg/proxy/endpointslicecache.go

    				}
    			}
    		}
    
    		endpointInfo := newBaseEndpointInfo(endpoint.Addresses[0], portNum, isLocal,
    			ready, serving, terminating, zoneHints)
    
    		// This logic ensures we're deduplicating potential overlapping endpoints
    		// isLocal should not vary between matching endpoints, but if it does, we
    		// favor a true value here if it exists.
    		if _, exists := endpointSet[endpointInfo.String()]; !exists || isLocal {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/topology_hints_test.go

    		m.healthyDevices[tc.resource] = sets.New[string]()
    		m.endpoints[tc.resource] = endpointInfo{}
    
    		for _, d := range tc.devices {
    			m.allDevices[tc.resource][d.ID] = d
    			m.healthyDevices[tc.resource].Insert(d.ID)
    		}
    
    		if tc.getPreferredAllocationFunc != nil {
    			m.endpoints[tc.resource] = endpointInfo{
    				e: &MockEndpoint{
    					getPreferredAllocationFunc: tc.getPreferredAllocationFunc,
    				},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 47.5K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/devicemanager/manager.go

    type ActivePodsFunc func() []*v1.Pod
    
    // ManagerImpl is the structure in charge of managing Device Plugins.
    type ManagerImpl struct {
    	checkpointdir string
    
    	endpoints map[string]endpointInfo // Key is ResourceName
    	mutex     sync.Mutex
    
    	server plugin.Server
    
    	// activePods is a method for listing active pods on the node
    	// so the amount of pluginResources requested by existing pods
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 15 12:01:56 UTC 2024
    - 43K bytes
    - Viewed (0)
Back to top