- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for sync_bg (0.18 sec)
-
pkg/kubelet/kubelet.go
go kl.fastStatusUpdateOnce() // start syncing lease go kl.nodeLeaseController.Run(context.Background()) } go wait.Until(kl.updateRuntimeUp, 5*time.Second, wait.NeverStop) // Set up iptables util rules if kl.makeIPTablesUtilChains { kl.initNetworkUtil() } // Start component sync loops. kl.statusManager.Start() // Start syncing RuntimeClasses if enabled.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
if err == nil { t.Error("Syncing jobs expected to return error on podControl exception") } } else if tc.podLimit != 0 && fakePodControl.CreateCallCount > tc.podLimit { if err == nil { t.Error("Syncing jobs expected to return error when reached the podControl limit") } } else if err != nil { t.Errorf("Unexpected error when syncing jobs: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
// UID is updated, which causes pod config to deliver DELETE -> ADD while the old pod is still shutting // down and the pod worker to ignore the ADD. The HandlePodCleanups method then is responsible for syncing // that pod to the pod worker so that it restarts.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
if err != nil { t.Fatal(err) } assert.Equal(t, 0, len(gc.dependencyGraphBuilder.monitors)) // Make sure resource monitor syncing creates and stops resource monitors. tweakableRM.Add(schema.GroupVersionKind{Group: "tpr.io", Version: "v1", Kind: "unknown"}, nil) err = gc.resyncMonitors(logger, twoResources) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
cmd/site-replication.go
objAPI := newObjectLayerFn() if objAPI == nil { return nil, errSRObjectLayerNotReady } return objAPI.ListBuckets(ctx, BucketOptions{Deleted: true}) } // syncToAllPeers is used for syncing local data to all remote peers, it is // called once during initial "AddPeerClusters" request. func (c *SiteReplicationSys) syncToAllPeers(ctx context.Context, addOpts madmin.SRAddOptions) error { objAPI := newObjectLayerFn()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 184.3K bytes - Viewed (0) -
src/cmd/go/alldocs.go
// work sync generates that build list using the Minimal Version Selection // algorithm, and then syncs those versions back to each of modules // specified in the workspace (with use directives). // // The syncing is done by sequentially upgrading each of the dependency // modules specified in a workspace module to the version in the build list // if the dependency module's version is not already the same as the build
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 16:54:28 UTC 2024 - 142.4K bytes - Viewed (0)