Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for assumedPods (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top