Support for NATS Creds

.gitignore

@@ -18,6 +18,10 @@
 # Project specific ignores
 /var
 
+aditya.creds
+test.creds
+config.json
+
 migrateTimestamps.pl
 test_ccms_api.sh
 test_ccms_free_api.sh

configs/config.json

@@ -166,12 +166,12 @@
         }
     },
     "checkpoints": {
-        "interval": "1h",
+        "interval": "12h",
         "directory": "./var/checkpoints",
-        "restore": "1h"
+        "restore": "48h"
     },
     "archive": {
-        "interval": "2h",
+        "interval": "50h",
         "directory": "./var/archive"
     },
     "http-api": {
@@ -179,7 +179,18 @@
         "https-cert-file": null,
         "https-key-file": null
     },
-    "retention-in-memory": "1h",
-    "nats": null,
+    "retention-in-memory": "48h",
+    "nats": [
+        {
+            "address": "nats://localhost:4222",
+            "creds-file-path": "test.creds",
+            "subscriptions": [
+                {
+                    "subscribe-to": "ee-hpc-nats",
+                    "cluster-tag": "fritz2"
+                }
+            ]
+        }
+    ],
     "jwt-public-key": "kzfYrYy+TzpanWZHJ5qSdMj5uKUWgq74BWhQG6copP0="
 }

internal/api/lineprotocol.go

@@ -92,6 +92,10 @@ func ReceiveNats(conf *config.NatsConfig,
 		opts = append(opts, nats.UserInfo(conf.Username, conf.Password))
 	}
 
+	if conf.Credsfilepath != "" {
+		opts = append(opts, nats.UserCredentials(conf.Credsfilepath))
+	}
+
 	nc, err := nats.Connect(conf.Address, opts...)
 	if err != nil {
 		return err

internal/config/config.go

@@ -65,6 +65,9 @@ type NatsConfig struct {
 	Username string `json:"username"`
 	Password string `json:"password"`
 
+	//Creds file path
+	Credsfilepath string `json:"creds-file-path"`
+
 	Subscriptions []struct {
 		// Channel name
 		SubscribeTo string `json:"subscribe-to"`