- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 185 for Implementation (1.78 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/responsewriter/wrapper.go
UserProvidedDecorator: decorator, InnerCloseNotifierFlusher: innerNotifierFlusher, } if innerHijacker, hijackable := inner.(http.Hijacker); hijackable { // for HTTP/1.x request the default implementation of ResponseWriter // also implement CloseNotifier, Flusher and Hijacker return &outerWithCloseNotifyFlushAndHijack{ outerWithCloseNotifyAndFlush: outerHTTP2, InnerHijacker: innerHijacker, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 7K bytes - Viewed (0) -
pkg/apis/node/types.go
type RuntimeClass struct { metav1.TypeMeta // +optional metav1.ObjectMeta // handler specifies the underlying runtime and configuration that the CRI // implementation will use to handle pods of this class. The possible values // are specific to the node & CRI configuration. It is assumed that all // handlers are available on every node, and handlers of the same name are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 22 08:59:25 UTC 2022 - 3.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/linearized_read_test.go
// List calls. Today, the mechanism etcd uses to increment the store revision ensures that linearized reads // do *not* bump the key-value store revision. This test exists to ensure that we notice if this implementation // detail ever changes. // [1] https://etcd.io/docs/v3.5/learning/api_guarantees/#isolation-level-and-consistency-of-replicas ctx, store, etcdClient := testSetup(t) dir := "/testing" key := dir + "/testkey"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 07 20:08:59 UTC 2022 - 2.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake/clientset_generated.go
if err != nil { return false, nil, err } return true, watch, nil }) return cs } // Clientset implements clientset.Interface. Meant to be embedded into a // struct to get a default implementation. This makes faking out just the method // you want to test easier. type Clientset struct { testing.Fake discovery *fakediscovery.FakeDiscovery tracker testing.ObjectTracker }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/api/node/v1/types.go
// +optional metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` // handler specifies the underlying runtime and configuration that the CRI // implementation will use to handle pods of this class. The possible values // are specific to the node & CRI configuration. It is assumed that all // handlers are available on every node, and handlers of the same name are
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 4.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/validating/plugin.go
func Register(plugins *admission.Plugins) { plugins.Register(PluginName, func(configFile io.Reader) (admission.Interface, error) { return NewPlugin(configFile), nil }) } // Plugin is an implementation of admission.Interface. type Policy = v1.ValidatingAdmissionPolicy type PolicyBinding = v1.ValidatingAdmissionPolicyBinding type PolicyEvaluator = Validator
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service.go
kmsservice "k8s.io/kms/pkg/service" "k8s.io/kms/pkg/util" ) const ( // unixProtocol is the only supported protocol for remote KMS provider. unixProtocol = "unix" ) // The gRPC implementation for envelope.Service. type gRPCService struct { kmsClient kmsapi.KeyManagementServiceClient connection *grpc.ClientConn callTimeout time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 23:18:16 UTC 2023 - 4.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/versionconverter.go
"k8s.io/apimachinery/pkg/runtime/schema" "sigs.k8s.io/structured-merge-diff/v4/fieldpath" "sigs.k8s.io/structured-merge-diff/v4/merge" "sigs.k8s.io/structured-merge-diff/v4/typed" ) // versionConverter is an implementation of // sigs.k8s.io/structured-merge-diff/merge.Converter type versionConverter struct { typeConverter TypeConverter objectConvertor runtime.ObjectConvertor
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 3.7K bytes - Viewed (0) -
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) -
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)