- commit
- 7deac4f
- parent
- eb2019a
- author
- Eric Bower
- date
- 2025-06-15 12:12:35 -0400 EDT
refactor(pgs): use base storage adapter
3 files changed,
+5,
-8
+2,
-4
1@@ -9,16 +9,14 @@ import (
2 )
3
4 func main() {
5- minioURL := utils.GetEnv("MINIO_URL", "")
6- minioUser := utils.GetEnv("MINIO_ROOT_USER", "")
7- minioPass := utils.GetEnv("MINIO_ROOT_PASSWORD", "")
8 dbURL := utils.GetEnv("DATABASE_URL", "")
9 logger := shared.CreateLogger("pgs-ssh")
10 dbpool, err := pgsdb.NewDB(dbURL, logger)
11 if err != nil {
12 panic(err)
13 }
14- st, err := storage.NewStorageMinio(logger, minioURL, minioUser, minioPass)
15+ adapter := storage.GetStorageTypeFromEnv()
16+ st, err := storage.NewStorage(logger, adapter)
17 if err != nil {
18 panic(err)
19 }
+2,
-4
1@@ -9,16 +9,14 @@ import (
2 )
3
4 func main() {
5- minioURL := utils.GetEnv("MINIO_URL", "")
6- minioUser := utils.GetEnv("MINIO_ROOT_USER", "")
7- minioPass := utils.GetEnv("MINIO_ROOT_PASSWORD", "")
8 dbURL := utils.GetEnv("DATABASE_URL", "")
9 logger := shared.CreateLogger("pgs-web")
10 dbpool, err := pgsdb.NewDB(dbURL, logger)
11 if err != nil {
12 panic(err)
13 }
14- st, err := storage.NewStorageMinio(logger, minioURL, minioUser, minioPass)
15+ adapter := storage.GetStorageTypeFromEnv()
16+ st, err := storage.NewStorage(logger, adapter)
17 if err != nil {
18 panic(err)
19 }
+1,
-0
1@@ -19,6 +19,7 @@ services:
2 - db
3 - all
4 - prose
5+ - pgs
6 pipemgr:
7 image: ghcr.io/picosh/pipemgr:latest
8 command: -command "pub metric-drain -b=false"