- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 283 for containerId (0.3 sec)
-
pkg/kubelet/prober/prober.go
} // 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: probeSpec = container.LivenessProbe case startup: probeSpec = container.StartupProbe default:
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/instrumented_services.go
} func (in instrumentedRuntimeService) StartContainer(ctx context.Context, containerID string) error { const operation = "start_container" defer recordOperation(operation, time.Now()) err := in.service.StartContainer(ctx, containerID) recordError(operation, err) return err } func (in instrumentedRuntimeService) StopContainer(ctx context.Context, containerID string, timeout int64) error { const operation = "stop_container"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 13.1K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager_test.go
m.readinessManager.Set(kubecontainer.ParseContainerID(probedReady.ContainerID), results.Success, &v1.Pod{}) m.readinessManager.Set(kubecontainer.ParseContainerID(probedUnready.ContainerID), results.Failure, &v1.Pod{}) m.startupManager.Set(kubecontainer.ParseContainerID(startedNoReadiness.ContainerID), results.Success, &v1.Pod{}) m.readinessManager.Set(kubecontainer.ParseContainerID(terminated.ContainerID), results.Success, &v1.Pod{}) m.UpdatePodStatus(&v1.Pod{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
fakeOS.Removes) // Verify container is removed assert.Contains(t, fakeRuntime.Called, "RemoveContainer") containers, err := fakeRuntime.ListContainers(ctx, &runtimeapi.ContainerFilter{Id: containerID}) assert.NoError(t, err) assert.Empty(t, containers) } // TestKillContainer tests killing the container in a Pod. func TestKillContainer(t *testing.T) {
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
Stdout: test.stdout, Err: test.err, } prober := &prober{ runner: runner, } container := v1.Container{} containerID := kubecontainer.ContainerID{Type: "docker", ID: "containerID"} cmd := []string{"/foo", "bar"} exec := prober.newExecInContainer(ctx, container, containerID, cmd, 0) var dataBuffer bytes.Buffer writer := ioutils.LimitWriter(&dataBuffer, int64(limit))
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/kubelet/pod_container_deletor.go
} return nil }(filterContainerID, podStatus) if filterContainerID != "" && matchedContainer == nil { klog.InfoS("Container not found in pod's containers", "containerID", filterContainerID) return containerStatusbyCreatedList{} } // Find the exited containers whose name matches the name of the container with id being filterContainerId var candidates containerStatusbyCreatedList
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 4K bytes - Viewed (0) -
pkg/kubelet/status/fake_status_manager.go
} func (m *fakeManager) SetPodAllocation(pod *v1.Pod) error { klog.InfoS("SetPodAllocation()") for _, container := range pod.Spec.Containers { var alloc v1.ResourceList if container.Resources.Requests != nil { alloc = container.Resources.Requests.DeepCopy() } m.state.SetContainerResourceAllocation(string(pod.UID), container.Name, alloc) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_gc.go
continue } } if err := cgc.manager.removeContainer(ctx, containers[i].id); err != nil { klog.ErrorS(err, "Failed to remove container", "containerID", containers[i].id) } } // Assume we removed the containers so that we're not too aggressive. return containers[:numToKeep] } // removeOldestNSandboxes removes the oldest inactive toRemove sandboxes and // returns the resulting slice.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 15.3K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
// state, which is the set of containers that have attempted to start at least once. If all containers // are Waiting, the first container is always returned. func initializedContainers(containers []v1.ContainerStatus) []v1.ContainerStatus { for i := len(containers) - 1; i >= 0; i-- { if containers[i].State.Waiting == nil || containers[i].LastTerminationState.Terminated != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/legacy.go
) // legacyLogSymlink composes the legacy container log path. It is only used for legacy cluster // logging support. func legacyLogSymlink(containerID string, containerName, podName, podNamespace string) string { return logSymlink(legacyContainerLogsDir, kubecontainer.BuildPodFullName(podName, podNamespace), containerName, containerID) } // getContainerIDFromLegacyLogSymlink returns error if container Id cannot be parsed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 16:05:48 UTC 2022 - 2.7K bytes - Viewed (0)