123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252 |
- /*
- Copyright 2014 The Kubernetes Authors.
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
- package runtime
- import (
- "io"
- "net/url"
- "k8s.io/apimachinery/pkg/runtime/schema"
- )
- const (
- // APIVersionInternal may be used if you are registering a type that should not
- // be considered stable or serialized - it is a convention only and has no
- // special behavior in this package.
- APIVersionInternal = "__internal"
- )
- // GroupVersioner refines a set of possible conversion targets into a single option.
- type GroupVersioner interface {
- // KindForGroupVersionKinds returns a desired target group version kind for the given input, or returns ok false if no
- // target is known. In general, if the return target is not in the input list, the caller is expected to invoke
- // Scheme.New(target) and then perform a conversion between the current Go type and the destination Go type.
- // Sophisticated implementations may use additional information about the input kinds to pick a destination kind.
- KindForGroupVersionKinds(kinds []schema.GroupVersionKind) (target schema.GroupVersionKind, ok bool)
- }
- // Encoders write objects to a serialized form
- type Encoder interface {
- // Encode writes an object to a stream. Implementations may return errors if the versions are
- // incompatible, or if no conversion is defined.
- Encode(obj Object, w io.Writer) error
- }
- // Decoders attempt to load an object from data.
- type Decoder interface {
- // Decode attempts to deserialize the provided data using either the innate typing of the scheme or the
- // default kind, group, and version provided. It returns a decoded object as well as the kind, group, and
- // version from the serialized data, or an error. If into is non-nil, it will be used as the target type
- // and implementations may choose to use it rather than reallocating an object. However, the object is not
- // guaranteed to be populated. The returned object is not guaranteed to match into. If defaults are
- // provided, they are applied to the data by default. If no defaults or partial defaults are provided, the
- // type of the into may be used to guide conversion decisions.
- Decode(data []byte, defaults *schema.GroupVersionKind, into Object) (Object, *schema.GroupVersionKind, error)
- }
- // Serializer is the core interface for transforming objects into a serialized format and back.
- // Implementations may choose to perform conversion of the object, but no assumptions should be made.
- type Serializer interface {
- Encoder
- Decoder
- }
- // Codec is a Serializer that deals with the details of versioning objects. It offers the same
- // interface as Serializer, so this is a marker to consumers that care about the version of the objects
- // they receive.
- type Codec Serializer
- // ParameterCodec defines methods for serializing and deserializing API objects to url.Values and
- // performing any necessary conversion. Unlike the normal Codec, query parameters are not self describing
- // and the desired version must be specified.
- type ParameterCodec interface {
- // DecodeParameters takes the given url.Values in the specified group version and decodes them
- // into the provided object, or returns an error.
- DecodeParameters(parameters url.Values, from schema.GroupVersion, into Object) error
- // EncodeParameters encodes the provided object as query parameters or returns an error.
- EncodeParameters(obj Object, to schema.GroupVersion) (url.Values, error)
- }
- // Framer is a factory for creating readers and writers that obey a particular framing pattern.
- type Framer interface {
- NewFrameReader(r io.ReadCloser) io.ReadCloser
- NewFrameWriter(w io.Writer) io.Writer
- }
- // SerializerInfo contains information about a specific serialization format
- type SerializerInfo struct {
- // MediaType is the value that represents this serializer over the wire.
- MediaType string
- // EncodesAsText indicates this serializer can be encoded to UTF-8 safely.
- EncodesAsText bool
- // Serializer is the individual object serializer for this media type.
- Serializer Serializer
- // PrettySerializer, if set, can serialize this object in a form biased towards
- // readability.
- PrettySerializer Serializer
- // StreamSerializer, if set, describes the streaming serialization format
- // for this media type.
- StreamSerializer *StreamSerializerInfo
- }
- // StreamSerializerInfo contains information about a specific stream serialization format
- type StreamSerializerInfo struct {
- // EncodesAsText indicates this serializer can be encoded to UTF-8 safely.
- EncodesAsText bool
- // Serializer is the top level object serializer for this type when streaming
- Serializer
- // Framer is the factory for retrieving streams that separate objects on the wire
- Framer
- }
- // NegotiatedSerializer is an interface used for obtaining encoders, decoders, and serializers
- // for multiple supported media types. This would commonly be accepted by a server component
- // that performs HTTP content negotiation to accept multiple formats.
- type NegotiatedSerializer interface {
- // SupportedMediaTypes is the media types supported for reading and writing single objects.
- SupportedMediaTypes() []SerializerInfo
- // EncoderForVersion returns an encoder that ensures objects being written to the provided
- // serializer are in the provided group version.
- EncoderForVersion(serializer Encoder, gv GroupVersioner) Encoder
- // DecoderForVersion returns a decoder that ensures objects being read by the provided
- // serializer are in the provided group version by default.
- DecoderToVersion(serializer Decoder, gv GroupVersioner) Decoder
- }
- // StorageSerializer is an interface used for obtaining encoders, decoders, and serializers
- // that can read and write data at rest. This would commonly be used by client tools that must
- // read files, or server side storage interfaces that persist restful objects.
- type StorageSerializer interface {
- // SupportedMediaTypes are the media types supported for reading and writing objects.
- SupportedMediaTypes() []SerializerInfo
- // UniversalDeserializer returns a Serializer that can read objects in multiple supported formats
- // by introspecting the data at rest.
- UniversalDeserializer() Decoder
- // EncoderForVersion returns an encoder that ensures objects being written to the provided
- // serializer are in the provided group version.
- EncoderForVersion(serializer Encoder, gv GroupVersioner) Encoder
- // DecoderForVersion returns a decoder that ensures objects being read by the provided
- // serializer are in the provided group version by default.
- DecoderToVersion(serializer Decoder, gv GroupVersioner) Decoder
- }
- // NestedObjectEncoder is an optional interface that objects may implement to be given
- // an opportunity to encode any nested Objects / RawExtensions during serialization.
- type NestedObjectEncoder interface {
- EncodeNestedObjects(e Encoder) error
- }
- // NestedObjectDecoder is an optional interface that objects may implement to be given
- // an opportunity to decode any nested Objects / RawExtensions during serialization.
- type NestedObjectDecoder interface {
- DecodeNestedObjects(d Decoder) error
- }
- ///////////////////////////////////////////////////////////////////////////////
- // Non-codec interfaces
- type ObjectDefaulter interface {
- // Default takes an object (must be a pointer) and applies any default values.
- // Defaulters may not error.
- Default(in Object)
- }
- type ObjectVersioner interface {
- ConvertToVersion(in Object, gv GroupVersioner) (out Object, err error)
- }
- // ObjectConvertor converts an object to a different version.
- type ObjectConvertor interface {
- // Convert attempts to convert one object into another, or returns an error. This
- // method does not mutate the in object, but the in and out object might share data structures,
- // i.e. the out object cannot be mutated without mutating the in object as well.
- // The context argument will be passed to all nested conversions.
- Convert(in, out, context interface{}) error
- // ConvertToVersion takes the provided object and converts it the provided version. This
- // method does not mutate the in object, but the in and out object might share data structures,
- // i.e. the out object cannot be mutated without mutating the in object as well.
- // This method is similar to Convert() but handles specific details of choosing the correct
- // output version.
- ConvertToVersion(in Object, gv GroupVersioner) (out Object, err error)
- ConvertFieldLabel(version, kind, label, value string) (string, string, error)
- }
- // ObjectTyper contains methods for extracting the APIVersion and Kind
- // of objects.
- type ObjectTyper interface {
- // ObjectKinds returns the all possible group,version,kind of the provided object, true if
- // the object is unversioned, or an error if the object is not recognized
- // (IsNotRegisteredError will return true).
- ObjectKinds(Object) ([]schema.GroupVersionKind, bool, error)
- // Recognizes returns true if the scheme is able to handle the provided version and kind,
- // or more precisely that the provided version is a possible conversion or decoding
- // target.
- Recognizes(gvk schema.GroupVersionKind) bool
- }
- // ObjectCreater contains methods for instantiating an object by kind and version.
- type ObjectCreater interface {
- New(kind schema.GroupVersionKind) (out Object, err error)
- }
- // ResourceVersioner provides methods for setting and retrieving
- // the resource version from an API object.
- type ResourceVersioner interface {
- SetResourceVersion(obj Object, version string) error
- ResourceVersion(obj Object) (string, error)
- }
- // SelfLinker provides methods for setting and retrieving the SelfLink field of an API object.
- type SelfLinker interface {
- SetSelfLink(obj Object, selfLink string) error
- SelfLink(obj Object) (string, error)
- // Knowing Name is sometimes necessary to use a SelfLinker.
- Name(obj Object) (string, error)
- // Knowing Namespace is sometimes necessary to use a SelfLinker
- Namespace(obj Object) (string, error)
- }
- // All API types registered with Scheme must support the Object interface. Since objects in a scheme are
- // expected to be serialized to the wire, the interface an Object must provide to the Scheme allows
- // serializers to set the kind, version, and group the object is represented as. An Object may choose
- // to return a no-op ObjectKindAccessor in cases where it is not expected to be serialized.
- type Object interface {
- GetObjectKind() schema.ObjectKind
- DeepCopyObject() Object
- }
- // Unstructured objects store values as map[string]interface{}, with only values that can be serialized
- // to JSON allowed.
- type Unstructured interface {
- Object
- // UnstructuredContent returns a non-nil map with this object's contents. Values may be
- // []interface{}, map[string]interface{}, or any primitive type. Contents are typically serialized to
- // and from JSON. SetUnstructuredContent should be used to mutate the contents.
- UnstructuredContent() map[string]interface{}
- // SetUnstructuredContent updates the object content to match the provided map.
- SetUnstructuredContent(map[string]interface{})
- // IsList returns true if this type is a list or matches the list convention - has an array called "items".
- IsList() bool
- // EachListItem should pass a single item out of the list as an Object to the provided function. Any
- // error should terminate the iteration. If IsList() returns false, this method should return an error
- // instead of calling the provided function.
- EachListItem(func(Object) error) error
- }
|