- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 144 for sync_bg (0.13 sec)
-
pkg/kubelet/kubeletconfig/util/files/files.go
} defer func() { // close the file, return the close error only if there haven't been any other errors if err := tmpFile.Close(); retErr == nil { retErr = err } // if there was an error writing, syncing, or closing, delete the temporary file and return the error if retErr != nil { if err := fs.Remove(tmpPath); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 13 01:02:46 UTC 2023 - 7.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) -
pkg/controller/endpointslice/endpointslice_controller.go
trackSync(err) if err == nil { c.serviceQueue.Forget(key) return } if c.serviceQueue.NumRequeues(key) < maxRetries { logger.Info("Error syncing endpoint slices for service, retrying", "key", key, "err", err) c.serviceQueue.AddRateLimited(key) return } logger.Info("Retry budget exceeded, dropping service out of the queue", "key", key, "err", err)
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/controller/resourcequota/resource_quota_controller.go
startTime := time.Now() logger := klog.FromContext(ctx) logger = klog.LoggerWithValues(logger, "key", key) defer func() { logger.V(4).Info("Finished syncing resource quota", "key", key, "duration", 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 - 21.3K bytes - Viewed (0) -
pkg/proxy/iptables/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: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
internal/bucket/replication/replication_test.go
// using config 4 - with replica modification sync disabled. {ObjectOpts{Name: "xy/c5test", UserTags: "k1=v1", Replica: true}, cfgs[4], false}, // 39. replica syncing disabled, this object is a replica {ObjectOpts{Name: "xa/c5test", UserTags: "k1=v1", Replica: false}, cfgs[4], true}, // 40. replica syncing disabled, this object is NOT a replica } for _, testCase := range testCases { testCase := testCase
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 28 17:44:56 UTC 2024 - 32.5K bytes - Viewed (0) -
testing/integ-test/src/integTest/groovy/org/gradle/integtests/SyncTaskIntegrationTest.groovy
when: executer.withStackTraceChecksDisabled() runAndFail "sync" then: failure.assertHasDocumentedCause("Cannot access a file in the destination directory. " + "Syncing to a directory which contains unreadable content is not supported. " + "Use a Copy task with Task.doNotTrackState() instead. " +
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 18.9K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
if keyErr != nil { logger.Error(err, "Failed to split meta namespace cache key", "key", key) } if e.queue.NumRequeues(key) < maxRetries { logger.V(2).Info("Error syncing endpoints, retrying", "service", klog.KRef(ns, name), "err", err) e.queue.AddRateLimited(key) return } logger.Info("Dropping service out of the queue", "service", klog.KRef(ns, name), "err", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0)