- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for ephemeral_volume (0.26 sec)
-
pkg/controller/volume/ephemeral/controller.go
pvcsSynced: pvcInformer.Informer().HasSynced, queue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{Name: "ephemeral_volume"}, ), } ephemeralvolumemetrics.RegisterMetrics() eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx)) eventBroadcaster.StartLogging(klog.Infof)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
mockCadvisor.EXPECT().ImagesFsInfo().Return(imagefs, nil) mockRuntime := containertest.NewMockRuntime(mockCtrl) ephemeralVolumes := []statsapi.VolumeStats{getPodVolumeStats(seedEphemeralVolume1, "ephemeralVolume1"), getPodVolumeStats(seedEphemeralVolume2, "ephemeralVolume2")} persistentVolumes := []statsapi.VolumeStats{getPodVolumeStats(seedPersistentVolume1, "persistentVolume1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator_test.go
statsCalculator.calcAndStoreStats() vs, _ := statsCalculator.GetLatest() assert.Len(t, append(vs.EphemeralVolumes, vs.PersistentVolumes...), 4) // Verify 'vol0' doesn't have a PVC reference assert.Contains(t, append(vs.EphemeralVolumes, vs.PersistentVolumes...), kubestats.VolumeStats{ Name: vol0, FsStats: expectedFSStats(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/ephemeralcontroller.go
func (o *EphemeralVolumeControllerOptions) AddFlags(fs *pflag.FlagSet) { if o == nil { return } fs.Int32Var(&o.ConcurrentEphemeralVolumeSyncs, "concurrent-ephemeralvolume-syncs", o.ConcurrentEphemeralVolumeSyncs, "The number of ephemeral volume syncing operations that will be done concurrently. Larger number = faster ephemeral volume updating, but more CPU (and network) load") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jul 25 13:36:57 UTC 2021 - 2.1K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/metrics/metrics.go
Help: "Number of PersistenVolumeClaims creation requests", StabilityLevel: metrics.ALPHA, }) ) var registerMetrics sync.Once // RegisterMetrics registers EphemeralVolume metrics. func RegisterMetrics() { registerMetrics.Do(func() { legacyregistry.MustRegister(EphemeralVolumeCreateAttempts) legacyregistry.MustRegister(EphemeralVolumeCreateFailures) })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 02 11:01:37 UTC 2021 - 1.8K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
}) ephemeralVolumes := makeFakeVolumeStats([]string{"ephVolume1, ephVolumes2"}) persistentVolumes := makeFakeVolumeStats([]string{"persisVolume1, persisVolumes2"}) resourceAnalyzer.podVolumeStats = serverstats.PodVolumeStats{ EphemeralVolumes: ephemeralVolumes, PersistentVolumes: persistentVolumes, } fakeStats := map[string]*volume.Metrics{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pkg/kubelet/stats/helper.go
if vstats, found := resourceAnalyzer.GetPodVolumeStats(podUID); found { ephemeralStats = make([]statsapi.VolumeStats, len(vstats.EphemeralVolumes)) copy(ephemeralStats, vstats.EphemeralVolumes) s.VolumeStats = append(append([]statsapi.VolumeStats{}, vstats.EphemeralVolumes...), vstats.PersistentVolumes...) } logStats, err := hostStatsProvider.getPodLogStats(podNs, podName, podUID, rootFsInfo) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 23:40:02 UTC 2023 - 14.8K bytes - Viewed (0) -
pkg/kubelet/server/stats/volume_stat_calculator.go
} // PodVolumeStats encapsulates the VolumeStats for a pod. // It consists of two lists, for local ephemeral volumes, and for persistent volumes respectively. type PodVolumeStats struct { EphemeralVolumes []stats.VolumeStats PersistentVolumes []stats.VolumeStats } // newVolumeStatCalculator creates a new VolumeStatCalculator
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 29 00:55:10 UTC 2022 - 7.1K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/options_test.go
"--concurrent-deployment-syncs=10", "--concurrent-horizontal-pod-autoscaler-syncs=10", "--concurrent-statefulset-syncs=15", "--concurrent-endpoint-syncs=10", "--concurrent-ephemeralvolume-syncs=10", "--concurrent-service-endpoint-syncs=10", "--concurrent-gc-syncs=30", "--concurrent-namespace-syncs=20", "--concurrent-job-syncs=10", "--concurrent-cron-job-syncs=10",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 02:59:09 UTC 2024 - 55.1K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.23.md
- The `TTLAfterFinished` feature gate is now GA and enabled by default. ([#105219](https://github.com/kubernetes/kubernetes/pull/105219), [@sahilvv](https://github.com/sahilvv)) - The `kube-controller-manager` supports `--concurrent-ephemeralvolume-syncs` flag to set the number of ephemeral volume controller workers. ([#102981](https://github.com/kubernetes/kubernetes/pull/102981), [@SataQiu](https://github.com/SataQiu))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 28 21:06:52 UTC 2023 - 424.5K bytes - Viewed (0)