- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 393 for Implementation (0.18 sec)
-
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) -
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) -
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) -
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) -
staging/src/k8s.io/cli-runtime/pkg/printers/jsonpath.go
if v.IsNil() { return v, true } if v.Kind() == reflect.Interface && v.NumMethod() > 0 { break } } return v, false } // JSONPathPrinter is an implementation of ResourcePrinter which formats data with jsonpath expression. type JSONPathPrinter struct { rawTemplate string *jsonpath.JSONPath } func NewJSONPathPrinter(tmpl string) (*JSONPathPrinter, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 4.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/endpointsadapter.go
utilnet "k8s.io/utils/net" ) // EndpointsAdapter provides a simple interface for reading and writing both // Endpoints and Endpoint Slices. // NOTE: This is an incomplete adapter implementation that is only suitable for // use in this package. This takes advantage of the Endpoints used in this // package always having a consistent set of ports, a single subset, and a small
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 27 12:46:23 UTC 2022 - 7.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/errors/errors.go
type Aggregate interface { error Errors() []error Is(error) bool } // NewAggregate converts a slice of errors into an Aggregate interface, which // is itself an implementation of the error interface. If the slice is empty, // this returns nil. // It will check if any of the element of input error list is nil, to avoid // nil pointer panic when call Error().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 29 09:44:02 UTC 2023 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
// jitter is applied per step and is not cumulative over multiple steps nextDuration, duration, steps = delay(steps, duration, cap, factor, jitter) return nextDuration } } // Timer returns a timer implementation appropriate to this backoff's parameters // for use with wait functions. func (b Backoff) Timer() Timer { if b.Steps > 1 || b.Jitter != 0 { return &variableTimer{new: internalClock.NewTimer, fn: b.DelayFunc()} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/timing_ratio_histogram.go
// When scraped it produces a histogram of samples of the ratio // taken at the end of every nanosecond. // `*TimingRatioHistogram` implements both Registerable and RatioedGauge. type TimingRatioHistogram struct { // The implementation is layered on TimingHistogram, // adding the division by an occasionally adjusted denominator. // Registerable is the registerable aspect. // That is the registerable aspect of the underlying TimingHistogram.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 03 06:51:04 UTC 2023 - 8.6K bytes - Viewed (0) -
pkg/printers/tablegenerator.go
} type handlerEntry struct { columnDefinitions []metav1.TableColumnDefinition printFunc reflect.Value } // HumanReadableGenerator is an implementation of TableGenerator used to generate // a table for a specific resource. The table is printed with a TablePrinter using // PrintObj(). type HumanReadableGenerator struct { handlerMap map[reflect.Type]*handlerEntry }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 5.9K bytes - Viewed (0)