- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 117 for CONTAINERID (0.15 sec)
-
staging/src/k8s.io/api/testdata/HEAD/core.v1.PodStatusResult.yaml
type: typeValue containerStatuses: - allocatedResources: allocatedResourcesKey: "0" containerID: containerIDValue image: imageValue imageID: imageIDValue lastState: running: startedAt: "2001-01-01T01:01:01Z" terminated: containerID: containerIDValue exitCode: 1 finishedAt: "2006-01-01T01:01:01Z" message: messageValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
continue } lcset := m.lastUpdateState.GetCPUSetOrDefault(string(pod.UID), container.Name) if !cset.Equals(lcset) { klog.V(4).InfoS("ReconcileState: updating container", "pod", klog.KObj(pod), "containerName", container.Name, "containerID", containerID, "cpuSet", cset) err = m.updateContainerCPUSet(ctx, containerID, cset) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (0) -
pkg/kubelet/prober/prober.go
var err error var result probe.Result var output string for i := 0; i < retries; i++ { result, output, err = pb.runProbe(ctx, probeType, p, pod, status, container, containerID) if err == nil { return result, output, nil } }
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/container/runtime.go
ID string } // BuildContainerID returns the ContainerID given type and id. func BuildContainerID(typ, ID string) ContainerID { return ContainerID{Type: typ, ID: ID} } // ParseContainerID is a convenience method for creating a ContainerID from an ID string. func ParseContainerID(containerID string) ContainerID { var id ContainerID if err := id.ParseString(containerID); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K 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/status/status_manager.go
"pod", klog.KObj(pod), "containerID", containerID.String()) return } // Find the container to update. containerStatus, _, ok := findContainerStatus(&oldStatus.status, containerID.String()) if !ok { klog.InfoS("Container readiness changed for unknown container", "pod", klog.KObj(pod), "containerID", containerID.String()) return }
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/kuberuntime_container_test.go
assert.NoError(t, err) assert.Empty(t, containers) } // TestKillContainer tests killing the container in a Pod. func TestKillContainer(t *testing.T) { _, _, m, _ := createTestRuntimeManager() tests := []struct { caseName string pod *v1.Pod containerID kubecontainer.ContainerID containerName string
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
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)) exec.SetStderr(writer)
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
buffer := make(chan kubecontainer.ContainerID, containerDeletorBufferLimit) go wait.Until(func() { for { id := <-buffer if err := runtime.DeleteContainer(context.Background(), id); err != nil { klog.InfoS("DeleteContainer returned error", "containerID", id, "err", err) } } }, 0, wait.NeverStop) return &podContainerDeletor{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 4K bytes - Viewed (0)