- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 70 for newCodecFactory (0.29 sec)
-
istioctl/pkg/tag/generate.go
}) if err != nil { return "", fmt.Errorf("failed rendering istio-control manifest: %v", err) } scheme := runtime.NewScheme() codecFactory := serializer.NewCodecFactory(scheme) deserializer := codecFactory.UniversalDeserializer() serializer := json.NewSerializerWithOptions( json.DefaultMetaFactory, nil, nil, json.SerializerOptions{ Yaml: true, Pretty: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 17:43:49 UTC 2024 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/config.go
data, err := os.ReadFile(configFilePath) if err != nil { return nil, fmt.Errorf("unable to read admission control configuration from %q [%v]", configFilePath, err) } codecs := serializer.NewCodecFactory(configScheme) decoder := codecs.UniversalDecoder() decodedObj, err := runtime.Decode(decoder, data) // we were able to decode the file successfully if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 5.8K bytes - Viewed (0) -
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)