Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for endpointsMap (0.12 sec)

  1. pkg/proxy/endpointschangetracker_test.go

    }
    
    func TestGetLocalEndpointIPs(t *testing.T) {
    	testCases := []struct {
    		endpointsMap EndpointsMap
    		expected     map[types.NamespacedName]sets.Set[string]
    	}{{
    		// Case[0]: nothing
    		endpointsMap: EndpointsMap{},
    		expected:     map[types.NamespacedName]sets.Set[string]{},
    	}, {
    		// Case[1]: unnamed port
    		endpointsMap: EndpointsMap{
    			makeServicePortName("ns1", "ep1", "", v1.ProtocolTCP): []Endpoint{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 79.9K bytes
    - Viewed (0)
  2. 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)
  3. pkg/proxy/nftables/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: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
Back to top