- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for NewPriorityQueue (0.33 sec)
-
pkg/scheduler/internal/queue/testing.go
} func NewTestQueueWithInformerFactory( ctx context.Context, lessFn framework.LessFunc, informerFactory informers.SharedInformerFactory, opts ...Option, ) *PriorityQueue { pq := NewPriorityQueue(lessFn, informerFactory, opts...) informerFactory.Start(ctx.Done()) informerFactory.WaitForCacheSync(ctx.Done()) return pq
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 10 00:53:58 UTC 2022 - 1.7K bytes - Viewed (0) -
src/main/java/org/codelibs/core/collection/CollectionsUtil.java
* * @param <E> * {@link PriorityQueue}の要素型 * @return {@link PriorityQueue}の新しいインスタンス * @see PriorityQueue#PriorityQueue() */ public static <E> PriorityQueue<E> newPriorityQueue() { return new PriorityQueue<>(); } /** * {@link PriorityQueue}の新しいインスタンスを作成して返します。 * * @param <E> * {@link PriorityQueue}の要素型
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 53.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* in 15.0) */ @SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989 public static <E extends Comparable> PriorityQueue<E> newPriorityQueue() { return new PriorityQueue<>(); } /** * Creates a {@code PriorityQueue} containing the given elements. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 16K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
* in 15.0) */ @SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989 public static <E extends Comparable> PriorityQueue<E> newPriorityQueue() { return new PriorityQueue<>(); } /** * Creates a {@code PriorityQueue} containing the given elements. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 18K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
podInformer := informerFactory.Core().V1().Pods() // Need to add/update/delete testPod to the store. podInformer.Informer().GetStore().Add(testPod) queue := internalqueue.NewPriorityQueue(nil, informerFactory, internalqueue.WithClock(testingclock.NewFakeClock(time.Now()))) schedulerCache := internalcache.New(ctx, 30*time.Second) if err := queue.Add(logger, testPod); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
return &framework.QueuedPodInfo{ PodInfo: &framework.PodInfo{Pod: pod}, UnschedulablePlugins: sets.New(plugins...), } } // NewPriorityQueue creates a PriorityQueue object. func NewPriorityQueue( lessFn framework.LessFunc, informerFactory informers.SharedInformerFactory, opts ...Option, ) *PriorityQueue { options := defaultPriorityQueueOptions
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
cs := fake.NewSimpleClientset(tt.podInfo.Pod) informerFactory := informers.NewSharedInformerFactory(cs, 0) podLister := informerFactory.Core().V1().Pods().Lister() // Build a PriorityQueue. q := NewPriorityQueue(newDefaultQueueSort(), informerFactory, WithPodLister(podLister)) ctx, cancel := context.WithCancel(context.Background()) defer cancel() informerFactory.Start(ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)