Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for syncBatch (0.08 sec)

  1. pkg/kubelet/status/status_manager.go

    	syncTicker := time.NewTicker(syncPeriod).C
    
    	// syncPod and syncBatch share the same go routine to avoid sync races.
    	go wait.Forever(func() {
    		for {
    			select {
    			case <-m.podStatusChannel:
    				klog.V(4).InfoS("Syncing updated statuses")
    				m.syncBatch(false)
    			case <-syncTicker:
    				klog.V(4).InfoS("Syncing all statuses")
    				m.syncBatch(true)
    			}
    		}
    	}, 0)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
Back to top