Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 62 for runtimeHandler (0.24 sec)

  1. pkg/kubelet/container/runtime.go

    		sh = append(sh, h.String())
    	}
    	return fmt.Sprintf("Runtime Conditions: %s; Handlers: %s", strings.Join(ss, ", "), strings.Join(sh, ", "))
    }
    
    // RuntimeHandler contains condition information for the runtime handler.
    type RuntimeHandler struct {
    	// Name is the handler name.
    	Name string
    	// SupportsRecursiveReadOnlyMounts is true if the handler has support for
    	// recursive read-only mounts.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  2. pkg/kubelet/images/image_manager.go

    		podAnnotations = append(podAnnotations, kubecontainer.Annotation{
    			Name:  k,
    			Value: v,
    		})
    	}
    
    	spec := kubecontainer.ImageSpec{
    		Image:          image,
    		Annotations:    podAnnotations,
    		RuntimeHandler: podRuntimeHandler,
    	}
    
    	imageRef, err := m.imageService.GetImageRef(ctx, spec)
    	if err != nil {
    		msg := fmt.Sprintf("Failed to inspect image %q: %v", container.Image, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 08 00:30:31 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_image_test.go

    	_, _, fakeManager, err := createTestRuntimeManager()
    	assert.NoError(t, err)
    
    	imageSpec := kubecontainer.ImageSpec{
    		Image: "12345",
    		Annotations: []kubecontainer.Annotation{
    			{Name: "kubernetes.io/runtimehandler", Value: "handler_name"},
    		},
    	}
    
    	_, err = fakeManager.PullImage(ctx, imageSpec, nil, nil)
    	assert.NoError(t, err)
    
    	images, err := fakeManager.ListImages(ctx)
    	assert.NoError(t, err)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kuberuntime/kuberuntime_sandbox_test.go

    			if test.expectError {
    				assert.Error(t, err)
    			} else {
    				assert.NoError(t, err)
    				assert.Contains(t, fakeRuntime.Called, "RunPodSandbox")
    				assert.Equal(t, test.expectedHandler, fakeRuntime.Sandboxes[id].RuntimeHandler)
    			}
    		})
    	}
    }
    
    func newTestPod() *v1.Pod {
    	return &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			UID:       "12345678",
    			Name:      "bar",
    			Namespace: "new",
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_container.go

    	container := spec.container
    
    	// Step 1: pull the image.
    
    	// If RuntimeClassInImageCriAPI feature gate is enabled, pass runtimehandler
    	// information for the runtime class specified. If not runtime class is
    	// specified, then pass ""
    	podRuntimeHandler := ""
    	var err error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  6. pkg/kubelet/container/helpers.go

    	GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64
    
    	// GetOrCreateUserNamespaceMappings returns the configuration for the sandbox user namespace
    	GetOrCreateUserNamespaceMappings(pod *v1.Pod, runtimeHandler string) (*runtimeapi.UserNamespace, error)
    
    	// PrepareDynamicResources prepares resources for a pod.
    	PrepareDynamicResources(pod *v1.Pod) error
    
    	// UnprepareDynamicResources unprepares resources for a a pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. pkg/kubelet/nodestatus/setters.go

    		return nil
    	}
    }
    
    // RuntimeHandlers returns a Setter that sets RuntimeHandlers on the node.
    func RuntimeHandlers(fn func() []kubecontainer.RuntimeHandler) Setter {
    	return func(ctx context.Context, node *v1.Node) error {
    		if !utilfeature.DefaultFeatureGate.Enabled(features.RecursiveReadOnlyMounts) {
    			return nil
    		}
    		handlers := fn()
    		node.Status.RuntimeHandlers = make([]v1.NodeRuntimeHandler, len(handlers))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods.go

    func runtimeHandlerSupportsRecursiveReadOnlyMounts(runtimeHandlerName string, runtimeHandlers []kubecontainer.RuntimeHandler) bool {
    	if len(runtimeHandlers) == 0 {
    		// The runtime does not support returning the handler list.
    		// No need to print a warning here.
    		return false
    	}
    	for _, h := range runtimeHandlers {
    		if h.Name == runtimeHandlerName {
    			return h.SupportsRecursiveReadOnlyMounts
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.29.md

    - Added new feature gate called `RuntimeClassInImageCriApi` to address `kubelet` changes needed for KEP 4216.
      Noteable changes:
      1. Populate new `RuntimeHandler` field in CRI's `ImageSpec` struct during image pulls from container runtimes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 03:42:38 UTC 2024
    - 324.5K bytes
    - Viewed (0)
  10. staging/src/k8s.io/client-go/applyconfigurations/core/v1/nodestatus.go

    	VolumesAttached []AttachedVolumeApplyConfiguration     `json:"volumesAttached,omitempty"`
    	Config          *NodeConfigStatusApplyConfiguration    `json:"config,omitempty"`
    	RuntimeHandlers []NodeRuntimeHandlerApplyConfiguration `json:"runtimeHandlers,omitempty"`
    }
    
    // NodeStatusApplyConfiguration constructs an declarative configuration of the NodeStatus type for use with
    // apply.
    func NodeStatus() *NodeStatusApplyConfiguration {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 13 23:06:39 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top