- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 248 for Implementation (0.3 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go
return handler } initAPFOnce.Do(func() { initMaxInFlight(0, 0) // Fetching these gauges is delayed until after their underlying metric has been registered // so that this latches onto the efficient implementation. waitingMark.readOnlyObserver = fcmetrics.GetWaitingReadonlyConcurrency() waitingMark.mutatingObserver = fcmetrics.GetWaitingMutatingConcurrency() }) clock := &utilsclock.RealClock{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 15.3K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/generated.proto
// but should apply for any default implementation. If set, it is assumed that a load balancer // implementation is watching for Services with a matching class. Any default load balancer // implementation (e.g. cloud providers) should ignore Services that set this field. // This field can only be set when creating or updating a Service to type 'LoadBalancer'.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 280.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/interfaces.go
// current version of the object to avoid read operation from storage to get it. // However, the implementations have to retry in case suggestion is stale. // // Example: // // s := /* implementation of Interface */ // err := s.GuaranteedUpdate( // "myKey", &MyType{}, true, preconditions,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/apis/core/types.go
// but should apply for any default implementation. If set, it is assumed that a load balancer // implementation is watching for Services with a matching class. Any default load balancer // implementation (e.g. cloud providers) should ignore Services that set this field. // This field can only be set when creating or updating a Service to type 'LoadBalancer'.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 268.9K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types_swagger_doc_generated.go
"internalTrafficPolicy":...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 254.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
// error format. type ErrorResponder interface { Error(w http.ResponseWriter, req *http.Request, err error) } // SimpleErrorResponder is the legacy implementation of ErrorResponder for callers that only // service a single request/response per proxy. type SimpleErrorResponder interface { Error(err error) } func NewErrorResponder(r SimpleErrorResponder) ErrorResponder {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
) (map[string]*extenderv1.Victims, error) { nodeNameToVictimsCopy := map[string]*extenderv1.Victims{} // We don't want to change the original nodeNameToVictims for k, v := range nodeNameToVictims { // In real world implementation, extender's user should have their own way to get node object // by name if needed (e.g. query kube-apiserver etc). // // For test purpose, we just use node from parameters directly. nodeNameToVictimsCopy[k] = v
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_executor.go
type VolumeLogger interface { // Creates a detailed msg that can be used in logs // The msg format follows the pattern "<prefixMsg> <volume details> <suffixMsg>", // where each implementation provides the volume details GenerateMsgDetailed(prefixMsg, suffixMsg string) (detailedMsg string) // Creates a detailed error that can be used in logs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 42.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/aes/aes_test.go
if aead.NonceSize() != 12 { t.Errorf("The underlying Golang crypto size has changed, old version of AES on disk will not be readable unless the AES implementation is changed to hardcode nonce size.") } transformerCounterNonce, _, err := NewGCMTransformerWithUniqueKeyUnsafe() if err != nil { t.Fatal(err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 23.2K bytes - Viewed (0) -
staging/src/k8s.io/api/resource/v1alpha2/types_swagger_doc_generated.go
*/ package v1alpha2 // 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: Thu Mar 14 17:07:36 UTC 2024 - 22.4K bytes - Viewed (0)