Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for sync_bg (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top