Refactor reconciler

.gitignore

@@ -6,3 +6,5 @@ lieutenant-operator
 cmd/manager/__debug_bin
 
 tempgopath
+
+.cache/

CHANGELOG.md

@@ -3,6 +3,14 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
+
+## [unreleased] - 2020-10-22
+### Changed
+- Redesigned reconcile handling ([#120])
+- GitRepo objects now fetch their information instead of them receiving from other controllers ([#120])
+### Fixed
+- Lot's of race conditions and smaller bugs ([#120])
+
 ## [v0.4.0] - 2020-10-20
 ### Added
 - Configurable revisions for git repositories ([#116])
@@ -113,3 +121,4 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 [#104]: https://github.com/projectsyn/lieutenant-operator/pull/104
 [#110]: https://github.com/projectsyn/lieutenant-operator/pull/110
 [#116]: https://github.com/projectsyn/lieutenant-operator/pull/116
+[#120]: https://github.com/projectsyn/lieutenant-operator/pull/120

examples/gitrepo-secret.yaml

@@ -1,7 +1,7 @@
 apiVersion: v1
 stringData:
-  endpoint: http://192.168.5.42:8080
-  token: vY3gHvPs82NvYK8dKAGw
+  endpoint: http://192.168.5.195:8080
+  token: oqepRZZtm2QymfTXErHX
 kind: Secret
 metadata:
   name: example-secret

go.mod

@@ -17,6 +17,7 @@ require (
 	k8s.io/apimachinery v0.17.4
 	k8s.io/client-go v12.0.0+incompatible
 	k8s.io/kube-openapi v0.0.0-20191107075043-30be4d16710a
+	k8s.io/kubectl v0.17.4
 	k8s.io/utils v0.0.0-20191114200735-6ca3b61696b6
 	sigs.k8s.io/controller-runtime v0.5.2
 )

go.sum

@@ -167,6 +167,7 @@ github.com/coreos/etcd v3.3.17+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc
 github.com/coreos/go-etcd v2.0.0+incompatible/go.mod h1:Jez6KQU2B/sWsbdaef3ED8NzMklzPG4d5KIOhIy30Tk=
 github.com/coreos/go-oidc v2.1.0+incompatible/go.mod h1:CgnwVTmzoESiwO9qyAFEMiHoZ1nMCKZlZ9V6mm3/LKc=
 github.com/coreos/go-semver v0.2.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
+github.com/coreos/go-semver v0.3.0 h1:wkHLiw0WNATZnSG7epLsujiMCgPAc9xhjJ4tgnAxmfM=
 github.com/coreos/go-semver v0.3.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk=
 github.com/coreos/go-systemd v0.0.0-20180511133405-39ca1b05acc7/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
 github.com/coreos/go-systemd v0.0.0-20181012123002-c6f51f82210d/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
@@ -1275,6 +1276,7 @@ gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20190905181640-827449938966/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gotest.tools v2.2.0+incompatible h1:VsBPFP1AI068pPrMxtb/S8Zkgf9xEmTLJjfM+P5UIEo=
 gotest.tools v2.2.0+incompatible/go.mod h1:DsYFclhRJ6vuDpmuTbkuFWG+y2sxOXAzmJt81HFBacw=
 helm.sh/helm/v3 v3.1.0/go.mod h1:WYsFJuMASa/4XUqLyv54s0U/f3mlAaRErGmyy4z921g=
 helm.sh/helm/v3 v3.1.2 h1:VpNzaNv2DX4aRnOCcV7v5Of+XT2SZrJ8iOQ25AGKOos=

pkg/apis/syn/v1alpha1/cluster_types.go

@@ -81,3 +81,29 @@ type ClusterList struct {
 func init() {
 	SchemeBuilder.Register(&Cluster{}, &ClusterList{})
 }
+
+// GetGitTemplate returns the git repository template
+func (c *Cluster) GetGitTemplate() *GitRepoTemplate {
+	return c.Spec.GitRepoTemplate
+}
+
+// GetTenantRef returns the tenant of this CR
+func (c *Cluster) GetTenantRef() corev1.LocalObjectReference {
+	return c.Spec.TenantRef
+}
+
+// GetDeletionPolicy returns the object's deletion policy
+func (c *Cluster) GetDeletionPolicy() DeletionPolicy {
+	return c.Spec.DeletionPolicy
+}
+
+// GetDisplayName returns the display name of the object
+func (c *Cluster) GetDisplayName() string {
+	return c.Spec.DisplayName
+}
+
+// SetGitRepoURLAndHostKeys
+func (c *Cluster) SetGitRepoURLAndHostKeys(URL, hostKeys string) {
+	c.Spec.GitRepoURL = URL
+	c.Spec.GitHostKeys = hostKeys
+}

pkg/apis/syn/v1alpha1/gitrepo_types.go

@@ -130,3 +130,28 @@ type GitRepoList struct {
 func init() {
 	SchemeBuilder.Register(&GitRepo{}, &GitRepoList{})
 }
+
+// GetGitTemplate returns the git repository template
+func (g *GitRepo) GetGitTemplate() *GitRepoTemplate {
+	return &g.Spec.GitRepoTemplate
+}
+
+// GetTenantRef returns the tenant of this CR
+func (g *GitRepo) GetTenantRef() corev1.LocalObjectReference {
+	return g.Spec.TenantRef
+}
+
+// GetDeletionPolicy returns the object's deletion policy
+func (g *GitRepo) GetDeletionPolicy() DeletionPolicy {
+	return g.Spec.DeletionPolicy
+}
+
+// GetDisplayName returns the display name of the object
+func (g *GitRepo) GetDisplayName() string {
+	return g.Spec.DisplayName
+}
+
+// SetGitRepoURLAndHostKeys is currenlty a noop for gitrepo
+func (g *GitRepo) SetGitRepoURLAndHostKeys(URL, hostKeys string) {
+	//NOOP
+}

pkg/apis/syn/v1alpha1/tenant_types.go

@@ -1,6 +1,7 @@
 package v1alpha1
 
 import (
+	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
@@ -62,3 +63,31 @@ type TenantList struct {
 func init() {
 	SchemeBuilder.Register(&Tenant{}, &TenantList{})
 }
+
+// GetGitTemplate returns the git repository template
+func (t *Tenant) GetGitTemplate() *GitRepoTemplate {
+	if t.Spec.GitRepoTemplate == nil {
+		t.Spec.GitRepoTemplate = &GitRepoTemplate{}
+	}
+	return t.Spec.GitRepoTemplate
+}
+
+// GetTenantRef returns the tenant of this CR
+func (t *Tenant) GetTenantRef() corev1.LocalObjectReference {
+	return corev1.LocalObjectReference{Name: t.GetName()}
+}
+
+// GetDeletionPolicy returns the object's deletion policy
+func (t *Tenant) GetDeletionPolicy() DeletionPolicy {
+	return t.Spec.DeletionPolicy
+}
+
+// GetDisplayName returns the display name of the object
+func (t *Tenant) GetDisplayName() string {
+	return t.Spec.DisplayName
+}
+
+// SetGitRepoURLAndHostKeys will only set the URL for the tenant
+func (t *Tenant) SetGitRepoURLAndHostKeys(URL, hostKeys string) {
+	t.Spec.GitRepoURL = URL
+}

pkg/controller/cluster/cluster_controller.go

@@ -38,10 +38,9 @@ func add(mgr manager.Manager, r reconcile.Reconciler) error {
 	if err != nil {
 		return err
 	}
-
 	return c.Watch(&source.Kind{Type: &synv1alpha1.GitRepo{}}, &handler.EnqueueRequestForOwner{
 		IsController: true,
-		OwnerType:    &synv1alpha1.Cluster{},
+		OwnerType:    &synv1alpha1.Tenant{},
 	})
 
 }