Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for syncedFunc (0.17 sec)

  1. pkg/kubelet/nodestatus/setters.go

    func VolumesInUse(syncedFunc func() bool, // typically Kubelet.volumeManager.ReconcilerStatesHasBeenSynced
    	volumesInUseFunc func() []v1.UniqueVolumeName, // typically Kubelet.volumeManager.GetVolumesInUse
    ) Setter {
    	return func(ctx context.Context, node *v1.Node) error {
    		// Make sure to only update node status after reconciler starts syncing up states
    		if syncedFunc() {
    			node.Status.VolumesInUse = volumesInUseFunc()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  2. pkg/kubelet/nodestatus/setters_test.go

    	for _, tc := range cases {
    		t.Run(tc.desc, func(t *testing.T) {
    			ctx := context.Background()
    			syncedFunc := func() bool {
    				return tc.synced
    			}
    			volumesInUseFunc := func() []v1.UniqueVolumeName {
    				return tc.volumesInUse
    			}
    			// construct setter
    			setter := VolumesInUse(syncedFunc, volumesInUseFunc)
    			// call setter on node
    			if err := setter(ctx, tc.node); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
Back to top