- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 186 for pidStatus (0.18 sec)
-
pkg/kubelet/prober/prober.go
return } pb.recorder.Eventf(ref, eventType, reason, message, args...) } // probe probes the container. func (pb *prober) probe(ctx context.Context, probeType probeType, pod *v1.Pod, status v1.PodStatus, container v1.Container, containerID kubecontainer.ContainerID) (results.Result, error) { var probeSpec *v1.Probe switch probeType { case readiness: probeSpec = container.ReadinessProbe case liveness:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:50:13 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
} fakeRunner := &containertest.FakeContainerCommandRunner{} fakeHTTP := &fakeHTTP{} fakePodStatusProvider := podStatusProviderFunc(func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { return &kubecontainer.PodStatus{ ID: uid, Name: name, Namespace: namespace, IPs: []string{ "127.0.0.1", }, }, nil }) lcHanlder := lifecycle.NewHandlerRunner(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
pkg/kubelet/prober/prober_test.go
{&v1.HTTPGetAction{Host: "hostname", Port: intstr.FromInt32(76), Path: "path"}, true, "hostname", 76, "path"}, } for _, test := range testCases { state := v1.PodStatus{PodIP: "127.0.0.1"} container := v1.Container{ Ports: []v1.ContainerPort{{Name: "found", ContainerPort: 93}}, LivenessProbe: &v1.Probe{ ProbeHandler: v1.ProbeHandler{ HTTPGet: test.probe, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:35 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
// Test name, num of containers, restarts, container ready status api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "test1"}, Spec: api.PodSpec{Containers: make([]api.Container, 2)}, Status: api.PodStatus{ Phase: "podPhase", ContainerStatuses: []api.ContainerStatus{ {Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}}, {RestartCount: 3}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/example/v1/types.go
// +optional Status PodStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` } // PodStatus represents information about the status of a pod. Status may trail the actual // state of a system. type PodStatus struct { // Current condition of the pod. // More info: http://kubernetes.io/docs/user-guide/pod-states#pod-phase
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
func IsPodReadyConditionTrue(status v1.PodStatus) bool { condition := GetPodReadyCondition(status) return condition != nil && condition.Status == v1.ConditionTrue } func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition { _, condition := GetPodCondition(&status, v1.PodReady) return condition } func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K 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/apis/core/v1/conversion.go
out.Annotations = dropInitContainerAnnotations(out.Annotations) return nil } func Convert_v1_PodStatus_To_core_PodStatus(in *v1.PodStatus, out *core.PodStatus, s conversion.Scope) error { if err := autoConvert_v1_PodStatus_To_core_PodStatus(in, out, s); err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:30:55 UTC 2024 - 19K bytes - Viewed (0) -
cluster/gce/gci/audit_policy_test.go
podMetrics = resource("podmetrics", "default", "metrics.k8s.io") nodeMetrics = resource("nodemetrics", "", "metrics.k8s.io") pods = resource("pods", "default") podStatus = resource("pods", "default", "", "status") secrets = resource("secrets", "default") tokenReviews = resource("tokenreviews", "", "authentication.k8s.io")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 30 06:23:50 UTC 2021 - 9.8K bytes - Viewed (0) -
pkg/kubelet/lifecycle/handlers_test.go
return podStatusProviderFunc(func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { return &kubecontainer.PodStatus{ ID: uid, Name: name, Namespace: namespace, IPs: []string{podIP}, }, nil }) } type podStatusProviderFunc func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0)