- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 67 for newCodecFactory (0.21 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/etcd_test.go
wantHealthzChecks: nil, wantReadyzChecks: nil, wantLivezChecks: nil, skipHealth: true, }, } scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { serverConfig := server.NewConfig(codecs) etcdOptions := &EtcdOptions{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 16.4K bytes - Viewed (0) -
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/endpoints/filters/metrics_test.go
// This also implies that we can't run this test in parallel with other auth tests. authorizationAttemptsCounter.Reset() scheme := runtime.NewScheme() negotiatedSerializer := serializer.NewCodecFactory(scheme).WithoutConversion() for _, tt := range testCases { t.Run(tt.desc, func(t *testing.T) { defer authorizationAttemptsCounter.Reset()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 20 13:35:55 UTC 2023 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/apitesting/roundtrip/roundtrip.go
func RoundTripTestForScheme(t *testing.T, scheme *runtime.Scheme, fuzzingFuncs fuzzer.FuzzerFuncs) { codecFactory := runtimeserializer.NewCodecFactory(scheme) f := fuzzer.FuzzerFor( fuzzer.MergeFuzzerFuncs(metafuzzer.Funcs, fuzzingFuncs), rand.NewSource(rand.Int63()), codecFactory, ) RoundTripTypesWithoutProtobuf(t, scheme, codecFactory, f, nil) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 16.8K 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)