pkg/runtime/serializer/codec_factory.go

对原始decoder、encoder的封装：

  1. 在decoder中会清除对象的GroupVersionKind
  2. 在encoder中，会在序列化时写入GroupVersionKind
  1. // WithoutConversionCodecFactory is a CodecFactory that will explicitly ignore requests to perform conversion.
  2. // This wrapper is used while code migrates away from using conversion (such as external clients) and in the future
  3. // will be unnecessary when we change the signature of NegotiatedSerializer.
  4. type WithoutConversionCodecFactory struct {
  5.     CodecFactory
  6. }
  8. // EncoderForVersion returns an encoder that does not do conversion, but does set the group version kind of the object
  9. // when serialized.
  10. func (f WithoutConversionCodecFactory) EncoderForVersion(serializer runtime.Encoder, version runtime.GroupVersioner) runtime.Encoder {
  11.     return runtime.WithVersionEncoder{
  12.         Version:     version,
  13.         Encoder:     serializer,
  14.         ObjectTyper: f.CodecFactory.scheme,
  15.     }
  16. }
  18. // DecoderToVersion returns an decoder that does not do conversion.
  19. func (f WithoutConversionCodecFactory) DecoderToVersion(serializer runtime.Decoder, _ runtime.GroupVersioner) runtime.Decoder {
  20.     return runtime.WithoutVersionDecoder{
  21.         Decoder: serializer,
  22.     }
  23. }

WithoutVersionDecoder：

  1. // WithoutVersionDecoder clears the group version kind of a deserialized object.
  2. type WithoutVersionDecoder struct {
  3.     Decoder
  4. }
  6. // Decode does not do conversion. It removes the gvk during deserialization.
  7. func (d WithoutVersionDecoder) Decode(data []byte, defaults *schema.GroupVersionKind, into Object) (Object, *schema.GroupVersionKind, error) {
  8.     obj, gvk, err := d.Decoder.Decode(data, defaults, into)
  9.     if obj != nil {
  10.         kind := obj.GetObjectKind()
  11.         // clearing the gvk is just a convention of a codec
  12.         kind.SetGroupVersionKind(schema.GroupVersionKind{})
  13.     }
  14.     return obj, gvk, err
  15. }

WithVersionEncoder：

  1. // WithVersionEncoder serializes an object and ensures the GVK is set.
  2. type WithVersionEncoder struct {
  3.     Version GroupVersioner
  4.     Encoder
  5.     ObjectTyper
  6. }
  8. // Encode does not do conversion. It sets the gvk during serialization.
  9. func (e WithVersionEncoder) Encode(obj Object, stream io.Writer) error {
  10.     gvks, _, err := e.ObjectTyper.ObjectKinds(obj)
  11.     if err != nil {
  12.         if IsNotRegisteredError(err) {
  13.             return e.Encoder.Encode(obj, stream)
  14.         }
  15.         return err
  16.     }
  17.     kind := obj.GetObjectKind()
  18.     oldGVK := kind.GroupVersionKind()
  19.     gvk := gvks[0]
  20.     if e.Version != nil {
  21.         preferredGVK, ok := e.Version.KindForGroupVersionKinds(gvks)
  22.         if ok {
  23.             gvk = preferredGVK
  24.         }
  25.     }
  26.     kind.SetGroupVersionKind(gvk)
  27.     err = e.Encoder.Encode(obj, stream)
  28.     kind.SetGroupVersionKind(oldGVK)
  29.     return err
  30. }