- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 100 for sync_bg (0.13 sec)
-
pkg/controller/nodeipam/ipam/range_allocator.go
// Foo resource to be synced. if err := r.syncNode(ctx, key); err != nil { // Put the item back on the queue to handle any transient errors. r.queue.AddRateLimited(key) return fmt.Errorf("error syncing '%s': %s, requeuing", key, err.Error()) } // Finally, if no error occurs we Forget this item so it does not // get queue again until another change happens. r.queue.Forget(obj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
// listing all policies at all, we would want to wipe the list. s.policies.Store(&policies) if err != nil { // An error was generated while syncing policies. Mark it as dirty again // so we can retry later utilruntime.HandleError(fmt.Errorf("encountered error syncing policies: %w. Rescheduling policy sync", err)) s.notify() } } func (s *policySource[P, B, E]) notify() { s.policiesDirty.Store(true) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
} func (r *RepairIPAddress) handleSvcErr(err error, key string) { if err == nil { r.svcQueue.Forget(key) return } if r.svcQueue.NumRequeues(key) < maxRetries { klog.V(2).InfoS("Error syncing Service, retrying", "service", key, "err", err) r.svcQueue.AddRateLimited(key) return } klog.Warningf("Dropping Service %q out of the queue: %v", key, err) r.svcQueue.Forget(key)
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/controller/namespace/namespace_controller.go
func (nm *NamespaceController) syncNamespaceFromKey(ctx context.Context, key string) (err error) { startTime := time.Now() logger := klog.FromContext(ctx) defer func() { logger.V(4).Info("Finished syncing namespace", "namespace", key, "duration", time.Since(startTime)) }() namespace, err := nm.lister.Get(key) if errors.IsNotFound(err) { logger.Info("Namespace has been deleted", "namespace", key) return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
proxier.logger.Error(err, "Error syncing healthcheck services") } if err := proxier.serviceHealthServer.SyncEndpoints(proxier.endpointsMap.LocalReadyEndpoints()); err != nil { proxier.logger.Error(err, "Error syncing healthcheck endpoints") }
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/storageversionmigrator/resourceversion.go
if quit { return false } defer rv.queue.Done(key) err := rv.sync(ctx, key) if err == nil { rv.queue.Forget(key) return true } klog.FromContext(ctx).V(2).Info("Error syncing SVM resource, retrying", "svm", key, "err", err) rv.queue.AddRateLimited(key) return true } func (rv *ResourceVersionController) sync(ctx context.Context, key string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
{sizeMin: 450, sizeMax: 1000, ttlSeconds: 30}, {sizeMin: 900, sizeMax: 2000, ttlSeconds: 60}, {sizeMin: 1800, sizeMax: math.MaxInt32, ttlSeconds: 300}, } ) // Run begins watching and syncing. func (ttlc *Controller) Run(ctx context.Context, workers int) { defer utilruntime.HandleCrash() defer ttlc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting TTL controller")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
defer c.hasProcessed.Finished(key) if err := c.reconcile(key); err != nil { // Put the item back on the workqueue to handle any transient errors. c.queue.AddRateLimited(key) return fmt.Errorf("error syncing '%s': %s, requeuing", key, err.Error()) } // Finally, if no error occurs we Forget this item so it is allowed // to be re-enqueued without a long rate limit c.queue.Forget(obj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
ServiceExportController = "istio-serviceexport-controller-election" // This holds the legacy name to not conflict with older control plane deployments which are just // doing the ingress syncing. IngressController = "istio-leader" // GatewayStatusController controls the status of gateway.networking.k8s.io objects. For the v1alpha1
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
err := esController.syncService(logger, fmt.Sprintf("%s/%s", namespace, missingServiceName)) // nil should be returned when the service doesn't exist assert.Nil(t, err, "Expected no error syncing service") // That should mean no client actions were performed assert.Len(t, client.Actions(), 0) // TriggerTimeTracker should have removed the reference to the missing service
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0)