Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for NewServiceChangeTracker (0.28 sec)

  1. pkg/proxy/servicechangetracker.go

    // current is state after applying all of the changes.
    type serviceChange struct {
    	previous ServicePortMap
    	current  ServicePortMap
    }
    
    // NewServiceChangeTracker initializes a ServiceChangeTracker
    func NewServiceChangeTracker(makeServiceInfo makeServicePortFunc, ipFamily v1.IPFamily, recorder events.EventRecorder, processServiceMapChange processServiceMapChangeFunc) *ServiceChangeTracker {
    	return &ServiceChangeTracker{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  2. pkg/proxy/conntrack/cleanup_test.go

    	// provide our own implementation of that interface, or else use a
    	// proxy.ServiceChangeTracker to construct them and fill in the map for us.
    
    	sct := proxy.NewServiceChangeTracker(nil, v1.IPv4Protocol, nil, nil)
    	svc := &v1.Service{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "cleanup-test",
    			Namespace: "test",
    		},
    		Spec: v1.ServiceSpec{
    			ClusterIP:   testClusterIP,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 15 18:09:05 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. pkg/proxy/servicechangetracker_test.go

    	for _, tc := range testCases {
    		t.Run(tc.desc, func(t *testing.T) {
    			featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.LoadBalancerIPMode, tc.ipModeEnabled)
    			svcTracker := NewServiceChangeTracker(nil, tc.ipFamily, nil, nil)
    			// outputs
    			newServices := svcTracker.serviceToServiceMap(tc.service)
    
    			if len(newServices) != len(tc.expected) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier_test.go

    		hcn:                   hcnMock,
    		endPointsRefCount:     make(endPointsReferenceCountMap),
    		forwardHealthCheckVip: true,
    		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)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. pkg/proxy/nftables/proxier.go

    	if err != nil {
    		return nil, err
    	}
    
    	proxier := &Proxier{
    		ipFamily:            ipFamily,
    		svcPortMap:          make(proxy.ServicePortMap),
    		serviceChanges:      proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:        make(proxy.EndpointsMap),
    		endpointsChanges:    proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  6. pkg/proxy/winkernel/proxier.go

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

    		logger.Error(err, "Failed to create nfacct runner")
    	}
    
    	proxier := &Proxier{
    		ipFamily:                 ipFamily,
    		svcPortMap:               make(proxy.ServicePortMap),
    		serviceChanges:           proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:             make(proxy.EndpointsMap),
    		endpointsChanges:         proxy.NewEndpointsChangeTracker(hostname, newEndpointInfo, ipFamily, recorder, nil),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  8. pkg/proxy/ipvs/proxier.go

    	parsedExcludeCIDRs, _ := netutils.ParseCIDRs(excludeCIDRs)
    
    	proxier := &Proxier{
    		ipFamily:              ipFamily,
    		svcPortMap:            make(proxy.ServicePortMap),
    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, recorder, nil),
    		endpointsMap:          make(proxy.EndpointsMap),
    		endpointsChanges:      proxy.NewEndpointsChangeTracker(hostname, nil, ipFamily, recorder, nil),
    		initialSync:           true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  9. pkg/proxy/nftables/proxier_test.go

    	} else {
    		nodeIP = netutils.ParseIPSloppy(testNodeIPv6)
    	}
    	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,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/proxier_test.go

    		ipsetList[is.name] = NewIPSet(ipset, is.name, is.setType, false, is.comment)
    	}
    	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),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
Back to top