- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for assumedNode (0.32 sec)
-
pkg/scheduler/internal/cache/cache.go
imageStates map[string]*framework.ImageStateSummary } type podState struct { pod *v1.Pod // Used by assumedPod to determinate expiration. // If deadline is nil, assumedPod will never expire. deadline *time.Time // Used to block cache from expiring assumedPod if binding still runs bindingFinished bool } func newCache(ctx context.Context, ttl, period time.Duration) *cacheImpl {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K 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 return b.config.AllBound, b.config.AssumeErr } // RevertAssumedPodVolumes implements SchedulerVolumeBinder.RevertAssumedPodVolumes
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/scheduler/schedule_one.go
// This allows us to keep scheduling without waiting on binding to occur. assumedPodInfo := podInfo.DeepCopy() assumedPod := assumedPodInfo.Pod // assume modifies `assumedPod` by setting NodeName=scheduleResult.SuggestedHost err = sched.assume(logger, assumedPod, scheduleResult.SuggestedHost) if err != nil { // This is most probably result of a BUG in retrying logic.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
} assumedPod, err := cache.GetPod(pod) if err != nil { t.Fatalf("GetPod failed: %v.", err) } if assumedPod.Namespace != pod.Namespace { t.Errorf("assumedPod.Namespace != pod.Namespace (%s != %s)", assumedPod.Namespace, pod.Namespace) } if assumedPod.Name != pod.Name { t.Errorf("assumedPod.Name != pod.Name (%s != %s)", assumedPod.Name, pod.Name) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
// by the PV controller. func (b *volumeBinder) BindPodVolumes(ctx context.Context, assumedPod *v1.Pod, podVolumes *PodVolumes) (err error) { logger := klog.FromContext(ctx) logger.V(4).Info("BindPodVolumes", "pod", klog.KObj(assumedPod), "node", klog.KRef("", assumedPod.Spec.NodeName)) defer func() { if err != nil { metrics.VolumeSchedulingStageFailed.WithLabelValues("bind").Inc() }
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/internal/cache/interface.go
UpdateSnapshot(logger klog.Logger, nodeSnapshot *Snapshot) error // Dump produces a dump of the current cache. Dump() *Dump } // Dump is a dump of the cache state. type Dump struct { AssumedPods sets.Set[string] Nodes map[string]*framework.NodeInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 29 05:26:32 UTC 2023 - 5.2K bytes - Viewed (0) -
cmd/bucket-policy.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8K bytes - Viewed (0)