123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325 |
- /*
- Copyright 2015 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 unversioned
- import (
- "encoding/json"
- "fmt"
- "strings"
- )
- // ParseResourceArg takes the common style of string which may be either `resource.group.com` or `resource.version.group.com`
- // and parses it out into both possibilities. This code takes no responsibility for knowing which representation was intended
- // but with a knowledge of all GroupVersions, calling code can take a very good guess. If there are only two segments, then
- // `*GroupVersionResource` is nil.
- // `resource.group.com` -> `group=com, version=group, resource=resource` and `group=group.com, resource=resource`
- func ParseResourceArg(arg string) (*GroupVersionResource, GroupResource) {
- var gvr *GroupVersionResource
- if strings.Count(arg, ".") >= 2 {
- s := strings.SplitN(arg, ".", 3)
- gvr = &GroupVersionResource{Group: s[2], Version: s[1], Resource: s[0]}
- }
- return gvr, ParseGroupResource(arg)
- }
- // GroupResource specifies a Group and a Resource, but does not force a version. This is useful for identifying
- // concepts during lookup stages without having partially valid types
- //
- // +protobuf.options.(gogoproto.goproto_stringer)=false
- type GroupResource struct {
- Group string `protobuf:"bytes,1,opt,name=group"`
- Resource string `protobuf:"bytes,2,opt,name=resource"`
- }
- func (gr GroupResource) WithVersion(version string) GroupVersionResource {
- return GroupVersionResource{Group: gr.Group, Version: version, Resource: gr.Resource}
- }
- func (gr GroupResource) Empty() bool {
- return len(gr.Group) == 0 && len(gr.Resource) == 0
- }
- func (gr *GroupResource) String() string {
- if len(gr.Group) == 0 {
- return gr.Resource
- }
- return gr.Resource + "." + gr.Group
- }
- // ParseGroupResource turns "resource.group" string into a GroupResource struct. Empty strings are allowed
- // for each field.
- func ParseGroupResource(gr string) GroupResource {
- if i := strings.Index(gr, "."); i == -1 {
- return GroupResource{Resource: gr}
- } else {
- return GroupResource{Group: gr[i+1:], Resource: gr[:i]}
- }
- }
- // GroupVersionResource unambiguously identifies a resource. It doesn't anonymously include GroupVersion
- // to avoid automatic coersion. It doesn't use a GroupVersion to avoid custom marshalling
- //
- // +protobuf.options.(gogoproto.goproto_stringer)=false
- type GroupVersionResource struct {
- Group string `protobuf:"bytes,1,opt,name=group"`
- Version string `protobuf:"bytes,2,opt,name=version"`
- Resource string `protobuf:"bytes,3,opt,name=resource"`
- }
- func (gvr GroupVersionResource) Empty() bool {
- return len(gvr.Group) == 0 && len(gvr.Version) == 0 && len(gvr.Resource) == 0
- }
- func (gvr GroupVersionResource) GroupResource() GroupResource {
- return GroupResource{Group: gvr.Group, Resource: gvr.Resource}
- }
- func (gvr GroupVersionResource) GroupVersion() GroupVersion {
- return GroupVersion{Group: gvr.Group, Version: gvr.Version}
- }
- func (gvr *GroupVersionResource) String() string {
- return strings.Join([]string{gvr.Group, "/", gvr.Version, ", Resource=", gvr.Resource}, "")
- }
- // GroupKind specifies a Group and a Kind, but does not force a version. This is useful for identifying
- // concepts during lookup stages without having partially valid types
- //
- // +protobuf.options.(gogoproto.goproto_stringer)=false
- type GroupKind struct {
- Group string `protobuf:"bytes,1,opt,name=group"`
- Kind string `protobuf:"bytes,2,opt,name=kind"`
- }
- func (gk GroupKind) Empty() bool {
- return len(gk.Group) == 0 && len(gk.Kind) == 0
- }
- func (gk GroupKind) WithVersion(version string) GroupVersionKind {
- return GroupVersionKind{Group: gk.Group, Version: version, Kind: gk.Kind}
- }
- func (gk *GroupKind) String() string {
- if len(gk.Group) == 0 {
- return gk.Kind
- }
- return gk.Kind + "." + gk.Group
- }
- // GroupVersionKind unambiguously identifies a kind. It doesn't anonymously include GroupVersion
- // to avoid automatic coersion. It doesn't use a GroupVersion to avoid custom marshalling
- //
- // +protobuf.options.(gogoproto.goproto_stringer)=false
- type GroupVersionKind struct {
- Group string `protobuf:"bytes,1,opt,name=group"`
- Version string `protobuf:"bytes,2,opt,name=version"`
- Kind string `protobuf:"bytes,3,opt,name=kind"`
- }
- // Empty returns true if group, version, and kind are empty
- func (gvk GroupVersionKind) Empty() bool {
- return len(gvk.Group) == 0 && len(gvk.Version) == 0 && len(gvk.Kind) == 0
- }
- func (gvk GroupVersionKind) GroupKind() GroupKind {
- return GroupKind{Group: gvk.Group, Kind: gvk.Kind}
- }
- func (gvk GroupVersionKind) GroupVersion() GroupVersion {
- return GroupVersion{Group: gvk.Group, Version: gvk.Version}
- }
- func (gvk GroupVersionKind) String() string {
- return gvk.Group + "/" + gvk.Version + ", Kind=" + gvk.Kind
- }
- // GroupVersion contains the "group" and the "version", which uniquely identifies the API.
- //
- // +protobuf.options.(gogoproto.goproto_stringer)=false
- type GroupVersion struct {
- Group string `protobuf:"bytes,1,opt,name=group"`
- Version string `protobuf:"bytes,2,opt,name=version"`
- }
- // Empty returns true if group and version are empty
- func (gv GroupVersion) Empty() bool {
- return len(gv.Group) == 0 && len(gv.Version) == 0
- }
- // String puts "group" and "version" into a single "group/version" string. For the legacy v1
- // it returns "v1".
- func (gv GroupVersion) String() string {
- // special case the internal apiVersion for the legacy kube types
- if gv.Empty() {
- return ""
- }
- // special case of "v1" for backward compatibility
- if len(gv.Group) == 0 && gv.Version == "v1" {
- return gv.Version
- }
- if len(gv.Group) > 0 {
- return gv.Group + "/" + gv.Version
- }
- return gv.Version
- }
- // KindForGroupVersionKinds identifies the preferred GroupVersionKind out of a list. It returns ok false
- // if none of the options match the group. It prefers a match to group and version over just group.
- // TODO: Move GroupVersion to a package under pkg/runtime, since it's used by scheme.
- // TODO: Introduce an adapter type between GroupVersion and runtime.GroupVersioner, and use LegacyCodec(GroupVersion)
- // in fewer places.
- func (gv GroupVersion) KindForGroupVersionKinds(kinds []GroupVersionKind) (target GroupVersionKind, ok bool) {
- for _, gvk := range kinds {
- if gvk.Group == gv.Group && gvk.Version == gv.Version {
- return gvk, true
- }
- }
- for _, gvk := range kinds {
- if gvk.Group == gv.Group {
- return gv.WithKind(gvk.Kind), true
- }
- }
- return GroupVersionKind{}, false
- }
- // ParseGroupVersion turns "group/version" string into a GroupVersion struct. It reports error
- // if it cannot parse the string.
- func ParseGroupVersion(gv string) (GroupVersion, error) {
- // this can be the internal version for the legacy kube types
- // TODO once we've cleared the last uses as strings, this special case should be removed.
- if (len(gv) == 0) || (gv == "/") {
- return GroupVersion{}, nil
- }
- switch strings.Count(gv, "/") {
- case 0:
- return GroupVersion{"", gv}, nil
- case 1:
- i := strings.Index(gv, "/")
- return GroupVersion{gv[:i], gv[i+1:]}, nil
- default:
- return GroupVersion{}, fmt.Errorf("unexpected GroupVersion string: %v", gv)
- }
- }
- // WithKind creates a GroupVersionKind based on the method receiver's GroupVersion and the passed Kind.
- func (gv GroupVersion) WithKind(kind string) GroupVersionKind {
- return GroupVersionKind{Group: gv.Group, Version: gv.Version, Kind: kind}
- }
- // WithResource creates a GroupVersionResource based on the method receiver's GroupVersion and the passed Resource.
- func (gv GroupVersion) WithResource(resource string) GroupVersionResource {
- return GroupVersionResource{Group: gv.Group, Version: gv.Version, Resource: resource}
- }
- // MarshalJSON implements the json.Marshaller interface.
- func (gv GroupVersion) MarshalJSON() ([]byte, error) {
- s := gv.String()
- if strings.Count(s, "/") > 1 {
- return []byte{}, fmt.Errorf("illegal GroupVersion %v: contains more than one /", s)
- }
- return json.Marshal(s)
- }
- func (gv *GroupVersion) unmarshal(value []byte) error {
- var s string
- if err := json.Unmarshal(value, &s); err != nil {
- return err
- }
- parsed, err := ParseGroupVersion(s)
- if err != nil {
- return err
- }
- *gv = parsed
- return nil
- }
- // UnmarshalJSON implements the json.Unmarshaller interface.
- func (gv *GroupVersion) UnmarshalJSON(value []byte) error {
- return gv.unmarshal(value)
- }
- // UnmarshalTEXT implements the Ugorji's encoding.TextUnmarshaler interface.
- func (gv *GroupVersion) UnmarshalText(value []byte) error {
- return gv.unmarshal(value)
- }
- // GroupVersions can be used to represent a set of desired group versions.
- // TODO: Move GroupVersions to a package under pkg/runtime, since it's used by scheme.
- // TODO: Introduce an adapter type between GroupVersions and runtime.GroupVersioner, and use LegacyCodec(GroupVersion)
- // in fewer places.
- type GroupVersions []GroupVersion
- // KindForGroupVersionKinds identifies the preferred GroupVersionKind out of a list. It returns ok false
- // if none of the options match the group.
- func (gvs GroupVersions) KindForGroupVersionKinds(kinds []GroupVersionKind) (target GroupVersionKind, ok bool) {
- for _, gv := range gvs {
- target, ok := gv.KindForGroupVersionKinds(kinds)
- if !ok {
- continue
- }
- return target, true
- }
- return GroupVersionKind{}, false
- }
- // ToAPIVersionAndKind is a convenience method for satisfying runtime.Object on types that
- // do not use TypeMeta.
- func (gvk *GroupVersionKind) ToAPIVersionAndKind() (string, string) {
- if gvk == nil {
- return "", ""
- }
- return gvk.GroupVersion().String(), gvk.Kind
- }
- // FromAPIVersionAndKind returns a GVK representing the provided fields for types that
- // do not use TypeMeta. This method exists to support test types and legacy serializations
- // that have a distinct group and kind.
- // TODO: further reduce usage of this method.
- func FromAPIVersionAndKind(apiVersion, kind string) GroupVersionKind {
- if gv, err := ParseGroupVersion(apiVersion); err == nil {
- return GroupVersionKind{Group: gv.Group, Version: gv.Version, Kind: kind}
- }
- return GroupVersionKind{Kind: kind}
- }
- // All objects that are serialized from a Scheme encode their type information. This interface is used
- // by serialization to set type information from the Scheme onto the serialized version of an object.
- // For objects that cannot be serialized or have unique requirements, this interface may be a no-op.
- // TODO: this belongs in pkg/runtime, move unversioned.GVK into runtime.
- type ObjectKind interface {
- // SetGroupVersionKind sets or clears the intended serialized kind of an object. Passing kind nil
- // should clear the current setting.
- SetGroupVersionKind(kind GroupVersionKind)
- // GroupVersionKind returns the stored group, version, and kind of an object, or nil if the object does
- // not expose or provide these fields.
- GroupVersionKind() GroupVersionKind
- }
- // EmptyObjectKind implements the ObjectKind interface as a noop
- // TODO: this belongs in pkg/runtime, move unversioned.GVK into runtime.
- var EmptyObjectKind = emptyObjectKind{}
- type emptyObjectKind struct{}
- // SetGroupVersionKind implements the ObjectKind interface
- func (emptyObjectKind) SetGroupVersionKind(gvk GroupVersionKind) {}
- // GroupVersionKind implements the ObjectKind interface
- func (emptyObjectKind) GroupVersionKind() GroupVersionKind { return GroupVersionKind{} }
|