Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewServiceChangeTracker (0.58 sec)

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