minio.go 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. package docker
  2. import (
  3. "fmt"
  4. "goseg/config"
  5. "os"
  6. "path/filepath"
  7. )
  8. func LoadMC() error {
  9. logger.Info("Loading MC container")
  10. confPath := filepath.Join(config.BasePath, "settings", "mc.json")
  11. _, err := os.Open(confPath)
  12. if err != nil {
  13. // create a default if it doesn't exist
  14. err = config.CreateDefaultMcConf()
  15. if err != nil {
  16. // error if we can't create it
  17. errmsg := fmt.Sprintf("Unable to create MC config! %v", err)
  18. logger.Error(errmsg)
  19. }
  20. }
  21. logger.Info("Running MC")
  22. info, err := StartContainer("mc", "mc")
  23. if err != nil {
  24. logger.Error(fmt.Sprintf("Error starting MC: %v", err))
  25. return err
  26. }
  27. config.UpdateContainerState("mc", info)
  28. return nil
  29. }
  30. func LoadMinIOs() error {
  31. logger.Info("Loading MinIO containers")
  32. conf := config.Conf()
  33. for _, pier := range conf.Piers {
  34. // uConf := config.UrbitConf(pier)
  35. label := "minio_" + pier
  36. info, err := StartContainer(label, "minio")
  37. if err != nil {
  38. logger.Error(fmt.Sprintf("Error starting %s Minio: %v", pier, err))
  39. return err
  40. }
  41. config.UpdateContainerState(label, info)
  42. }
  43. // load config from each pier
  44. // apply latest version info (if automated updates)
  45. // start containers
  46. return nil
  47. }