- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for podVolumes (0.16 sec)
-
pkg/kubelet/volumemanager/reconciler/reconstruct_common.go
deviceMounter volumepkg.DeviceMounter blockVolumeMapper volumepkg.BlockVolumeMapper podVolumes map[volumetypes.UniquePodName]*reconstructedVolume } func (gvi globalVolumeInfo) MarshalLog() interface{} { podVolumes := make(map[volumetypes.UniquePodName]v1.UniqueVolumeName) for podName, volume := range gvi.podVolumes { podVolumes[podName] = volume.volumeName } return struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/fake_binder.go
return nil, b.config.FindReasons, b.config.FindErr } // AssumePodVolumes implements SchedulerVolumeBinder.AssumePodVolumes. func (b *FakeVolumeBinder) AssumePodVolumes(_ klog.Logger, assumedPod *v1.Pod, nodeName string, podVolumes *PodVolumes) (bool, error) { b.AssumeCalled = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 03:28:12 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_linux_test.go
propagationNone := v1.MountPropagationNone testCases := map[string]struct { container v1.Container podVolumes kubecontainer.VolumeMap supportsRRO bool expectErr bool expectedErrMsg string expectedMounts []kubecontainer.Mount }{ "valid mounts in unprivileged container": { podVolumes: kubecontainer.VolumeMap{ "disk": kubecontainer.VolumeInfo{Mounter: &stubVolume{path: "/mnt/disk"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 18:00:59 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding.go
state.Lock() state.podVolumesByNode[node.Name] = podVolumes state.hasStaticBindings = state.hasStaticBindings || (podVolumes != nil && len(podVolumes.StaticBindings) > 0) state.Unlock() return nil } // PreScore invoked at the preScore extension point. It checks whether volumeBinding can skip Score
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
} podVolumes.StaticBindings = newBindings podVolumes.DynamicProvisions = newProvisionedPVCs return } // RevertAssumedPodVolumes will revert assumed PV and PVC cache. func (b *volumeBinder) RevertAssumedPodVolumes(podVolumes *PodVolumes) { b.revertAssumedPVs(podVolumes.StaticBindings) b.revertAssumedPVCs(podVolumes.DynamicProvisions) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
func (env *testEnv) validatePodCache(t *testing.T, node string, pod *v1.Pod, podVolumes *PodVolumes, expectedBindings []*BindingInfo, expectedProvisionings []*v1.PersistentVolumeClaim) { var ( bindings []*BindingInfo provisionedClaims []*v1.PersistentVolumeClaim ) if podVolumes != nil { bindings = podVolumes.StaticBindings provisionedClaims = podVolumes.DynamicProvisions }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_windows_test.go
{ MountPath: `/mnt/path7`, Name: "disk7", ReadOnly: false, }, { MountPath: `\\.\pipe\pipe1`, Name: "pipe1", ReadOnly: false, }, }, } podVolumes := kubecontainer.VolumeMap{ "disk": kubecontainer.VolumeInfo{Mounter: &stubVolume{path: "c:/mnt/disk"}}, "disk4": kubecontainer.VolumeInfo{Mounter: &stubVolume{path: "c:/mnt/host"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct.go
// Get volumes information by reading the pod's directory podVolumes, err := getVolumesFromPodDir(rc.kubeletPodsDir) if err != nil { klog.ErrorS(err, "Cannot get volumes from disk, skip sync states for volume reconstruction") return } reconstructedVolumes := make(map[v1.UniqueVolumeName]*globalVolumeInfo) reconstructedVolumeNames := []v1.UniqueVolumeName{} for _, volume := range podVolumes {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go
}, unboundClaimsDelayBinding: []*v1.PersistentVolumeClaim{}, unboundVolumesDelayBinding: map[string][]*v1.PersistentVolume{}, }, podVolumesByNode: map[string]*PodVolumes{}, }, wantFilterStatus: []*framework.Status{ nil, }, wantPreScoreStatus: framework.NewStatus(framework.Skip), }, { name: "all bound with local volumes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 32K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
func (kl *Kubelet) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) { volumesToReturn := make(map[string]volume.Volume) podVolumes := kl.volumeManager.GetMountedVolumesForPod( volumetypes.UniquePodName(podUID)) for outerVolumeSpecName, volume := range podVolumes { // TODO: volume.Mounter could be nil if volume object is recovered // from reconciler's sync state process. PR 33616 will fix this problem
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0)