support clustersync component (#47)

Author: kqzh

deploy/bare-metal/config.yaml

@@ -28,4 +28,16 @@ clusters:
       - name: storaged2
         endpointIP: 192.168.10.133
         endpointPort: 19779
-        componentType: storaged
+        componentType: storaged
+      - name: meta-listener-0
+        endpointIP: 192.168.10.134
+        endpointPort: 19569
+        componentType: meta_listener
+      - name: storage-listener-0
+        endpointIP: 192.168.10.134
+        endpointPort: 19789
+        componentType: storage_listener
+      - name: drainer0
+        endpointIP: 192.168.10.134
+        endpointPort: 19889
+        componentType: drainer

exporter/exporter.go

@@ -159,7 +159,7 @@ func (e *NebulaExporter) collect(wg *sync.WaitGroup, namespace, clusterName stri
 		instance.Name, instance.EndpointPort)
 
 	wg.Add(2)
-	if instance.ComponentType == "storaged" {
+	if instance.ComponentType == ComponentTypeStoraged {
 		wg.Add(1)
 		go func() {
 			defer wg.Done()

exporter/type.go

@@ -1,5 +1,7 @@
 package exporter
 
+import "fmt"
+
 const (
 	DefaultClusterName = "default"
 
@@ -13,6 +15,13 @@ const (
 	// FQNamespace represents the prometheus FQName
 	FQNamespace  = "nebula"
 	NonNamespace = "none_namespace"
+
+	ComponentTypeGraphd          = "graphd"
+	ComponentTypeMetad           = "metad"
+	ComponentTypeStoraged        = "storaged"
+	ComponentTypeMetaListener    = "meta_listener"
+	ComponentTypeStorageListener = "storage_listener"
+	ComponentTypeDrainer         = "drainer"
 )
 
 type (
@@ -33,3 +42,19 @@ type (
 		ComponentType string `yaml:"componentType"`
 	}
 )
+
+func (s *StaticConfig) Validate() error {
+	for _, cluster := range s.Clusters {
+		for _, instance := range cluster.Instances {
+			switch instance.ComponentType {
+			case ComponentTypeGraphd, ComponentTypeMetad, ComponentTypeStoraged, ComponentTypeMetaListener, ComponentTypeStorageListener, ComponentTypeDrainer:
+				continue
+			default:
+				return fmt.Errorf("invalid component type: %s", instance.ComponentType)
+			}
+		}
+
+	}
+
+	return nil
+}

main.go

@@ -96,6 +96,10 @@ func main() {
 		if err := yaml.Unmarshal(raw, &nebulaExporter.Config); err != nil {
 			klog.Fatalf("unmarshal failed: %v", err)
 		}
+
+		if err := nebulaExporter.Config.Validate(); err != nil {
+			klog.Fatalf("bare-metal config validation failed: %v", err)
+		}
 	} else {
 		config, err := buildConfig(*kubeconfig)
 		if err != nil {