- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for PodID (0.89 sec)
-
pkg/kubelet/pleg/evented_test.go
for _, podStatus := range podStatuses[:2] { podId := string(podStatus.ID) newPodStatus := kubecontainer.PodStatus{ ID: podStatus.ID, SandboxStatuses: []*v1.PodSandboxStatus{ {Id: podId}, }, ContainerStatuses: []*kubecontainer.Status{ // update state to container exited {ID: kubecontainer.ContainerID{ID: podId}, State: kubecontainer.ContainerStateExited}, }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 01 07:45:05 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_linux_test.go
"disk4": kubecontainer.VolumeInfo{Mounter: &stubVolume{path: "/mnt/host"}}, "disk5": kubecontainer.VolumeInfo{Mounter: &stubVolume{path: "/var/lib/kubelet/podID/volumes/empty/disk5"}}, }, container: v1.Container{ Name: "container1", VolumeMounts: []v1.VolumeMount{ { MountPath: "/etc/hosts", Name: "disk",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 18:00:59 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/pod_devices_test.go
) func TestGetContainerDevices(t *testing.T) { podDevices := newPodDevices() resourceName1 := "domain1.com/resource1" podID := "pod1" contID := "con1" devices := checkpoint.DevicesPerNUMA{0: []string{"dev1"}, 1: []string{"dev1"}} podDevices.insert(podID, contID, resourceName1, devices, newContainerAllocateResponse(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
"portForward": {url: "/portForward/podNamespace/podID", bucket: "portForward"}, "portForward with uid": {url: "/portForward/podNamespace/podID/uid", bucket: "portForward"}, "run": {url: "/run/podNamespace/podID/containerName", bucket: "run"}, "run with uid": {url: "/run/podNamespace/podID/uid/containerName", bucket: "run"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
tests/integration/security/cacert_rotation/main_test.go
}) }) } func getWorkloadCertLastUpdateTime(t framework.TestContext, i echo.Instance, ctl istioctl.Instance) (time.Time, error) { podID, err := getPodID(i) if err != nil { t.Fatalf("Could not get Pod ID: %v", err) } podName := fmt.Sprintf("%s.%s", podID, i.NamespaceName()) out, errOut, err := ctl.Invoke([]string{"pc", "s", podName, "-o", "json"}) if err != nil || errOut != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/controller/controller_utils.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
pkg/controller/replication/conversion.go
} func (pc podControlAdapter) DeletePod(ctx context.Context, namespace string, podID string, object runtime.Object) error { rc, err := convertRStoRC(object.(*apps.ReplicaSet)) if err != nil { return err } return pc.PodControlInterface.DeletePod(ctx, namespace, podID, rc)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
func (u *UnschedulablePods) addOrUpdate(pInfo *framework.QueuedPodInfo) { podID := u.keyFunc(pInfo.Pod) if _, exists := u.podInfoMap[podID]; !exists { if pInfo.Gated && u.gatedRecorder != nil { u.gatedRecorder.Inc() } else if !pInfo.Gated && u.unschedulableRecorder != nil { u.unschedulableRecorder.Inc() } } u.podInfoMap[podID] = pInfo } // delete deletes a pod from the unschedulable podInfoMap.
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/test/framework/components/istio/ingress.go
return "", fmt.Errorf("must provide either protocol or scheme") } if opts.Scheme != "" { return opts.Scheme, nil } return opts.Port.Scheme() } func (c *ingressImpl) PodID(i int) (string, error) { pods, err := c.env.Clusters().Default().PodsForSelector(context.TODO(), c.service.Namespace, c.labelSelector) if err != nil { return "", fmt.Errorf("unable to get ingressImpl gateway stats: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 17:13:34 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
func (f *fakePodControl) DeletePod(ctx context.Context, namespace string, podID string, object runtime.Object) error { f.Lock() defer f.Unlock() if err := f.FakePodControl.DeletePod(ctx, namespace, podID, object); err != nil { return fmt.Errorf("failed to delete pod %q", podID) } pod, ok := f.podIDMap[podID] if !ok { return fmt.Errorf("pod %q does not exist", podID) } f.podStore.Delete(pod) delete(f.podIDMap, podID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0)