- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for pidStatus (0.14 sec)
-
pkg/kubelet/status/status_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
makeAndSetFakePod(t, m, fakeRuntime, pod) podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace) assert.NoError(t, err) assert.Equal(t, pod.UID, podStatus.ID) assert.Equal(t, pod.Name, podStatus.Name) assert.Equal(t, pod.Namespace, podStatus.Namespace) assert.Equal(t, apitest.FakePodSandboxIPs, podStatus.IPs) } func TestStopContainerWithNotFoundError(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
} func shouldRestartOnFailure(pod *v1.Pod) bool { return pod.Spec.RestartPolicy != v1.RestartPolicyNever } func containerSucceeded(c *v1.Container, podStatus *kubecontainer.PodStatus) bool { cStatus := podStatus.FindContainerStatusByName(c.Name) if cStatus == nil || cStatus.State == kubecontainer.ContainerStateRunning { return false } return cStatus.ExitCode == 0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
kl.pod, kl.mirrorPod, kl.podStatus = pod, mirrorPod, podStatus kl.wg.Done() return false, nil } func (kl *simpleFakeKubelet) SyncTerminatingPod(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
// targeting. The target is stored as EphemeralContainer.TargetContainerName, which must be // resolved to a ContainerID using podStatus. The target container must already exist, which // usually isn't a problem since ephemeral containers aren't allowed at pod creation time. func (s *startSpec) getTargetID(podStatus *kubecontainer.PodStatus) (*kubecontainer.ContainerID, error) { if s.ephemeralContainer == nil || s.ephemeralContainer.TargetContainerName == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
expectMatch: false, }, { in: &api.Pod{ Status: api.PodStatus{Phase: api.PodRunning}, }, fieldSelector: fields.ParseSelectorOrDie("status.phase=Running"), expectMatch: true, }, { in: &api.Pod{ Status: api.PodStatus{Phase: api.PodRunning}, }, fieldSelector: fields.ParseSelectorOrDie("status.phase=Pending"), expectMatch: false,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
ResourceVersion: fmt.Sprint(n), }, Spec: v1.PodSpec{ Containers: []v1.Container{{ Name: "container-1", }}, NodeName: "node-1", }, Status: v1.PodStatus{ PodIP: fmt.Sprintf("1.2.3.%d", 4+n), PodIPs: []v1.PodIP{{ IP: fmt.Sprintf("1.2.3.%d", 4+n), }}, Conditions: []v1.PodCondition{ { Type: v1.PodReady, Status: status,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0)