Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for CONTAINERID (0.14 sec)

  1. pkg/kubelet/prober/worker.go

    			return true // Wait for more information.
    		}
    	}
    
    	if w.containerID.String() != c.ContainerID {
    		if !w.containerID.IsEmpty() {
    			w.resultsManager.Remove(w.containerID)
    		}
    		w.containerID = kubecontainer.ParseContainerID(c.ContainerID)
    		w.resultsManager.Set(w.containerID, w.initialValue, w.pod)
    		// We've got a new container; resume probing.
    		w.onHold = false
    	}
    
    	if w.onHold {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 27 01:28:06 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  2. pkg/kubelet/userns/userns_manager_test.go

    	                        "gidMappings":[ { "hostId":131072, "containerId":0, "length":userNsLength }, { "hostId":196608, "containerId":0, "length":65536 } ]
                                   }`,
    			success: false,
    		},
    		{
    			name: "two UID mappings",
    			file: `{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  3. pkg/kubelet/lifecycle/handlers_test.go

    		}
    	}
    }
    
    type fakeContainerCommandRunner struct {
    	Cmd []string
    	ID  kubecontainer.ContainerID
    	Err error
    	Msg string
    }
    
    func (f *fakeContainerCommandRunner) RunInContainer(_ context.Context, id kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) {
    	f.Cmd = cmd
    	f.ID = id
    	return []byte(f.Msg), f.Err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 24.4K 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/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)
  8. 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)
  9. pkg/kubelet/container/testing/fake_runtime.go

    	// actual values when invoked
    	ContainerID kubecontainer.ContainerID
    	Cmd         []string
    }
    
    var _ kubecontainer.CommandRunner = &FakeContainerCommandRunner{}
    
    func (f *FakeContainerCommandRunner) RunInContainer(_ context.Context, containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) {
    	// record invoked values
    	f.ContainerID = containerID
    	f.Cmd = cmd
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 00:23:50 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/memorymanager/memory_manager.go

    func (m *manager) RemoveContainer(containerID string) error {
    	m.Lock()
    	defer m.Unlock()
    
    	// if error appears it means container entry already does not exist under the container map
    	podUID, containerName, err := m.containerMap.GetContainerRef(containerID)
    	if err != nil {
    		klog.InfoS("Failed to get container from container map", "containerID", containerID, "err", err)
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (1)
Back to top