Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 187 for Implementation (0.15 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go

    // such as retry requests.
    type GenericWebhook struct {
    	RestClient   *rest.RESTClient
    	RetryBackoff wait.Backoff
    	ShouldRetry  func(error) bool
    }
    
    // DefaultShouldRetry is a default implementation for the GenericWebhook ShouldRetry function property.
    // If the error reason is one of: networking (connection reset) or http (InternalServerError (500), GatewayTimeout (504), TooManyRequests (429)),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 19:02:55 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  2. pkg/scheduler/metrics/metric_recorder.go

    // metric Inc(), Dec() and Clear()
    type MetricRecorder interface {
    	Inc()
    	Dec()
    	Clear()
    }
    
    var _ MetricRecorder = &PendingPodsRecorder{}
    
    // PendingPodsRecorder is an implementation of MetricRecorder
    type PendingPodsRecorder struct {
    	recorder metrics.GaugeMetric
    }
    
    // NewActivePodsRecorder returns ActivePods in a Prometheus metric fashion
    func NewActivePodsRecorder() *PendingPodsRecorder {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 16 07:27:08 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  3. pkg/volume/util/hostutil/fake_hostutil.go

    limitations under the License.
    */
    
    package hostutil
    
    import (
    	"errors"
    	"os"
    	"sync"
    
    	"k8s.io/mount-utils"
    )
    
    // FakeHostUtil is a fake HostUtils implementation for testing
    type FakeHostUtil struct {
    	MountPoints []mount.MountPoint
    	Filesystem  map[string]FileType
    
    	mutex sync.Mutex
    }
    
    // NewFakeHostUtil returns a struct that implements the HostUtils interface
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 13:32:38 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  4. pkg/util/filesystem/watcher.go

    type fsnotifyWatcher struct {
    	watcher      *fsnotify.Watcher
    	eventHandler FSEventHandler
    	errorHandler FSErrorHandler
    }
    
    var _ FSWatcher = &fsnotifyWatcher{}
    
    // NewFsnotifyWatcher returns an implementation of FSWatcher that continuously listens for
    // fsnotify events and calls the event handler as soon as an event is received.
    func NewFsnotifyWatcher() FSWatcher {
    	return &fsnotifyWatcher{}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/certificates/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
    - 5.9K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/dra/state/state_checkpoint.go

    	// CDIDevices is a map of DriverName --> CDI devices returned by the
    	// GRPC API call NodePrepareResource
    	CDIDevices map[string][]string
    }
    
    // ClaimInfoStateWithoutResourceHandles is an old implementation of the ClaimInfoState
    // TODO: remove in Beta
    type ClaimInfoStateWithoutResourceHandles struct {
    	// Name of the DRA driver
    	DriverName string
    
    	// ClassName is a resource class of the claim
    	ClassName string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:27 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/server/filters/maxinflight.go

    func initMaxInFlight(nonMutatingLimit, mutatingLimit int) {
    	initMaxInFlightOnce.Do(func() {
    		// Fetching these gauges is delayed until after their underlying metric has been registered
    		// so that this latches onto the efficient implementation.
    		watermark.readOnlyObserver = fcmetrics.GetExecutingReadonlyConcurrency()
    		watermark.mutatingObserver = fcmetrics.GetExecutingMutatingConcurrency()
    		if nonMutatingLimit != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 08 11:34:15 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/authentication/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: Wed Mar 08 23:42:33 UTC 2023
    - 5.1K bytes
    - Viewed (0)
  9. pkg/scheduler/internal/cache/interface.go

    	// DO NOT use outside of tests.
    	PodCount() (int, error)
    
    	// AssumePod assumes a pod scheduled and aggregates the pod's information into its node.
    	// The implementation also decides the policy to expire pod before being confirmed (receiving Add event).
    	// After expiration, its information would be subtracted.
    	AssumePod(logger klog.Logger, pod *v1.Pod) error
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 5.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/events/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.9K bytes
    - Viewed (0)
Back to top