generate crd using controller-gen

Signed-off-by: Shovan Maity <[email protected]>

Author: shovanmaity

Makefile

@@ -2,6 +2,11 @@ QUAY_USERNAME ?= shovanmaity
 LATEST_TAG ?= latest
 IMAGE_TAG ?= 0.0.1
 
+.PHONY: crd-gen
+crd-gen:
+	controller-gen crd:crdVersions=v1 paths=./client/apis/kvm.io/v1
+	controller-gen object paths=./client/apis/kvm.io/v1/types.go
+
 ##
 .PHONY: rsync-image
 rsync-image:

app/populator/claim/controller.go

@@ -28,6 +28,8 @@ import (
 	"k8s.io/client-go/tools/cache"
 	"k8s.io/client-go/util/workqueue"
 	"k8s.io/klog/v2"
+
+	internalv1 "github.com/shovanmaity/kvm/client/apis/kvm.io/v1"
 )
 
 const (
@@ -215,13 +217,13 @@ func (c *controller) syncPvc(ctx context.Context, key, namespace, name string) (
 		}
 		return false, err
 	}
-	populator := VolumeClaimPopulator{}
+	populator := internalv1.VolumeClaimPopulator{}
 	if err := runtime.DefaultUnstructuredConverter.
 		FromUnstructured(unstructured.UnstructuredContent(), &populator); err != nil {
 		return false, err
 	}
 	// Get source PVC
-	source, err := c.pvcLister.PersistentVolumeClaims(namespace).Get(populator.Spec.Name)
+	source, err := c.pvcLister.PersistentVolumeClaims(namespace).Get(populator.Spec.PVCName)
 	if err != nil {
 		klog.V(2).Infof("Error getting pvc, error: `%s`.", err)
 		if errors.IsNotFound(err) {
@@ -231,7 +233,7 @@ func (c *controller) syncPvc(ctx context.Context, key, namespace, name string) (
 		return false, err
 	}
 	// If source and pvc name is same then skip
-	if pvc.Name == populator.Spec.Name {
+	if pvc.Name == populator.Spec.PVCName {
 		return true, nil
 	}
 	// If storageclass is not present in pvc and storageclass is not matching then skip it

app/populator/claim/types.go

@@ -10,6 +10,8 @@ import (
 	"k8s.io/apimachinery/pkg/runtime"
 	"k8s.io/apimachinery/pkg/runtime/schema"
 	"k8s.io/klog/v2"
+
+	internalv1 "github.com/shovanmaity/kvm/client/apis/kvm.io/v1"
 )
 
 const (
@@ -46,7 +48,7 @@ func main() {
 }
 
 func getPopulatorCmds(rawBlock bool, u *unstructured.Unstructured) ([]string, error) {
-	populator := RsyncPopulator{}
+	populator := internalv1.RsyncPopulator{}
 	err := runtime.DefaultUnstructuredConverter.
 		FromUnstructured(u.UnstructuredContent(), &populator)
 	if nil != err {
@@ -59,23 +61,23 @@ func getPopulatorCmds(rawBlock bool, u *unstructured.Unstructured) ([]string, er
 }
 
 func getPopulatorArgs(rawBlock bool, u *unstructured.Unstructured) ([]string, error) {
-	populator := RsyncPopulator{}
+	populator := internalv1.RsyncPopulator{}
 	err := runtime.DefaultUnstructuredConverter.
 		FromUnstructured(u.UnstructuredContent(), &populator)
 	if nil != err {
 		return nil, err
 	}
 	args := []string{
 		"-rv",
-		"rsync://" + populator.Spec.Username + "@" + populator.Spec.Service +
-			":873" + populator.Spec.Path,
+		"rsync://" + populator.Spec.Username + "@" +
+			populator.Spec.URL + populator.Spec.Path,
 		mountPath,
 	}
 	return args, nil
 }
 
 func getPopulatorEnvs(u *unstructured.Unstructured) ([]corev1.EnvVar, error) {
-	populator := RsyncPopulator{}
+	populator := internalv1.RsyncPopulator{}
 	err := runtime.DefaultUnstructuredConverter.
 		FromUnstructured(u.UnstructuredContent(), &populator)
 	if nil != err {

app/populator/rsync/main.go

@@ -0,0 +1,4 @@
+// +k8s:deepcopy-gen=package
+// +groupName=kvm.io
+
+package v1

app/populator/rsync/types.go

@@ -0,0 +1,41 @@
+package v1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+)
+
+// GroupName is the group name use in this package.
+const GroupName = "kvm.io"
+
+var (
+	// SchemeBuilder is the new scheme builder
+	SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)
+	// AddToScheme adds to scheme
+	AddToScheme = SchemeBuilder.AddToScheme
+	// SchemeGroupVersion is the group version used to register these objects.
+	SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1"}
+)
+
+// Resource takes an unqualified resource and returns a Group-qualified GroupResource.
+func Resource(resource string) schema.GroupResource {
+	return SchemeGroupVersion.WithResource(resource).GroupResource()
+}
+
+func init() {
+	// We only register manually written functions here. The registration of the
+	// generated functions takes place in the generated files. The separation
+	// makes the code compile even when the generated files are missing.
+	SchemeBuilder.Register(addKnownTypes)
+}
+
+// addKnownTypes adds the set of types defined in this package to the supplied scheme.
+func addKnownTypes(scheme *runtime.Scheme) error {
+	scheme.AddKnownTypes(SchemeGroupVersion,
+		&RsyncPopulator{},
+		&RsyncPopulatorList{},
+	)
+	metav1.AddToGroupVersion(scheme, SchemeGroupVersion)
+	return nil
+}

client/apis/kvm.io/v1/doc.go

@@ -0,0 +1,73 @@
+// +kubebuilder:object:generate=true
+package v1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// +genclient
+// +genclient:nonNamespaced
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// RsyncPopulator is a volume populator that helps
+// to create a volume from any rsync source.
+type RsyncPopulator struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
+
+	// Spec contains details of rsync source/ rsync daemon. Rsync client will
+	// use these information to get the data for the volume.
+	Spec RsyncPopulatorSpec `json:"spec"`
+}
+
+// RsyncPopulatorSpec contains the information of rsync daemon.
+type RsyncPopulatorSpec struct {
+	// Username is used as credential to access rsync daemon by the client.
+	Username string `json:"username"`
+	// Password is used as credential to access rsync daemon by the client.
+	Password string `json:"password"`
+	// Path represent mount path of the volume which we want to sync by the clinet.
+	Path string `json:"path"`
+	// URL is rsync daemon url it can be dns can be ip:port. Client will use
+	// it to connect and get the data from daemon.
+	URL string `json:"url"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// RsyncPopulatorList is a list of RsyncPopulator objects
+type RsyncPopulatorList struct {
+	metav1.TypeMeta `json:",inline"`
+	// +optional
+	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
+
+	// List of RsyncPopulators
+	Items []RsyncPopulator `json:"items" protobuf:"bytes,2,rep,name=items"`
+}
+
+// +genclient
+// +genclient:nonNamespaced
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// VolumeClaimPopulator is a volume populator that helps to rename a
+// PVC by applying patch on the PV of older PVC with new PVC.
+type VolumeClaimPopulator struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+	// Spec contains volume claim information. ie - PVC name
+	Spec VolumeClaimPopulatorSpec `json:"spec"`
+}
+
+// VolumeClaimPopulatorSpec contains information on Volume Claim.
+type VolumeClaimPopulatorSpec struct {
+	// PVCName is the name of the pvc which we want to rename.
+	PVCName string `json:"pvcName"`
+}
+
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+// VolumeClaimPopulatorList is a list of VolumeClaimPopulator objects
+type VolumeClaimPopulatorList struct {
+	metav1.TypeMeta `json:",inline"`
+	// +optional
+	metav1.ListMeta `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"`
+
+	// List of VolumeClaimPopulators
+	Items []VolumeClaimPopulator `json:"items" protobuf:"bytes,2,rep,name=items"`
+}