- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 67 for newCodecFactory (0.27 sec)
-
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/codec_factory.go
// TODO: accept a scheme interface func NewCodecFactory(scheme *runtime.Scheme, mutators ...CodecFactoryOptionsMutator) CodecFactory { options := CodecFactoryOptions{Pretty: true} for _, fn := range mutators { fn(&options) } serializers := newSerializersForScheme(scheme, json.DefaultMetaFactory, options) return newCodecFactory(scheme, serializers) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/codec_test.go
s.AddKnownTypeWithName(externalGV2.WithKind("TestType1"), &runtimetesting.ExternalTestType1{}) s.AddUnversionedTypes(externalGV, &metav1.Status{}) utilruntime.Must(runtimetesting.RegisterConversions(s)) cf := newCodecFactory(s, newSerializersForScheme(s, testMetaFactory{}, CodecFactoryOptions{Pretty: true, Strict: true})) codec := cf.LegacyCodec(schema.GroupVersion{Version: "v1"}) return s, codec }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured_test.go
// Finally, it checks that both the unstructured objects are equal. func TestUnstructuredMetadataRoundTrip(t *testing.T) { scheme := runtime.NewScheme() codecs := serializer.NewCodecFactory(scheme) seed := rand.Int63() fuzzer := fuzzer.FuzzerFor(metafuzzer.Funcs, rand.NewSource(seed), codecs) N := 1000 for i := 0; i < N; i++ { u := &unstructured.Unstructured{Object: map[string]interface{}{}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/bench_test.go
} for _, test := range tests { b.Run(test.gvk.Kind, func(b *testing.B) { f := managedfieldstest.NewTestFieldManager(fakeTypeConverter, test.gvk) decoder := serializer.NewCodecFactory(scheme).UniversalDecoder(test.gvk.GroupVersion()) newObj, err := runtime.Decode(decoder, test.obj) if err != nil { b.Fatalf("Failed to parse yaml object: %v", err) } objMeta, err := meta.Accessor(newObj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/kubelet/apis/config/scheme/scheme.go
} if err := kubeletconfigv1beta1.AddToScheme(scheme); err != nil { return nil, nil, err } if err := kubeletconfigv1.AddToScheme(scheme); err != nil { return nil, nil, err } codecs := serializer.NewCodecFactory(scheme, mutators...) return scheme, &codecs, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 09 06:11:06 UTC 2022 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/fake/register.go
schema "k8s.io/apimachinery/pkg/runtime/schema" serializer "k8s.io/apimachinery/pkg/runtime/serializer" utilruntime "k8s.io/apimachinery/pkg/util/runtime" ) var scheme = runtime.NewScheme() var codecs = serializer.NewCodecFactory(scheme) var localSchemeBuilder = runtime.SchemeBuilder{ crv1.AddToScheme, } // AddToScheme adds all types of this clientset into the given scheme. This allows composition // of clientsets, like in: //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/scheduler/apis/config/scheme/scheme.go
) var ( // Scheme is the runtime.Scheme to which all kubescheduler api types are registered. Scheme = runtime.NewScheme() // Codecs provides access to encoding and decoding for the scheme. Codecs = serializer.NewCodecFactory(Scheme, serializer.EnableStrict) ) func init() { AddToScheme(Scheme) } // AddToScheme builds the kubescheduler scheme using all known versions of the kubescheduler api.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 17 05:27:21 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/config.go
resourcequotav1 "k8s.io/apiserver/pkg/admission/plugin/resourcequota/apis/resourcequota/v1" ) var ( scheme = runtime.NewScheme() codecs = serializer.NewCodecFactory(scheme) ) func init() { install.Install(scheme) } // LoadConfiguration loads the provided configuration. func LoadConfiguration(config io.Reader) (*resourcequotaapi.Configuration, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/scheme/register.go
schema "k8s.io/apimachinery/pkg/runtime/schema" serializer "k8s.io/apimachinery/pkg/runtime/serializer" utilruntime "k8s.io/apimachinery/pkg/util/runtime" ) var Scheme = runtime.NewScheme() var Codecs = serializer.NewCodecFactory(Scheme) var ParameterCodec = runtime.NewParameterCodec(Scheme) var localSchemeBuilder = runtime.SchemeBuilder{ apiextensionsv1.AddToScheme, apiextensionsv1beta1.AddToScheme, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 21:36:26 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/apiserver/load/load.go
api "k8s.io/apiserver/pkg/apis/apiserver" "k8s.io/apiserver/pkg/apis/apiserver/install" externalapi "k8s.io/apiserver/pkg/apis/apiserver/v1alpha1" ) var ( scheme = runtime.NewScheme() codecs = serializer.NewCodecFactory(scheme, serializer.EnableStrict) ) func init() { install.Install(scheme) } func LoadFromFile(file string) (*api.AuthorizationConfiguration, error) { data, err := os.ReadFile(file) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 06:28:47 UTC 2023 - 2.1K bytes - Viewed (0)