Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for endpointMap (0.28 sec)

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