Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ReconcilerStatesHasBeenSynced (0.49 sec)

  1. pkg/kubelet/volumemanager/volume_manager_fake.go

    	inuse := []v1.UniqueVolumeName{}
    	for v := range f.volumes {
    		inuse = append(inuse, v)
    	}
    	return inuse
    }
    
    // ReconcilerStatesHasBeenSynced is not implemented
    func (f *FakeVolumeManager) ReconcilerStatesHasBeenSynced() bool {
    	return true
    }
    
    // VolumeIsAttached is not implemented
    func (f *FakeVolumeManager) VolumeIsAttached(volumeName v1.UniqueVolumeName) bool {
    	return false
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 17 16:53:28 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. pkg/kubelet/volumemanager/volume_manager.go

    	GetVolumesInUse() []v1.UniqueVolumeName
    
    	// ReconcilerStatesHasBeenSynced returns true only after the actual states in reconciler
    	// has been synced at least once after kubelet starts so that it is safe to update mounted
    	// volume list retrieved from actual state.
    	ReconcilerStatesHasBeenSynced() bool
    
    	// VolumeIsAttached returns true if the given volume is attached to this
    	// node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  3. pkg/kubelet/nodestatus/setters.go

    		}
    		return nil
    	}
    }
    
    // VolumesInUse returns a Setter that updates the volumes in use on the node.
    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 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    			kl.containerManager.Status, kl.shutdownManager.ShutdownStatus, kl.recordNodeStatusEvent, kl.supportLocalStorageCapacityIsolation()),
    		nodestatus.VolumesInUse(kl.volumeManager.ReconcilerStatesHasBeenSynced, kl.volumeManager.GetVolumesInUse),
    		// TODO(mtaufen): I decided not to move this setter for now, since all it does is send an event
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_node_status_test.go

    			kubelet.volumeManager = fakeVolumeManager
    
    			// Only test VolumesInUse setter
    			kubelet.setNodeStatusFuncs = []func(context.Context, *v1.Node) error{
    				nodestatus.VolumesInUse(kubelet.volumeManager.ReconcilerStatesHasBeenSynced,
    					kubelet.volumeManager.GetVolumesInUse),
    			}
    
    			kubeClient := testKubelet.fakeKubeClient
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
Back to top