- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for newCodecFactory (0.28 sec)
-
staging/src/k8s.io/api/roundtrip_test.go
storagev1beta1.SchemeBuilder, storagev1.SchemeBuilder, svmv1alpha1.SchemeBuilder, } func TestRoundTripExternalTypes(t *testing.T) { scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) for _, builder := range groups { require.NoError(t, builder.AddToScheme(scheme)) } seed := rand.Int63() // I'm only using the generic fuzzer funcs, but at some point in time we might need to
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
"k8s.io/apiserver/pkg/storage/etcd3" etcd3testing "k8s.io/apiserver/pkg/storage/etcd3/testing" "k8s.io/apiserver/pkg/storage/value/encrypt/identity" ) var ( scheme = runtime.NewScheme() codecs = serializer.NewCodecFactory(scheme) ) func init() { metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) utilruntime.Must(example.AddToScheme(scheme)) utilruntime.Must(examplev1.AddToScheme(scheme))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory_test.go
"k8s.io/apiserver/pkg/storage/storagebackend" ) var ( v1GroupVersion = schema.GroupVersion{Group: "", Version: "v1"} scheme = runtime.NewScheme() codecs = serializer.NewCodecFactory(scheme) ) func init() { metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) scheme.AddUnversionedTypes(v1GroupVersion, &metav1.Status{}, &metav1.APIVersions{}, &metav1.APIGroupList{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/client.go
return ClientManager{}, err } } return ClientManager{ cache: cache, negotiatedSerializer: serializer.NegotiatedSerializerWrapper(runtime.SerializerInfo{ Serializer: serializer.NewCodecFactory(hookScheme).LegacyCodec(gvs...), }), }, nil } // SetAuthenticationInfoResolverWrapper sets the // AuthenticationInfoResolverWrapper.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease_test.go
metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) utilruntime.Must(corev1.AddToScheme(scheme)) utilruntime.Must(scheme.SetVersionPriority(corev1.SchemeGroupVersion)) codecs = serializer.NewCodecFactory(scheme) } var codecs serializer.CodecFactory type serverInfo struct { existingIP string id string ports []corev1.EndpointPort newIP string removeLease bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/webhooks/validation/server/server.go
"istio.io/istio/pkg/kube" "istio.io/istio/pkg/log" ) var scope = log.RegisterScope("validationServer", "validation webhook server") var ( runtimeScheme = runtime.NewScheme() codecs = serializer.NewCodecFactory(runtimeScheme) deserializer = codecs.UniversalDeserializer() // Expect AdmissionRequest to only include these top-level field names validFields = map[string]bool{ "apiVersion": true, "kind": true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 04 06:13:56 UTC 2024 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/apiserver.go
genericapiserver "k8s.io/apiserver/pkg/server" serverstorage "k8s.io/apiserver/pkg/server/storage" "k8s.io/apiserver/pkg/util/webhook" ) var ( Scheme = runtime.NewScheme() Codecs = serializer.NewCodecFactory(Scheme) // if you modify this, make sure you update the crEncoder unversionedVersion = schema.GroupVersion{Group: "", Version: "v1"} unversionedTypes = []runtime.Object{ &metav1.Status{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 14:31:43 UTC 2023 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/serving_test.go
cliflag "k8s.io/component-base/cli/flag" "k8s.io/klog/v2/ktesting" netutils "k8s.io/utils/net" ) func setUp(t *testing.T) server.Config { scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) config := server.NewConfig(codecs) return *config } type TestCertSpec struct { host string names, ips []string // in certificate } type NamedTestCertSpec struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 15:52:39 UTC 2024 - 13.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/roundtripper.go
var statusScheme = runtime.NewScheme() // ParameterCodec knows about query parameters used with the meta v1 API spec. var statusCodecs = serializer.NewCodecFactory(statusScheme) func init() { statusScheme.AddUnversionedTypes(metav1.SchemeGroupVersion, &metav1.Status{}, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler_test.go
var codecs = runtimeserializer.NewCodecFactory(scheme) const discoveryPath = "/apis" func init() { utilruntime.Must(apidiscoveryv2.AddToScheme(scheme)) utilruntime.Must(apidiscoveryv2beta1.AddToScheme(scheme)) // Register conversion for apidiscovery utilruntime.Must(apidiscoveryv2conversion.RegisterConversions(scheme)) codecs = runtimeserializer.NewCodecFactory(scheme) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 00:29:39 UTC 2024 - 28.6K bytes - Viewed (0)