- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for syncService (0.36 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/controller/endpointslice/endpointslice_controller.go
// queuing a syncService call after an EndpointSlice changes. If // endpointUpdatesBatchPeriod is greater than this value, it will be used // instead. This helps batch processing of changes to multiple // EndpointSlices. endpointSliceChangeMinSyncDelay = 1 * time.Second // defaultSyncBackOff is the default backoff period for syncService calls. defaultSyncBackOff = 1 * time.Second
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
} klog.Warningf("Dropping Service %q out of the queue: %v", key, err) r.svcQueue.Forget(key) runtime.HandleError(err) } // syncServices reconcile the Service ClusterIPs to verify that each one has the corresponding IPAddress object associated func (r *RepairIPAddress) syncService(key string) error { var syncError error namespace, name, err := cache.SplitMetaNamespaceKey(key) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K 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/controller/endpoint/endpoints_controller.go
func (e *Controller) processNextWorkItem(ctx context.Context) bool { eKey, quit := e.queue.Get() if quit { return false } defer e.queue.Done(eKey) logger := klog.FromContext(ctx) err := e.syncService(ctx, eKey) e.handleErr(logger, err, eKey) return true } func (e *Controller) handleErr(logger klog.Logger, err error, key string) { if err == nil { e.queue.Forget(key) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/proxy/healthcheck/service_health.go
func NewFakeServiceHealthServer() ServiceHealthServer { return FakeServiceHealthServer{} } // SyncServices is part of ServiceHealthServer func (fake FakeServiceHealthServer) SyncServices(_ map[types.NamespacedName]uint16) error { return nil } // SyncEndpoints is part of ServiceHealthServer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 30 09:25:48 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} // delete the service hcs.SyncServices(nil) if len(hcs.services) != 0 { t.Errorf("expected 0 services, got %d", len(hcs.services)) } // sync multiple services nsn1 := mknsn("a", "b") nsn2 := mknsn("c", "d") nsn3 := mknsn("e", "f") nsn4 := mknsn("g", "h") hcs.SyncServices(map[types.NamespacedName]uint16{ nsn1: 9376, nsn2: 12909, nsn3: 11113,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
if err := proxier.ipvs.AddVirtualServer(testCases[i].oldVirtualServer); err != nil { t.Errorf("Case [%d], unexpected add IPVS virtual server error: %v", i, err) } } if err := proxier.syncService(testCases[i].svcName, testCases[i].newVirtualServer, testCases[i].bindAddr, testCases[i].alreadyBoundAddrs); err != nil { t.Errorf("Case [%d], unexpected sync IPVS virtual server error: %v", i, err) } // check
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K 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)