Merge pull request #319 from kube-tarian/add-crossplane-job-handlers

add crossplane resource synch job handlers

Author: vramk23

capten/agent/pkg/crossplane/crossplane_cluster_claims.go

@@ -35,8 +35,8 @@ type ClusterClaimSyncHandler struct {
 	clusters map[string]*captenpluginspb.ManagedCluster
 }
 
-func NewClusterClaimSyncHandler(log logging.Logger, dbStore *captenstore.Store) (*ClusterClaimSyncHandler, error) {
-	return &ClusterClaimSyncHandler{log: log, dbStore: dbStore, clusters: map[string]*captenpluginspb.ManagedCluster{}}, nil
+func NewClusterClaimSyncHandler(log logging.Logger, dbStore *captenstore.Store) *ClusterClaimSyncHandler {
+	return &ClusterClaimSyncHandler{log: log, dbStore: dbStore, clusters: map[string]*captenpluginspb.ManagedCluster{}}
 }
 
 func (h *ClusterClaimSyncHandler) Sync() error {

capten/agent/pkg/crossplane/crossplane_providers.go

@@ -5,7 +5,6 @@ import (
 	"encoding/json"
 	"fmt"
 
-	"github.com/intelops/go-common/credentials"
 	"github.com/intelops/go-common/logging"
 	captenstore "github.com/kube-tarian/kad/capten/agent/pkg/capten-store"
 
@@ -21,13 +20,11 @@ const (
 
 type ProvidersSyncHandler struct {
 	log     logging.Logger
-	client  *k8s.K8SClient
 	dbStore *captenstore.Store
-	creds   credentials.CredentialAdmin
 }
 
-func NewProvidersSyncHandler(log logging.Logger, dbStore *captenstore.Store) (*ProvidersSyncHandler, error) {
-	return &ProvidersSyncHandler{log: log, dbStore: dbStore}, nil
+func NewProvidersSyncHandler(log logging.Logger, dbStore *captenstore.Store) *ProvidersSyncHandler {
+	return &ProvidersSyncHandler{log: log, dbStore: dbStore}
 }
 
 func (h *ProvidersSyncHandler) Sync() error {

capten/agent/pkg/job/crossplane_resources_sync.go

@@ -3,28 +3,37 @@ package job
 import (
 	"github.com/intelops/go-common/logging"
 	captenstore "github.com/kube-tarian/kad/capten/agent/pkg/capten-store"
+	"github.com/kube-tarian/kad/capten/agent/pkg/crossplane"
 )
 
 type CrossplaneResourcesSync struct {
-	dbStore   *captenstore.Store
-	log       logging.Logger
-	frequency string
+	log             logging.Logger
+	frequency       string
+	clusterHandler  *crossplane.ClusterClaimSyncHandler
+	providerHandler *crossplane.ProvidersSyncHandler
 }
 
 func NewCrossplaneResourcesSync(log logging.Logger, frequency string, dbStore *captenstore.Store) (*CrossplaneResourcesSync, error) {
 	return &CrossplaneResourcesSync{
-		log:       log,
-		frequency: frequency,
-		dbStore:   dbStore,
+		log:             log,
+		frequency:       frequency,
+		clusterHandler:  crossplane.NewClusterClaimSyncHandler(log, dbStore),
+		providerHandler: crossplane.NewProvidersSyncHandler(log, dbStore),
 	}, nil
 }
 
-func (v *CrossplaneResourcesSync) CronSpec() string {
-	return v.frequency
+func (s *CrossplaneResourcesSync) CronSpec() string {
+	return s.frequency
 }
 
-func (v *CrossplaneResourcesSync) Run() {
-	v.log.Debug("started crossplane resource sync job")
+func (s *CrossplaneResourcesSync) Run() {
+	s.log.Debug("started crossplane resource sync job")
+	if err := s.providerHandler.Sync(); err != nil {
+		s.log.Errorf("failed to synch providers, %v", err)
+	}
 
-	v.log.Debug("crossplane resource sync job completed")
+	if err := s.clusterHandler.Sync(); err != nil {
+		s.log.Errorf("failed to synch managed clusters, %v", err)
+	}
+	s.log.Debug("crossplane resource sync job completed")
 }