- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for corelisters (0.59 sec)
-
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go
func NewDesiredStateOfWorldPopulator( loopSleepDuration time.Duration, listPodsRetryDuration time.Duration, podLister corelisters.PodLister, desiredStateOfWorld cache.DesiredStateOfWorld, volumePluginMgr *volume.VolumePluginMgr, pvcLister corelisters.PersistentVolumeClaimLister, pvLister corelisters.PersistentVolumeLister, csiMigratedPluginManager csimigration.PluginManager,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
gooPod := newStatefulSetPod(set, 0) gooPod.Name = "goo-0" podIndexer.Add(gooPod) podLister := corelisters.NewPodLister(podIndexer) claimIndexer := cache.NewIndexer(cache.MetaNamespaceKeyFunc, cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc}) claimLister := corelisters.NewPersistentVolumeClaimLister(claimIndexer) control := NewStatefulPodControl(fakeClient, podLister, claimLister, recorder)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/helper/spread.go
) // DefaultSelector returns a selector deduced from the Services, Replication // Controllers, Replica Sets, and Stateful Sets matching the given pod. func DefaultSelector( pod *v1.Pod, sl corelisters.ServiceLister, cl corelisters.ReplicationControllerLister, rsl appslisters.ReplicaSetLister, ssl appslisters.StatefulSetLister, ) labels.Selector { labelSet := make(labels.Set)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 25 20:04:48 UTC 2021 - 3.4K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/metrics/metrics.go
}, []string{"reason"}, ) ) var registerMetrics sync.Once // Register registers metrics in A/D Controller. func Register(pvcLister corelisters.PersistentVolumeClaimLister, pvLister corelisters.PersistentVolumeLister, podLister corelisters.PodLister, asw cache.ActualStateOfWorld, dsw cache.DesiredStateOfWorld, pluginMgr *volume.VolumePluginMgr, csiMigratedPluginManager csimigration.PluginManager,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 10 06:30:05 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_listers.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/labels" appslisters "k8s.io/client-go/listers/apps/v1" corelisters "k8s.io/client-go/listers/core/v1" storagelisters "k8s.io/client-go/listers/storage/v1" "k8s.io/kubernetes/pkg/scheduler/framework" ) var _ corelisters.ServiceLister = &ServiceLister{} // ServiceLister implements ServiceLister on []v1.Service for test purposes. type ServiceLister []*v1.Service
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 20 10:14:08 UTC 2023 - 10.1K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/debugger.go
type CacheDebugger struct { Comparer CacheComparer Dumper CacheDumper } // New creates a CacheDebugger. func New( nodeLister corelisters.NodeLister, podLister corelisters.PodLister, cache internalcache.Cache, podQueue internalqueue.SchedulingQueue, ) *CacheDebugger { return &CacheDebugger{ Comparer: CacheComparer{ NodeLister: nodeLister, PodLister: podLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/scheduler/metrics/resources/resources.go
// of startup and compare to actual resource usage. func NewPodResourcesMetricsCollector(podLister corelisters.PodLister) metrics.StableCollector { return &podResourceCollector{ lister: podLister, } } type podResourceCollector struct { metrics.BaseStableCollector lister corelisters.PodLister } func (c *podResourceCollector) DescribeWithStability(ch chan<- *metrics.Desc) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 23:15:53 UTC 2023 - 6.8K bytes - Viewed (0) -
pkg/scheduler/internal/cache/debugger/comparer.go
) // CacheComparer is an implementation of the Scheduler's cache comparer. type CacheComparer struct { NodeLister corelisters.NodeLister PodLister corelisters.PodLister Cache internalcache.Cache PodQueue internalqueue.SchedulingQueue } // Compare compares the nodes and pods of NodeLister with Cache.Snapshot. func (c *CacheComparer) Compare(logger klog.Logger) error { logger.V(3).Info("Cache comparer started")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/statusupdater/node_status_updater.go
kubeClient clientset.Interface, nodeLister corelisters.NodeLister, actualStateOfWorld cache.ActualStateOfWorld) NodeStatusUpdater { return &nodeStatusUpdater{ actualStateOfWorld: actualStateOfWorld, nodeLister: nodeLister, kubeClient: kubeClient, } } type nodeStatusUpdater struct { kubeClient clientset.Interface nodeLister corelisters.NodeLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util.go
// for the in-tree plugin is satisfied. func CreateVolumeSpec(logger klog.Logger, podVolume v1.Volume, pod *v1.Pod, nodeName types.NodeName, vpm *volume.VolumePluginMgr, pvcLister corelisters.PersistentVolumeClaimLister, pvLister corelisters.PersistentVolumeLister, csiMigratedPluginManager csimigration.PluginManager, csiTranslator csimigration.InTreeToCSITranslator) (*volume.Spec, error) { claimName := "" readOnly := false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 12K bytes - Viewed (0)