- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for volumeManager (0.34 sec)
-
pkg/kubelet/volumemanager/volume_manager.go
"k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/container" "k8s.io/kubernetes/pkg/kubelet/volumemanager/cache" "k8s.io/kubernetes/pkg/kubelet/volumemanager/metrics" "k8s.io/kubernetes/pkg/kubelet/volumemanager/populator" "k8s.io/kubernetes/pkg/kubelet/volumemanager/reconciler" "k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/csimigration" "k8s.io/kubernetes/pkg/volume/util"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
go simulateVolumeInUseUpdate( v1.UniqueVolumeName("fake/fake-device"), stopCh, kubelet.volumeManager) assert.NoError(t, kubelet.volumeManager.WaitForAttachAndMount(context.Background(), pod)) podVolumes := kubelet.volumeManager.GetMountedVolumesForPod( util.GetUniquePodName(pod)) allPodVolumes := kubelet.volumeManager.GetPossiblyMountedVolumesForPod( util.GetUniquePodName(pod))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
}, } return node, pod, pv, claim } func simulateVolumeInUseUpdate(volumeName v1.UniqueVolumeName, stopCh <-chan struct{}, volumeManager VolumeManager) { ticker := time.NewTicker(100 * time.Millisecond) defer ticker.Stop() for { select { case <-ticker.C: volumeManager.MarkVolumesAsReportedInUse( []v1.UniqueVolumeName{volumeName}) case <-stopCh: return } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_fake.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package volumemanager import ( "context" v1 "k8s.io/api/core/v1" "k8s.io/kubernetes/pkg/kubelet/config" "k8s.io/kubernetes/pkg/kubelet/container" "k8s.io/kubernetes/pkg/volume/util/types" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/runonce_test.go
if err != nil { t.Fatalf("failed to initialize VolumePluginMgr: %v", err) } kb.volumeManager = volumemanager.NewVolumeManager( true, kb.nodeName, kb.podManager, kb.podWorkers, kb.kubeClient, kb.volumePluginMgr, fakeRuntime, kb.mounter, kb.hostutil, kb.getPodsDir(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K 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
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics.go
limitations under the License. */ package metrics import ( "sync" "k8s.io/component-base/metrics" "k8s.io/component-base/metrics/legacyregistry" "k8s.io/kubernetes/pkg/kubelet/volumemanager/cache" "k8s.io/kubernetes/pkg/volume" volumeutil "k8s.io/kubernetes/pkg/volume/util" ) const ( pluginNameNotAvailable = "N/A" // Metric keys for Volume Manager.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 06 16:48:59 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/kubelet/volumemanager/metrics/metrics_test.go
package metrics import ( "k8s.io/klog/v2/ktesting" "testing" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" k8stypes "k8s.io/apimachinery/pkg/types" "k8s.io/kubernetes/pkg/kubelet/volumemanager/cache" "k8s.io/kubernetes/pkg/volume" volumetesting "k8s.io/kubernetes/pkg/volume/testing" "k8s.io/kubernetes/pkg/volume/util" "k8s.io/kubernetes/pkg/volume/util/operationexecutor" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
// already immutable. However, given that: // - we want to also handle the case when object is marked as immutable later // - Secrets and ConfigMaps are periodically fetched by volumemanager anyway // - doing that wouldn't provide visible scalability/performance gain - we // already have it from here // - doing that would require significant refactoring to reflector
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status_test.go
// override test volumeManager fakeVolumeManager := kubeletvolume.NewFakeVolumeManager(tc.existingVolumes) kubelet.volumeManager = fakeVolumeManager // Only test VolumesInUse setter kubelet.setNodeStatusFuncs = []func(context.Context, *v1.Node) error{ nodestatus.VolumesInUse(kubelet.volumeManager.ReconcilerStatesHasBeenSynced, kubelet.volumeManager.GetVolumesInUse), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 08 19:23:19 UTC 2024 - 115.8K bytes - Viewed (0)