- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 100 for sync_bg (0.13 sec)
-
pkg/controller/disruption/disruption.go
} utilruntime.HandleError(fmt.Errorf("error syncing Pod %v to clear DisruptionTarget condition, requeueing: %w", key, err)) dc.stalePodDisruptionQueue.AddRateLimited(key) return true } func (dc *DisruptionController) sync(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := dc.clock.Now() defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/MonotonicClock.java
* It does not deal as well with large jumps back in time. * <p> * When the system wall clock jumps back in time, this clock will effectively slow down until it is back in sync. * All syncing timestamps will be the same as the previously issued timestamp. * The rate by which this clock slows, and therefore the time it takes to resync, * is determined by how frequently the clock is read.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 5K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
key, quit := c.queue.Get() if quit { return false } defer c.queue.Done(key) if err := c.syncConfigMap(); err != nil { utilruntime.HandleError(fmt.Errorf("while syncing ConfigMap %q, err: %w", key, err)) c.queue.AddRateLimited(key) return true } c.queue.Forget(key) return true } func (c *Controller) syncConfigMap() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
architecture/networking/controllers.md
* Simple object filtering. Beyond just static filters on objects, `kclient` supports _dynamic filters_ that can change at runtime. When a filter changes and includes/removes new objects, those are automatically handled. * Proper syncing and shutdown logic. Checking for when an informer has fully started can be quite tricky; `kclient` automatically handles it. Under the `kclient` package, `clienttest` also provides similar interfaces meant for writing unit tests.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
if !proxier.isInitialized() { klog.V(2).InfoS("Not syncing hns until Services and Endpoints have been received from master") return } // Keep track of how long syncs take. start := time.Now() defer func() { metrics.SyncProxyRulesLatency.Observe(metrics.SinceInSeconds(start)) klog.V(4).InfoS("Syncing proxy rules complete", "elapsed", time.Since(start)) }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
// after the next discovery sync. // For now, record the error and retry. logger.V(5).Error(err, "error syncing item", "item", n.identity) } else { utilruntime.HandleError(fmt.Errorf("error syncing item %s: %v", n, err)) } // retry if garbage collection of an object failed. return requeueItem } else if !n.isObserved() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
if err := c.syncPods(); err != nil { log.Errorf("one or more errors force-syncing pods: %v", err) } if err := c.endpoints.initializeNamespace(metav1.NamespaceAll, true); err != nil { log.Errorf("one or more errors force-syncing endpoints: %v", err) } c.reloadNetworkGateways()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
return true } func (tc *TokenCleaner) syncFunc(ctx context.Context, key string) error { logger := klog.FromContext(ctx) startTime := time.Now() defer func() { logger.V(4).Info("Finished syncing secret", "secret", key, "elapsedTime", time.Since(startTime)) }() 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 - 6.3K bytes - Viewed (0) -
pkg/proxy/nftables/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") } // Finish housekeeping, clear stale conntrack entries for UDP 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/controller/serviceaccount/serviceaccounts_controller.go
return true } func (c *ServiceAccountsController) syncNamespace(ctx context.Context, key string) error { startTime := time.Now() defer func() { klog.FromContext(ctx).V(4).Info("Finished syncing namespace", "namespace", key, "duration", time.Since(startTime)) }() ns, err := c.nsLister.Get(key) if apierrors.IsNotFound(err) { return nil } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)