Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for NewEndpointsChangeTracker (0.32 sec)

  1. pkg/proxy/endpointschangetracker_test.go

    	}{
    		"empty slices": {
    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    			expectedChanges:        []*endpointsChange{},
    			appliedSlices:          []*discovery.EndpointSlice{},
    			pendingSlices:          []*discovery.EndpointSlice{},
    		},
    		"adding initial slice": {
    			endpointsChangeTracker: NewEndpointsChangeTracker("", nil, v1.IPv4Protocol, nil, nil),
    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/endpointschangetracker.go

    type makeEndpointFunc func(info *BaseEndpointInfo, svcPortName *ServicePortName) Endpoint
    type processEndpointsMapChangeFunc func(oldEndpointsMap, newEndpointsMap EndpointsMap)
    
    // NewEndpointsChangeTracker initializes an EndpointsChangeTracker
    func NewEndpointsChangeTracker(hostname string, makeEndpointInfo makeEndpointFunc, ipFamily v1.IPFamily, recorder events.EventRecorder, processEndpointsMapChange processEndpointsMapChangeFunc) *EndpointsChangeTracker {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier_test.go

    		mapStaleLoadbalancers: make(map[string]bool),
    	}
    
    	serviceChanges := proxy.NewServiceChangeTracker(proxier.newServiceInfo, v1.IPv4Protocol, nil, proxier.serviceMapChange)
    	endpointsChangeTracker := proxy.NewEndpointsChangeTracker(hostname, proxier.newEndpointInfo, v1.IPv4Protocol, nil, proxier.endpointsMapChange)
    	proxier.endpointsChanges = endpointsChangeTracker
    	proxier.serviceChanges = serviceChanges
    
    	return proxier
    }
    
    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/nftables/proxier.go

    		serviceChanges:      proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:        make(proxy.EndpointsMap),
    		endpointsChanges:    proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    		syncPeriod:          syncPeriod,
    		nftables:            nft,
    		masqueradeAll:       masqueradeAll,
    		masqueradeMark:      masqueradeMark,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/winkernel/proxier.go

    		mapStaleLoadbalancers: make(map[string]bool),
    	}
    
    	serviceChanges := proxy.NewServiceChangeTracker(proxier.newServiceInfo, ipFamily, recorder, proxier.serviceMapChange)
    	endPointChangeTracker := proxy.NewEndpointsChangeTracker(hostname, proxier.newEndpointInfo, ipFamily, recorder, proxier.endpointsMapChange)
    	proxier.endpointsChanges = endPointChangeTracker
    	proxier.serviceChanges = serviceChanges
    
    	burstSyncs := 2
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  6. pkg/proxy/iptables/proxier.go

    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    		needFullSync:             true,
    		syncPeriod:               syncPeriod,
    		iptables:                 ipt,
    		masqueradeAll:            masqueradeAll,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  7. pkg/proxy/ipvs/proxier.go

    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:          make(proxy.EndpointsMap),
    		endpointsChanges:      proxy.NewEndpointsChangeTracker(hostname, nil, ipFamily, recorder, nil),
    		initialSync:           true,
    		syncPeriod:            syncPeriod,
    		minSyncPeriod:         minSyncPeriod,
    		excludeCIDRs:          parsedExcludeCIDRs,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  8. pkg/proxy/nftables/proxier_test.go

    		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",
    		conntrack:           conntrack.NewFake(),
    		localDetector:       detectLocal,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  9. pkg/proxy/ipvs/proxier_test.go

    		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,
    		ipset:                 ipset,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  10. pkg/proxy/iptables/proxier_test.go

    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipfamily, nil, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(testHostname, newEndpointInfo, ipfamily, nil, nil),
    		needFullSync:             true,
    		iptables:                 ipt,
    		masqueradeMark:           "0x4000",
    		conntrack:                conntrack.NewFake(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
Back to top