Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for syncService (0.2 sec)

  1. pkg/controller/endpoint/endpoints_controller_test.go

    		}},
    	})
    	endpoints.serviceStore.Add(&v1.Service{
    		ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: ns},
    		Spec:       v1.ServiceSpec{Ports: []v1.ServicePort{{Port: 80}}},
    	})
    	err := endpoints.syncService(tCtx, ns+"/foo")
    	if err != nil {
    		t.Errorf("Unexpected error syncing service %v", err)
    	}
    	endpointsHandler.ValidateRequestCount(t, 0)
    }
    
    func TestSyncEndpointsExistingNilSubsets(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
  2. pkg/controller/endpointslice/endpointslice_controller_test.go

    			Ports:    []v1.ServicePort{{TargetPort: intstr.FromInt32(80)}},
    		},
    	})
    
    	logger, _ := ktesting.NewTestContext(t)
    	err := esController.syncService(logger, fmt.Sprintf("%s/%s", ns, serviceName))
    	assert.NoError(t, err)
    	assert.Len(t, client.Actions(), 0)
    }
    
    // Ensure SyncService for service with selector but no pods results in placeholder EndpointSlice
    func TestSyncServiceWithSelector(t *testing.T) {
    	ns := metav1.NamespaceDefault
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier.go

    		if proxier.ipvsScheduler == "mh" {
    			serv.Flags |= utilipvs.FlagSourceHash
    		}
    		// We need to bind ClusterIP to dummy interface, so set `bindAddr` parameter to `true` in syncService()
    		if err := proxier.syncService(svcPortNameString, serv, true, alreadyBoundAddrs); err == nil {
    			activeIPVSServices.Insert(serv.String())
    			activeBindAddrs.Insert(serv.Address.String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  4. pkg/proxy/winkernel/proxier.go

    	// not "OnlyLocal", but the services list will not, and the serviceHealthServer
    	// will just drop those endpoints.
    	if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil {
    		klog.ErrorS(err, "Error syncing healthcheck services")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  5. pkg/proxy/nftables/proxier.go

    	// not "OnlyLocal", but the services list will not, and the serviceHealthServer
    	// will just drop those endpoints.
    	if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil {
    		proxier.logger.Error(err, "Error syncing healthcheck services")
    	}
    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/iptables/proxier.go

    	// not "OnlyLocal", but the services list will not, and the serviceHealthServer
    	// will just drop those endpoints.
    	if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil {
    		proxier.logger.Error(err, "Error syncing healthcheck services")
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
Back to top