- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for runtimeHandler (0.2 sec)
-
pkg/kubelet/images/image_gc_manager.go
imageKey = getImageTuple(image.ID, image.Spec.RuntimeHandler) klog.V(5).InfoS("Adding image ID with runtime class to currentImages", "imageKey", imageKey, "runtimeHandler", image.Spec.RuntimeHandler) } currentImages.Insert(imageKey) // New image, set it as detected now. if _, ok := im.imageRecords[imageKey]; !ok { klog.V(5).InfoS("Image ID is new", "imageID", imageKey, "runtimeHandler", image.Spec.RuntimeHandler)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kubelet/images/image_manager_test.go
image := images[0] assert.Equal(t, "missing_image:latest", image.ID, "Image ID") assert.Equal(t, "", image.Spec.RuntimeHandler, "image.Spec.RuntimeHandler not empty", "ImageID", image.ID) expectedAnnotations := []Annotation{ { Name: "kubernetes.io/runtimehandler", Value: "handler_name", }} assert.Equal(t, expectedAnnotations, image.Spec.Annotations, "image spec annotations") }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/instrumented_services.go
const operation = "run_podsandbox" startTime := time.Now() defer recordOperation(operation, startTime) defer metrics.RunPodSandboxDuration.WithLabelValues(runtimeHandler).Observe(metrics.SinceInSeconds(startTime)) out, err := in.service.RunPodSandbox(ctx, config, runtimeHandler) recordError(operation, err) if err != nil {
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/images/image_gc_manager_test.go
func makeImageWithRuntimeHandler(id int, size int64, runtimeHandler string) container.Image { if runtimeHandler == "" { return container.Image{ ID: imageID(id), Size: size, } } else { return container.Image{ ID: imageID(id), Size: size, Spec: container.ImageSpec{ RuntimeHandler: runtimeHandler, }, } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 15:38:20 UTC 2024 - 29.2K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_test.go
if len(m.podList) == 0 { return nil, nil } return m.podList, nil } func (m *testUserNsPodsManager) HandlerSupportsUserNamespaces(runtimeHandler string) (bool, error) { if runtimeHandler == "error" { return false, errors.New("unknown runtime") } return m.userns, nil } func (m *testUserNsPodsManager) GetKubeletMappings() (uint32, uint32, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_sandbox.go
return "", message, err } runtimeHandler := "" if m.runtimeClassManager != nil { runtimeHandler, err = m.runtimeClassManager.LookupRuntimeHandler(pod.Spec.RuntimeClassName) if err != nil { message := fmt.Sprintf("Failed to create sandbox for pod %q: %v", format.Pod(pod), err) return "", message, err } if runtimeHandler != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers_test.go
c := &runtimeapi.Container{ Id: "test-id", Metadata: &runtimeapi.ContainerMetadata{ Name: "test-name", Attempt: 1, }, Image: &runtimeapi.ImageSpec{Image: "test-image", RuntimeHandler: "test-runtimeHandler"}, ImageId: "test-image-id", ImageRef: "test-image-ref", State: runtimeapi.ContainerState_CONTAINER_RUNNING, Annotations: map[string]string{ containerHashLabel: "1234", }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers.go
Message: c.Message, }) } retHandlers := make([]kubecontainer.RuntimeHandler, len(handlers)) for i, h := range handlers { supportsRRO := false supportsUserns := false if h.Features != nil { supportsRRO = h.Features.RecursiveReadOnlyMounts supportsUserns = h.Features.UserNamespaces } retHandlers[i] = kubecontainer.RuntimeHandler{ Name: h.Name,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 12K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
if handlerSupportsUserns, err := m.kl.HandlerSupportsUserNamespaces(runtimeHandler); err != nil { return nil, err } else if !handlerSupportsUserns { return nil, fmt.Errorf("RuntimeClass handler %q does not support user namespaces", runtimeHandler) } m.lock.Lock() defer m.lock.Unlock() content, err := m.readMappingsFromFile(pod.UID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/api/node/v1alpha1/generated.pb.go
return 0, err } i -= size i = encodeVarintGenerated(dAtA, i, uint64(size)) } i-- dAtA[i] = 0x12 } i -= len(m.RuntimeHandler) copy(dAtA[i:], m.RuntimeHandler) i = encodeVarintGenerated(dAtA, i, uint64(len(m.RuntimeHandler))) i-- dAtA[i] = 0xa return len(dAtA) - i, nil } func (m *Scheduling) Marshal() (dAtA []byte, err error) { size := m.Size()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 40.2K bytes - Viewed (0)