Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 395 for Implementation (0.17 sec)

  1. pkg/volume/util/hostutil/hostutil_windows.go

    func (hu *HostUtil) PathIsDevice(pathname string) (bool, error) {
    	return false, nil
    }
    
    // MakeRShared checks that given path is on a mount with 'rshared' mount
    // propagation. Empty implementation here.
    func (hu *HostUtil) MakeRShared(path string) error {
    	return nil
    }
    
    func isSystemCannotAccessErr(err error) bool {
    	if fserr, ok := err.(*fs.PathError); ok {
    		errno, ok := fserr.Err.(syscall.Errno)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 13:38:40 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/node/v1beta1/types_swagger_doc_generated.go

    */
    
    package v1beta1
    
    // This file contains a collection of methods that can be used from go-restful to
    // generate Swagger API documentation for its models. Please read this PR for more
    // information on the implementation: https://github.com/emicklei/go-restful/pull/215
    //
    // TODOs are ignored from the parser (e.g. TODO(andronat):... || TODO:...) if and only if
    // they are on one line! For multiple line or blocks that you want to ignore use ---.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 22 00:51:25 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. pkg/kubelet/pluginmanager/reconciler/reconciler_test.go

    type DummyImpl struct{}
    
    func NewDummyImpl() *DummyImpl {
    	return &DummyImpl{}
    }
    
    // ValidatePlugin is a dummy implementation
    func (d *DummyImpl) ValidatePlugin(pluginName string, endpoint string, versions []string) error {
    	return nil
    }
    
    // RegisterPlugin is a dummy implementation
    func (d *DummyImpl) RegisterPlugin(pluginName string, endpoint string, versions []string, pluginClientTimeout *time.Duration) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:21:15 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    		ExecSeatsGaugeVec:      metrics.PriorityLevelExecutionSeatsGaugeVec,
    		QueueSetFactory:        fqs.NewQueueSetFactory(clk),
    	})
    }
    
    // TestableConfig carries the parameters to an implementation that is testable
    type TestableConfig struct {
    	// Name of the controller
    	Name string
    
    	// Clock to use in timing deliberate delays
    	Clock clock.PassiveClock
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
  5. pkg/volume/util/io_util.go

    	ReadDir(dirname string) ([]os.FileInfo, error)
    	Lstat(name string) (os.FileInfo, error)
    	EvalSymlinks(path string) (string, error)
    }
    
    type osIOHandler struct{}
    
    // NewIOHandler Create a new IoHandler implementation
    func NewIOHandler() IoUtil {
    	return &osIOHandler{}
    }
    
    func (handler *osIOHandler) ReadFile(filename string) ([]byte, error) {
    	return os.ReadFile(filename)
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 20 14:49:03 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  6. pkg/volume/util/selinux.go

    	// or don't support SELinux at all.
    	SELinuxOptionsToFileLabel(opts *v1.SELinuxOptions) (string, error)
    
    	// SELinuxEnabled returns true when the OS has enabled SELinux support.
    	SELinuxEnabled() bool
    }
    
    // Real implementation of the interface.
    // On Linux with SELinux enabled it translates. Otherwise it always returns an empty string and no error.
    type translator struct{}
    
    var _ SELinuxLabelTranslator = &translator{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 20 14:40:21 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  7. pkg/kubelet/util/manager/cache_based_manager.go

    		}
    	}
    	return data.object, data.err
    }
    
    // cacheBasedManager keeps a store with objects necessary
    // for registered pods. Different implementations of the store
    // may result in different semantics for freshness of objects
    // (e.g. ttl-based implementation vs watch-based implementation).
    type cacheBasedManager struct {
    	objectStore          Store
    	getReferencedObjects func(*v1.Pod) sets.Set[string]
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  8. pkg/kubelet/stats/cri_stats_provider.go

    		}
    		s, ok := status.FromError(err)
    		// Legitimate failure, rather than the CRI implementation does not support ListPodSandboxStats.
    		if !ok || s.Code() != codes.Unimplemented {
    			return nil, err
    		}
    		// CRI implementation doesn't support ListPodSandboxStats, warn and fallback.
    		klog.V(5).ErrorS(err,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go

    	storagetesting.RunWatchSemanticInitialEventsExtended(ctx, t, store)
    }
    
    // =======================================================================
    // Implementation-specific tests are following.
    // The following tests are exercising the details of the implementation
    // not the actual user-facing contract of storage interface.
    // As such, they may focus e.g. on non-functional aspects like performance
    // impact.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go

    		finalWork := SeatsTimesDuration(float64(finalSeats), e.config.eventAdditionalDuration())
    
    		// While processing individual events is highly parallel,
    		// the design/implementation of P&F has a couple limitations that
    		// make using this assumption in the P&F implementation very
    		// inefficient because:
    		// - we reserve max(initialSeats, finalSeats) for time of executing
    		//   both phases of the request
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 17 19:26:52 UTC 2023
    - 6K bytes
    - Viewed (0)
Back to top