Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,707 for GetPod (0.15 sec)

  1. pkg/api/v1/resource/helpers_test.go

    		expectedValue int64
    	}{
    		{
    			pod:           getPod("foo", podResources{cpuRequest: "9"}),
    			resourceName:  v1.ResourceCPU,
    			expectedValue: 9000,
    		},
    		{
    			pod:           getPod("foo", podResources{memoryRequest: "90Mi"}),
    			resourceName:  v1.ResourceMemory,
    			expectedValue: 94371840,
    		},
    		{
    			cName:         "just-overhead for cpu",
    			pod:           getPod("foo", podResources{cpuOverhead: "5", memoryOverhead: "5"}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:13 UTC 2023
    - 38.3K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    //     correctness and security.
    //
    // Note: this is only used by endpointslice controller
    func getPod(c *Controller, ip string, ep *metav1.ObjectMeta, targetRef *corev1.ObjectReference, host host.Name) (*corev1.Pod, bool) {
    	var expectPod bool
    	pod := c.getPod(ip, ep.Namespace, targetRef)
    	if targetRef != nil && targetRef.Kind == "Pod" {
    		expectPod = true
    		if pod == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_pod_control.go

    // with a clientset for writes and listers for reads; for tests we provide stubs.
    type StatefulPodControlObjectManager interface {
    	CreatePod(ctx context.Context, pod *v1.Pod) error
    	GetPod(namespace, podName string) (*v1.Pod, error)
    	UpdatePod(pod *v1.Pod) error
    	DeletePod(pod *v1.Pod) error
    	CreateClaim(claim *v1.PersistentVolumeClaim) error
    	GetClaim(namespace, claimName string) (*v1.PersistentVolumeClaim, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  4. pkg/registry/core/pod/strategy.go

    }
    
    // ResourceGetter is an interface for retrieving resources by ResourceLocation.
    type ResourceGetter interface {
    	Get(context.Context, string, *metav1.GetOptions) (runtime.Object, error)
    }
    
    func getPod(ctx context.Context, getter ResourceGetter, name string) (*api.Pod, error) {
    	obj, err := getter.Get(ctx, name, &metav1.GetOptions{})
    	if err != nil {
    		return nil, err
    	}
    	pod := obj.(*api.Pod)
    	if pod == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  5. pkg/registry/core/pod/storage/eviction.go

    		// if the original options included a resourceVersion precondition, don't retry
    		shouldRetry = func(err error) bool { return false }
    	}
    
    	err = retry.OnError(EvictionsRetry, shouldRetry, func() error {
    		pod, err = getPod(r, ctx, eviction.Name)
    		if err != nil {
    			return err
    		}
    
    		// Evicting a terminal pod should result in direct deletion of pod as it already caused disruption by the time we are evicting.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 08 11:58:48 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  6. pkg/scheduler/eventhandlers_test.go

    			sched.updatePodInCache(tt.oldObj, tt.newObj)
    
    			if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID {
    				if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil {
    					t.Errorf("Get pod UID %v from cache but it should not happen", pod.UID)
    				}
    			}
    			pod, err := sched.Cache.GetPod(tt.newObj.(*v1.Pod))
    			if err != nil {
    				t.Errorf("Failed to get pod from scheduler: %v", err)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  7. pkg/serviceaccount/jwt.go

    )
    
    // ServiceAccountTokenGetter defines functions to retrieve a named service account and secret
    type ServiceAccountTokenGetter interface {
    	GetServiceAccount(namespace, name string) (*v1.ServiceAccount, error)
    	GetPod(namespace, name string) (*v1.Pod, error)
    	GetSecret(namespace, name string) (*v1.Secret, error)
    	GetNode(name string) (*v1.Node, error)
    }
    
    type TokenGenerator interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 22:16:08 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  8. pkg/serviceaccount/claims.go

    		}
    	}
    
    	var podName, podUID string
    	if podref != nil {
    		// Make sure token hasn't been invalidated by deletion of the pod
    		pod, err := v.getter.GetPod(namespace, podref.Name)
    		if err != nil {
    			klog.V(4).Infof("Could not retrieve bound pod %s/%s for service account %s/%s: %v", namespace, podref.Name, namespace, saref.Name, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 21:15:10 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/cache/cache.go

    	}
    
    	cache.mu.RLock()
    	defer cache.mu.RUnlock()
    
    	return cache.assumedPods.Has(key), nil
    }
    
    // GetPod might return a pod for which its node has already been deleted from
    // the main cache. This is useful to properly process pod update events.
    func (cache *cacheImpl) GetPod(pod *v1.Pod) (*v1.Pod, error) {
    	key, err := framework.GetPodKey(pod)
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 24 09:56:48 UTC 2023
    - 24.9K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/interface.go

    		return nil
    	}
    	return &Status{
    		code: Error,
    		err:  err,
    	}
    }
    
    // WaitingPod represents a pod currently waiting in the permit phase.
    type WaitingPod interface {
    	// GetPod returns a reference to the waiting pod.
    	GetPod() *v1.Pod
    	// GetPendingPlugins returns a list of pending Permit plugin's name.
    	GetPendingPlugins() []string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
Back to top