Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for endpointsMap (0.12 sec)

  1. 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)
  2. pkg/proxy/nftables/proxier_test.go

    	}
    	p := &Proxier{
    		ipFamily:            ipFamily,
    		svcPortMap:          make(proxy.ServicePortMap),
    		serviceChanges:      proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, nil, nil),
    		endpointsMap:        make(proxy.EndpointsMap),
    		endpointsChanges:    proxy.NewEndpointsChangeTracker(testHostname, newEndpointInfo, ipFamily, nil, nil),
    		nftables:            nft,
    		masqueradeMark:      "0x4000",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier_test.go

    	}
    	p := &Proxier{
    		svcPortMap:            make(proxy.ServicePortMap),
    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, nil, nil),
    		endpointsMap:          make(proxy.EndpointsMap),
    		endpointsChanges:      proxy.NewEndpointsChangeTracker(testHostname, nil, ipFamily, nil, nil),
    		excludeCIDRs:          excludeCIDRs,
    		iptables:              ipt,
    		ipvs:                  ipvs,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier_test.go

    		ipFamily:                 ipfamily,
    		svcPortMap:               make(proxy.ServicePortMap),
    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipfamily, nil, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(testHostname, newEndpointInfo, ipfamily, nil, nil),
    		needFullSync:             true,
    		iptables:                 ipt,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
  5. pkg/proxy/endpointslicecache_test.go

    				},
    			},
    		},
    		// 2 slices with all endpoints overlapping, more unready in first than
    		// second. If an endpoint is marked ready, we add it to the
    		// EndpointsMap, even if conditions.Ready isn't true for another
    		// matching endpoint
    		"2 slices, overlapping endpoints, some endpoints unready in 1 or both": {
    			namespacedName: types.NamespacedName{Name: "svc1", Namespace: "ns1"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/testing/hcnutils_mock.go

    		return nil, err
    	}
    	if _, ok := endpointMap[endpoint.Id]; ok {
    		return nil, fmt.Errorf("endpoint id %s already present", endpoint.Id)
    	}
    	if _, ok := endpointMap[endpoint.Name]; ok {
    		return nil, fmt.Errorf("endpoint Name %s already present", endpoint.Name)
    	}
    	endpoint.Id, endpoint.Name = hcnObj.generateEndpointGuid()
    	endpoint.HostComputeNetwork = network.Id
    	endpointMap[endpoint.Id] = endpoint
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 18 06:29:01 UTC 2023
    - 6.2K bytes
    - Viewed (0)
Back to top