Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for rtHandlers (0.19 sec)

  1. pkg/kubelet/runtime.go

    	s.Lock()
    	defer s.Unlock()
    	s.runtimeError = err
    }
    
    func (s *runtimeState) setRuntimeHandlers(rtHandlers []kubecontainer.RuntimeHandler) {
    	s.Lock()
    	defer s.Unlock()
    	s.rtHandlers = rtHandlers
    }
    
    func (s *runtimeState) runtimeHandlers() []kubecontainer.RuntimeHandler {
    	s.RLock()
    	defer s.RUnlock()
    	return s.rtHandlers
    }
    
    func (s *runtimeState) setStorageState(err error) {
    	s.Lock()
    	defer s.Unlock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_getters.go

    func (kl *Kubelet) HandlerSupportsUserNamespaces(rtHandler string) (bool, error) {
    	rtHandlers := kl.runtimeState.runtimeHandlers()
    	if rtHandlers == nil {
    		return false, fmt.Errorf("runtime handlers are not set")
    	}
    	for _, h := range rtHandlers {
    		if h.Name == rtHandler {
    			return h.SupportsUserNamespaces, nil
    		}
    	}
    	return false, fmt.Errorf("the handler %q is not known", rtHandler)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 09 00:48:07 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/helpers.go

    			Reason:  c.Reason,
    			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)
Back to top