Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 117 for CONTAINERID (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top