- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for syncService (0.2 sec)
-
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) -
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) -
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) -
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) -
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) -
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)