Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DecoderToVersion (0.38 sec)

  1. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete_test.go

    			s, err := negotiation.NegotiateInputSerializer(req, false, test.codecFactory)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			options := &metav1.DeleteOptions{}
    			_, _, err = metainternalversionscheme.Codecs.DecoderToVersion(s.Serializer, defaultGVK.GroupVersion()).Decode(test.data, &defaultGVK, options)
    			if test.expectErr != "" {
    				if err == nil {
    					t.Fatalf("expect %s but got nil", test.expectErr)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jul 03 16:16:51 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/storage/storage_codec.go

    	)
    
    	// Ensure the storage receives the correct version.
    	encoder = opts.StorageSerializer.EncoderForVersion(
    		encoder,
    		encodeVersioner,
    	)
    	decoder := opts.StorageSerializer.DecoderToVersion(
    		recognizer.NewDecoder(decoders...),
    		runtime.NewCoercingMultiGroupVersioner(
    			opts.MemoryVersion,
    			schema.GroupKind{Group: opts.MemoryVersion.Group},
    			schema.GroupKind{Group: opts.StorageVersion.Group},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Nov 05 15:03:23 UTC 2022
    - 3.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/storage/storage_factory_test.go

    	return n.serializer
    }
    
    func (n *fakeNegotiater) EncoderForVersion(serializer runtime.Encoder, gv runtime.GroupVersioner) runtime.Encoder {
    	return n.serializer
    }
    
    func (n *fakeNegotiater) DecoderToVersion(serializer runtime.Decoder, gv runtime.GroupVersioner) runtime.Decoder {
    	return n.serializer
    }
    
    func TestConfigurableStorageFactory(t *testing.T) {
    	ns := &fakeNegotiater{types: []string{"test/test"}}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 13:35:58 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  4. pkg/api/testing/serialization_proto_test.go

    	for i := range items {
    		data, err := runtime.Encode(encoder, &items[i])
    		if err != nil {
    			b.Fatal(err)
    		}
    		encoded = append(encoded, data)
    	}
    
    	decoder := legacyscheme.Codecs.DecoderToVersion(s, api.SchemeGroupVersion)
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		if _, err := runtime.Decode(decoder, encoded[i%width]); err != nil {
    			b.Fatal(err)
    		}
    	}
    	b.StopTimer()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 25 16:23:43 UTC 2022
    - 7.1K bytes
    - Viewed (0)
Back to top