Resource conversion, one solo-kit.json per project

Gopkg.toml

@@ -17,6 +17,10 @@ required = ["k8s.io/code-generator/cmd/client-gen"]
       name = "k8s.io/gengo"
       unused-packages = false
 
+[[override]]
+  name = "gopkg.in/fsnotify.v1"
+  source = "https://github.com/fsnotify/fsnotify.git"
+
 [[constraint]]
   version = "1.1.1"
   name = "github.com/gogo/protobuf"
@@ -31,7 +35,7 @@ required = ["k8s.io/code-generator/cmd/client-gen"]
 
 [[constraint]]
   name = "github.com/solo-io/go-utils"
-  version = "0.9.1"
+  version = "0.9.4"
 
 [[constraint]]
   version = ">=0.8.0"

api/external/kubernetes/solo-kit.json

@@ -1,44 +1,51 @@
 {
   "title": "solo-kit",
-  "name": "kubernetes.solo.io",
-  "version": "kubernetes",
-  "go_package": "github.com/solo-io/solo-kit/pkg/api/v1/resources/common/kubernetes",
-  "custom_resources": [
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/pod",
-      "type": "Pod",
-      "plural_name": "pods",
-      "short_name": "p"
-    },
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/namespace",
-      "type": "KubeNamespace",
-      "plural_name": "kubenamespaces",
-      "short_name": "kn"
-    },
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/configmap",
-      "type": "ConfigMap",
-      "plural_name": "configmaps",
-      "short_name": "cm"
-    },
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/service",
-      "type": "Service",
-      "plural_name": "services",
-      "short_name": "svc"
-    },
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/deployment",
-      "type": "Deployment",
-      "plural_name": "deployments",
-      "short_name": "dp "
-    },
-    {
-      "package": "github.com/solo-io/solo-kit/api/external/kubernetes/customresourcedefinition",
-      "type": "CustomResourceDefinition",
-      "plural_name": "customresourcedefinition",
-      "short_name": "crd "
-    }
-  ]
+  "api_group": {
+    "name": "kubernetes.solo.io",
+    "resource_group_go_package": "github.com/solo-io/solo-kit/api/external/kubernetes/group",
+    "version_configs": [
+      {
+        "version": "kubernetes",
+        "go_package": "github.com/solo-io/solo-kit/pkg/api/v1/resources/common/kubernetes",
+        "custom_resources": [
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/pod",
+            "type": "Pod",
+            "plural_name": "pods",
+            "short_name": "p"
+          },
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/namespace",
+            "type": "KubeNamespace",
+            "plural_name": "kubenamespaces",
+            "short_name": "kn"
+          },
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/configmap",
+            "type": "ConfigMap",
+            "plural_name": "configmaps",
+            "short_name": "cm"
+          },
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/service",
+            "type": "Service",
+            "plural_name": "services",
+            "short_name": "svc"
+          },
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/deployment",
+            "type": "Deployment",
+            "plural_name": "deployments",
+            "short_name": "dp "
+          },
+          {
+            "package": "github.com/solo-io/solo-kit/api/external/kubernetes/customresourcedefinition",
+            "type": "CustomResourceDefinition",
+            "plural_name": "customresourcedefinition",
+            "short_name": "crd "
+          }
+        ]
+      }
+    ]
+  }
 }

api/multicluster/v1/solo-kit.json

@@ -1,21 +1,28 @@
 {
   "title": "Solo-Kit Multicluster Manager",
-  "name": "multicluster.solo.io",
-  "version": "v1",
-  "go_package": "github.com/solo-io/solo-kit/pkg/multicluster/v1",
-  "custom_resources": [
-    {
-      "package": "github.com/solo-io/solo-kit/api/multicluster/v1",
-      "type": "KubeConfig",
-      "plural_name": "kubeconfigs",
-      "short_name": "kc"
-    }
-  ],
-  "resource_groups": {
-    "kubeconfigs.multicluster.solo.io": [
+  "api_group": {
+    "name": "multicluster.solo.io",
+    "resource_group_go_package": "github.com/solo-io/solo-kit/pkg/multicluster/group",
+    "resource_groups": {
+      "kubeconfigs.multicluster.solo.io": [
+        {
+          "name": "KubeConfig",
+          "package": "github.com/solo-io/solo-kit/api/multicluster/v1"
+        }
+      ]
+    },
+    "version_configs": [
       {
-        "name": "KubeConfig",
-        "package": "github.com/solo-io/solo-kit/api/multicluster/v1"
+        "version": "v1",
+        "go_package": "github.com/solo-io/solo-kit/pkg/multicluster/v1",
+        "custom_resources": [
+          {
+            "package": "github.com/solo-io/solo-kit/api/multicluster/v1",
+            "type": "KubeConfig",
+            "plural_name": "kubeconfigs",
+            "short_name": "kc"
+          }
+        ]
       }
     ]
   }

changelog/v0.11.0/conversions.yaml

@@ -0,0 +1,7 @@
+changelog:
+  - type: NEW_FEATURE
+    description: Generate converters for multi-version resources.
+    issueLink: https://github.com/solo-io/solo-kit/issues/215
+  - type: BREAKING_CHANGE
+    description: Redefine solo-kit project concept to better support multi-version resources.
+    issueLink: https://github.com/solo-io/solo-kit/issues/215

pkg/api/v1/clients/kube/crd/crd.go

@@ -1,22 +1,36 @@
 package crd
 
 import (
-	"fmt"
 	"log"
 	"sync"
 
+	"github.com/solo-io/go-utils/errors"
 	"github.com/solo-io/solo-kit/pkg/api/v1/clients/kube/crd/client/clientset/versioned/scheme"
 	v1 "github.com/solo-io/solo-kit/pkg/api/v1/clients/kube/crd/solo.io/v1"
 	"github.com/solo-io/solo-kit/pkg/api/v1/resources"
-	"github.com/solo-io/solo-kit/pkg/utils/protoutils"
 	apiexts "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 )
 
 // TODO(ilackarms): evaluate this fix for concurrent map access in k8s.io/apimachinery/pkg/runtime.SchemaBuider
-var registerLock sync.Mutex
+var (
+	registerLock sync.Mutex
+
+	VersionNotFoundError = func(version string) error {
+		return errors.Errorf("could not find version %v", version)
+	}
+)
+
+type Converter interface {
+	Convert(src SoloKitCrd, dst SoloKitCrd) error
+}
+
+type SoloKitCrd interface {
+	runtime.Object
+	resources.Resource
+}
 
 type CrdMeta struct {
 	Plural        string
@@ -28,7 +42,7 @@ type CrdMeta struct {
 
 type Version struct {
 	Version string
-	Type    runtime.Object
+	Type    SoloKitCrd
 }
 
 type Crd struct {
@@ -41,14 +55,23 @@ type MultiVersionCrd struct {
 	Versions []Version
 }
 
+func (m *MultiVersionCrd) GetVersion(requested string) (*Version, error) {
+	for _, version := range m.Versions {
+		if version.Version == requested {
+			return &version, nil
+		}
+	}
+	return nil, VersionNotFoundError(requested)
+}
+
 func NewCrd(
 	plural string,
 	group string,
 	version string,
 	kindName string,
 	shortName string,
 	clusterScoped bool,
-	objType runtime.Object) Crd {
+	objType SoloKitCrd) Crd {
 	c := Crd{
 		CrdMeta: CrdMeta{
 			Plural:        plural,
@@ -73,25 +96,9 @@ func (d Crd) Register(apiexts apiexts.Interface) error {
 }
 
 func (d Crd) KubeResource(resource resources.InputResource) *v1.Resource {
-	data, err := protoutils.MarshalMap(resource)
-	if err != nil {
-		panic(fmt.Sprintf("internal error: failed to marshal resource to map: %v", err))
-	}
-	delete(data, "metadata")
-	delete(data, "status")
-	spec := v1.Spec(data)
-	return &v1.Resource{
-		TypeMeta: d.TypeMeta(),
-		ObjectMeta: metav1.ObjectMeta{
-			Namespace:       resource.GetMetadata().Namespace,
-			Name:            resource.GetMetadata().Name,
-			ResourceVersion: resource.GetMetadata().ResourceVersion,
-			Labels:          resource.GetMetadata().Labels,
-			Annotations:     resource.GetMetadata().Annotations,
-		},
-		Status: resource.GetStatus(),
-		Spec:   &spec,
-	}
+	res := KubeResource(resource)
+	res.TypeMeta = d.TypeMeta()
+	return res
 }
 
 func (d CrdMeta) FullName() string {

pkg/api/v1/clients/kube/crd/registry.go

@@ -6,6 +6,9 @@ import (
 
 	"github.com/solo-io/go-utils/errors"
 	"github.com/solo-io/go-utils/kubeutils"
+	v1 "github.com/solo-io/solo-kit/pkg/api/v1/clients/kube/crd/solo.io/v1"
+	"github.com/solo-io/solo-kit/pkg/api/v1/resources"
+	"github.com/solo-io/solo-kit/pkg/utils/protoutils"
 	"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
 	apiexts "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
 	apierrors "k8s.io/apimachinery/pkg/api/errors"
@@ -46,6 +49,10 @@ func AddCrd(resource Crd) error {
 	return getRegistry().addCrd(resource)
 }
 
+func GetMultiVersionCrd(gk schema.GroupKind) (MultiVersionCrd, error) {
+	return getRegistry().getMultiVersionCrd(gk)
+}
+
 func (r *crdRegistry) addCrd(resource Crd) error {
 	r.mu.Lock()
 	defer r.mu.Unlock()
@@ -149,3 +156,29 @@ func (r crdRegistry) getKubeCrd(crd MultiVersionCrd, gvk schema.GroupVersionKind
 		},
 	}, nil
 }
+
+func KubeResource(resource resources.Resource) *v1.Resource {
+	data, err := protoutils.MarshalMap(resource)
+	if err != nil {
+		panic(fmt.Sprintf("internal error: failed to marshal resource to map: %v", err))
+	}
+	delete(data, "metadata")
+	delete(data, "status")
+	spec := v1.Spec(data)
+	res := &v1.Resource{
+		ObjectMeta: metav1.ObjectMeta{
+			Namespace:       resource.GetMetadata().Namespace,
+			Name:            resource.GetMetadata().Name,
+			ResourceVersion: resource.GetMetadata().ResourceVersion,
+			Labels:          resource.GetMetadata().Labels,
+			Annotations:     resource.GetMetadata().Annotations,
+		},
+		Spec: &spec,
+	}
+
+	if withStatus, ok := resource.(resources.InputResource); ok {
+		res.Status = withStatus.GetStatus()
+	}
+
+	return res
+}