Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 561 for Pods (0.04 sec)

  1. pkg/kubelet/util/sliceutils/sliceutils_test.go

    	fooTests := []struct {
    		pods PodsByCreationTime
    		i    int
    		j    int
    	}{
    		{buildPodsByCreationTime(), 0, 1},
    		{buildPodsByCreationTime(), 2, 1},
    	}
    
    	for _, fooTest := range fooTests {
    		fooi := fooTest.pods[fooTest.i]
    		fooj := fooTest.pods[fooTest.j]
    		fooTest.pods.Swap(fooTest.i, fooTest.j)
    		if fooi.GetName() != fooTest.pods[fooTest.j].GetName() || fooj.GetName() != fooTest.pods[fooTest.i].GetName() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 13 08:27:42 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  2. pkg/client/tests/fake_client_test.go

    	}
    
    	wrongPod, err := tc.CoreV1().Pods("nsB").Get(context.TODO(), "pod-1", metav1.GetOptions{})
    	if err == nil {
    		t.Fatalf("Pods.Get: expected nsB/pod-1 not to match, but it matched %s/%s", wrongPod.Namespace, wrongPod.Name)
    	}
    
    	allPods, err := tc.CoreV1().Pods(metav1.NamespaceAll).List(context.TODO(), metav1.ListOptions{})
    	if err != nil {
    		t.Fatalf("Pods.List: %s", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 08 17:30:21 UTC 2020
    - 5.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/policy/v1/generated.proto

      // all pods within the namespace.
      // +patchStrategy=replace
      // +optional
      optional .k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector selector = 2;
    
      // An eviction is allowed if at most "maxUnavailable" pods selected by
      // "selector" are unavailable after the eviction, i.e. even in absence of
      // the evicted pod. For example, one can prevent all voluntary evictions
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. samples/external/README.md

    see errors such as 404s, HTTPS connection problems, and TCP connection problems.  If
    ServiceEntries are misconfigured pods may see problems with server names.
    
    ## Try it out
    
    After an operator runs `kubectl create -f aptget.yaml` pods will be able to
    succeed with `apt-get update` and `apt-get install`.
    
    After an operator runs `kubectl create -f github.yaml` pods will be able to
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jul 27 18:28:55 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  5. pkg/kubelet/pod/pod_manager_test.go

    	updates := append(expectedPods, mirrorPod)
    	podManager, _ := newTestManager()
    	podManager.SetPods(updates)
    
    	// Tests that all regular pods are recorded correctly.
    	actualPods := podManager.GetPods()
    	if len(actualPods) != len(expectedPods) {
    		t.Errorf("expected %d pods, got %d pods; expected pods %#v, got pods %#v", len(expectedPods), len(actualPods),
    			expectedPods, actualPods)
    	}
    	for _, expected := range expectedPods {
    		found := false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:27 UTC 2023
    - 5.4K bytes
    - Viewed (0)
  6. pkg/scheduler/util/utils.go

    		return pod.Status.StartTime
    	}
    	// Assumed pods and bound pods that haven't started don't have a StartTime yet.
    	return &metav1.Time{Time: time.Now()}
    }
    
    // GetEarliestPodStartTime returns the earliest start time of all pods that
    // have the highest priority among all victims.
    func GetEarliestPodStartTime(victims *extenderv1.Victims) *metav1.Time {
    	if len(victims.Pods) == 0 {
    		// should not reach here.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 01:40:44 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/cache/debugger/comparer.go

    }
    
    // ComparePods compares actual pods with cached pods.
    func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) {
    	actual := []string{}
    	for _, pod := range pods {
    		actual = append(actual, string(pod.UID))
    	}
    
    	cached := []string{}
    	for _, nodeinfo := range nodeinfos {
    		for _, p := range nodeinfo.Pods {
    			cached = append(cached, string(p.Pod.UID))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  8. pkg/kubelet/apis/podresources/server_v1alpha1.go

    }
    
    // List returns information about the resources assigned to pods on the node
    func (p *v1alpha1PodResourcesServer) List(ctx context.Context, req *v1alpha1.ListPodResourcesRequest) (*v1alpha1.ListPodResourcesResponse, error) {
    	metrics.PodResourcesEndpointRequestsTotalCount.WithLabelValues("v1alpha1").Inc()
    	pods := p.podsProvider.GetPods()
    	podResources := make([]*v1alpha1.PodResources, len(pods))
    	p.devicesProvider.UpdateAllocatedDevices()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:01 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  9. pkg/kubelet/apis/podresources/types.go

    // DevicesProvider knows how to provide the devices used by the given container
    type DevicesProvider interface {
    	// UpdateAllocatedDevices frees any Devices that are bound to terminated pods.
    	UpdateAllocatedDevices()
    	// GetDevices returns information about the devices assigned to pods and containers
    	GetDevices(podUID, containerName string) []*podresourcesapi.ContainerDevices
    	// GetAllocatableDevices returns information about all the devices known to the manager
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 17:33:04 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  10. pkg/kubelet/config/http.go

    			pods = append(pods, &podList.Items[i])
    		}
    		s.updates <- kubetypes.PodUpdate{Pods: pods, Op: kubetypes.SET, Source: kubetypes.HTTPSource}
    		return nil
    	}
    
    	return fmt.Errorf("%v: received '%v', but couldn't parse as "+
    		"single (%v) or multiple pods (%v)",
    		s.url, string(data), singlePodErr, multiPodErr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 01 07:19:44 UTC 2021
    - 4.1K bytes
    - Viewed (0)
Back to top