Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewMultiGroupVersioner (0.3 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/storage/storage_codec.go

    		runtime.NewBase64Serializer(nil, opts.StorageSerializer.UniversalDeserializer()),
    	}
    	if opts.DecoderDecoratorFn != nil {
    		decoders = opts.DecoderDecoratorFn(decoders)
    	}
    
    	encodeVersioner := runtime.NewMultiGroupVersioner(
    		opts.StorageVersion,
    		schema.GroupKind{Group: opts.StorageVersion.Group},
    		schema.GroupKind{Group: opts.MemoryVersion.Group},
    	)
    
    	// Ensure the storage receives the correct version.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 15:03:23 UTC 2022
    - 3.8K bytes
    - Viewed (0)
  2. pkg/controlplane/apiserver/apiextensions.go

    	etcdOptions.StorageConfig.EncodeVersioner = runtime.NewMultiGroupVersioner(v1beta1.SchemeGroupVersion, schema.GroupKind{Group: v1beta1.GroupName})
    	etcdOptions.SkipHealthEndpoints = true // avoid double wiring of health checks
    	if err := etcdOptions.ApplyTo(&genericConfig); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 18:08:20 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/runtime/codec.go

    	acceptedGroupKinds []schema.GroupKind
    	coerce             bool
    }
    
    // NewMultiGroupVersioner returns the provided group version for any kind that matches one of the provided group kinds.
    // Kind may be empty in the provided group kind, in which case any kind will match.
    func NewMultiGroupVersioner(gv schema.GroupVersion, groupKinds ...schema.GroupKind) GroupVersioner {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 03:20:30 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/runtime/scheme_test.go

    		{
    			scheme: GetTestScheme(),
    			in:     &runtimetesting.ExternalTestType1{A: "test"},
    			gv:     runtime.NewMultiGroupVersioner(schema.GroupVersion{Group: "other", Version: "v2"}, schema.GroupKind{Group: "custom", Kind: "TestType3"}, schema.GroupKind{Kind: "TestType1"}),
    			out: &runtimetesting.ExternalTestType1{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 38.2K bytes
    - Viewed (0)
  5. pkg/controlplane/apiserver/aggregator.go

    	etcdOptions := *commandOptions.Etcd
    	etcdOptions.StorageConfig.Codec = aggregatorscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion, v1beta1.SchemeGroupVersion)
    	etcdOptions.StorageConfig.EncodeVersioner = runtime.NewMultiGroupVersioner(v1.SchemeGroupVersion, schema.GroupKind{Group: v1beta1.GroupName})
    	etcdOptions.SkipHealthEndpoints = true // avoid double wiring of health checks
    	if err := etcdOptions.ApplyTo(&genericConfig); err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 18:08:20 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  6. pkg/api/testing/serialization_test.go

    	if err != nil {
    		t.Fatalf("unexpected encoding error: %v", err)
    	}
    
    	decoder := legacyscheme.Codecs.DecoderToVersion(
    		legacyscheme.Codecs.UniversalDeserializer(),
    		runtime.NewMultiGroupVersioner(
    			defaultGroup,
    			schema.GroupKind{Group: defaultGroup.Group},
    			schema.GroupKind{Group: extGroup.Group},
    		),
    	)
    
    	t.Logf("rs.v1.apps -> rc._internal")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 11:04:08 UTC 2023
    - 19.3K bytes
    - Viewed (0)
Back to top