minio starter

docker/minio.go

@@ -1,14 +1,48 @@
 package docker
 
+import (
+	"fmt"
+	"goseg/config"
+	"os"
+	"path/filepath"
+)
+
 func LoadMC() error {
-	logger.Info("Loading MinIO Client")
-	// apply latest version info
-	// start container
+	logger.Info("Loading MC container")
+	confPath := filepath.Join(config.BasePath, "settings", "mc.json")
+	_, err := os.Open(confPath)
+	if err != nil {
+		// create a default if it doesn't exist
+		err = config.CreateDefaultMcConf()
+		if err != nil {
+			// error if we can't create it
+			errmsg := fmt.Sprintf("Unable to create MC config! %v", err)
+			logger.Error(errmsg)
+		}
+	}
+	logger.Info("Running MC")
+	info, err := StartContainer("mc", "mc")
+	if err != nil {
+		logger.Error(fmt.Sprintf("Error starting MC: %v", err))
+		return err
+	}
+	config.UpdateContainerState("mc", info)
 	return nil
 }
 
 func LoadMinIOs() error {
 	logger.Info("Loading MinIO containers")
+	conf := config.Conf()
+	for _, pier := range conf.Piers {
+		// uConf := config.UrbitConf(pier)
+		label := "minio_" + pier
+		info, err := StartContainer(label, "minio")
+		if err != nil {
+			logger.Error(fmt.Sprintf("Error starting %s Minio: %v", pier, err))
+			return err
+		}
+		config.UpdateContainerState(label, info)
+	}
 	// load config from each pier
 	// apply latest version info (if automated updates)
 	// start containers

docker/netdata.go

@@ -1,7 +1,32 @@
 package docker
 
+import (
+	"fmt"
+	"goseg/config"
+	"os"
+	"path/filepath"
+)
+
 func LoadNetdata() error {
-	logger.Info("Loading Netdata container")
-	// start container
+	logger.Info("Loading NetData container")
+	confPath := filepath.Join(config.BasePath, "settings", "netdata.json")
+	_, err := os.Open(confPath)
+	if err != nil {
+		// create a default if it doesn't exist
+		err = config.CreateDefaultNetdataConf()
+		if err != nil {
+			// panic if we can't create it
+			errmsg := fmt.Sprintf("Unable to create NetData config! %v", err)
+			logger.Error(errmsg)
+			panic(errmsg)
+		}
+	}
+	logger.Info("Running NetData")
+	info, err := StartContainer("netdata", "netdata")
+	if err != nil {
+		logger.Error(fmt.Sprintf("Error starting NetData: %v", err))
+		return err
+	}
+	config.UpdateContainerState("netdata", info)
 	return nil
 }

docker/wireguard.go

@@ -15,7 +15,7 @@ func LoadWireguard() error {
 		// create a default if it doesn't exist
 		err = config.CreateDefaultWGConf()
 		if err != nil {
-			// panic if we can't create it
+			// error if we can't create it
 			errmsg := fmt.Sprintf("Unable to create WG config! %v", err)
 			logger.Error(errmsg)
 			panic(errmsg)

structs/configs.go

@@ -113,4 +113,4 @@ type NetdataConfig struct {
 	Restart        string   `json:"restart"`
 	SecurityOpt    string   `json:"security_opt"`
 	Volumes        []string `json:"volumes"`
-}
+}

structs/structs.go

@@ -22,9 +22,3 @@ type ContainerState struct {
 	DesiredStatus string
 	CreatedAt     string
 }
-
-
-
-
-
-

structs/version.go

@@ -28,4 +28,4 @@ type VersionDetails struct {
 	Patch       int    `json:"patch,omitempty"`
 	Repo        string `json:"repo,omitempty"`
 	Tag         string `json:"tag,omitempty"`
-}
+}