Meshync Dynamic Configuration from Meshsync

internal/config/crd_config.go

@@ -0,0 +1,57 @@
+package config
+
+import (
+	"context"
+	"errors"
+
+	"github.com/layer5io/meshkit/utils"
+	mesherykube "github.com/layer5io/meshkit/utils/kubernetes"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+)
+
+var (
+	namespace = "meshery"           // Namespace for the Custom Resource
+	crName    = "meshery-meshsync"  // Name of the custom resource
+	version   = "v1alpha1"          // Version of the Custom Resource
+	group     = "meshery.layer5.io" //Group for the Custom Resource
+	resource  = "meshsyncs"         //Name of the Resource
+)
+
+func GetMeshsyncCRDConfigs() (*MeshsyncConfig, error) {
+	// Initialize kubeclient
+	kubeClient, err := mesherykube.New(nil)
+	if err != nil {
+		return nil, ErrInitConfig(err)
+	}
+	// initialize the dynamic kube client
+	dyClient := kubeClient.DynamicKubeClient
+
+	// initialize the group version resource to access the custom resource
+	gvr := schema.GroupVersionResource{Version: version, Group: group, Resource: resource}
+
+	// make a call to get the custom resource
+	crd, err := dyClient.Resource(gvr).Namespace(namespace).Get(context.TODO(), crName, metav1.GetOptions{})
+
+	if err != nil {
+		return nil, ErrInitConfig(err)
+	}
+	// get the spec section of the unstructured object
+	spec := crd.Object["spec"]
+	configObj := spec.(map[string]interface{})["config"]
+
+	if configObj == nil {
+		return nil, ErrInitConfig(errors.New("Custom Resource does not have Meshsync Configs"))
+	}
+	configStr, err := utils.Marshal(configObj)
+	if err != nil {
+		return nil, ErrInitConfig(err)
+	}
+	meshsyncConfig := MeshsyncConfig{}
+	err = utils.Unmarshal(string(configStr), &meshsyncConfig)
+
+	if err != nil {
+		return nil, ErrInitConfig(err)
+	}
+	return &meshsyncConfig, nil
+}

internal/config/types.go

@@ -32,3 +32,9 @@ type ListenerConfig struct {
 	PublishTo      string `json:"publish-to" yaml:"publish-to"`
 	SubscribeTo    string `json:"subscribe-to" yaml:"subscribe-to"`
 }
+
+// Meshsync configuration controls the resources meshsync produces and consumes
+type MeshsyncConfig struct {
+	PipelineConfigs map[string]PipelineConfigs `json:"pipeline-configs,omitempty" yaml:"pipeline-configs,omitempty"`
+	ListenerConfigs map[string]ListenerConfig  `json:"listener-config,omitempty" yaml:"listener-config,omitempty"`
+}

main.go

@@ -39,6 +39,20 @@ func main() {
 		os.Exit(1)
 	}
 
+	// get configs from meshsync crd if available
+	crdConfigs, err := config.GetMeshsyncCRDConfigs()
+
+	if err != nil {
+		// no configs found from meshsync CRD log warning
+		log.Warn(err)
+	}
+
+	// pass configs from crd to default configs
+	if crdConfigs != nil {
+		config.Pipelines = crdConfigs.PipelineConfigs
+		config.Listeners = crdConfigs.ListenerConfigs
+	}
+
 	// Config init and seed
 	cfg, err := config.New(provider)
 	if err != nil {