- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for container1 (0.22 sec)
-
pkg/kubelet/volumemanager/volume_manager_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
return false } } return true } // HashContainer returns the hash of the container. It is used to compare // the running container with its desired spec. // Note: remember to update hashValues in container_hash_test.go as well. func HashContainer(container *v1.Container) uint64 { hash := fnv.New32a() containerJSON, _ := json.Marshal(pickFieldsToHash(container))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
// ContainerReasonStatusUnknown indicates a container the status of the container cannot be determined. const ContainerReasonStatusUnknown string = "ContainerStatusUnknown" // Container provides the runtime information for a container, such as ID, hash, // state of the container. type Container struct { // The ID of the container, used by the container runtime to identify // a container. ID ContainerID
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
Kubernetes Kubernetes `json:"kubernetes"` } // K8sArgs is the valid CNI_ARGS used for Kubernetes // The field names need to match exact keys in containerd args for unmarshalling // https://github.com/containerd/containerd/blob/ced9b18c231a28990617bc0a4b8ce2e81ee2ffa1/pkg/cri/server/sandbox_run.go#L526-L532 type K8sArgs struct { types.CommonArgs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.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/pleg/generic.go
} func getContainersFromPods(pods ...*kubecontainer.Pod) []*kubecontainer.Container { cidSet := sets.New[string]() var containers []*kubecontainer.Container fillCidSet := func(cs []*kubecontainer.Container) { for _, c := range cs { cid := c.ID.ID if cidSet.Has(cid) { continue } cidSet.Insert(cid) containers = append(containers, c) } } for _, p := range pods { if p == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
pkg/test/kube/dump.go
for _, pod := range pods { isVM := checkIfVM(pod) containers := append(pod.Spec.Containers, pod.Spec.InitContainers...) for _, container := range containers { l, err := c.PodLogs(context.TODO(), pod.Name, pod.Namespace, container.Name, false /* previousLog */) if err != nil { scopes.Framework.Warnf("Unable to get logs for cluster/pod/container: %s/%s/%s/%s for: %v",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/config/config_test.go
config.Sync() expectPodUpdate(t, ch, CreatePodUpdate(kubetypes.SET, kubetypes.AllSource, CreateValidPod("foo", "new"))) // container updates are separated as UPDATE pod := *podUpdate.Pods[0] pod.Spec.Containers = []v1.Container{{Name: "bar", Image: "test", ImagePullPolicy: v1.PullIfNotPresent, TerminationMessagePolicy: v1.TerminationMessageReadFile}} channel <- CreatePodUpdate(kubetypes.ADD, TestSource, &pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/kube/util.go
t.GetObjectMeta().SetManagedFields(nil) // only container ports can be used if pod := obj.(*corev1.Pod); pod != nil { containers := []corev1.Container{} for _, c := range pod.Spec.Containers { if len(c.Ports) > 0 { containers = append(containers, corev1.Container{ Ports: c.Ports, }) } } oldSpec := pod.Spec newSpec := corev1.PodSpec{ Containers: containers,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
pkg/controller/job/backoff_utils_test.go
}, // In this case, init container is stopped after the regular containers. // This is because with the sidecar (restartable init) containers, // sidecar containers will always finish later than regular containers. "Pod with sidecar container and all containers terminated": { pod: v1.Pod{ Spec: v1.PodSpec{ InitContainers: []v1.Container{ { Name: "sidecar",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 07:46:41 UTC 2024 - 16.7K bytes - Viewed (0)