diff --git a/cmd/spinifex/cmd/get.go b/cmd/spinifex/cmd/get.go index dd8bb1e9e..c8262b438 100644 --- a/cmd/spinifex/cmd/get.go +++ b/cmd/spinifex/cmd/get.go @@ -26,6 +26,7 @@ import ( "strings" "time" + "github.com/mulgadc/spinifex/spinifex/admin" "github.com/mulgadc/spinifex/spinifex/config" "github.com/mulgadc/spinifex/spinifex/types" "github.com/mulgadc/spinifex/spinifex/utils" @@ -90,7 +91,7 @@ func loadConfigAndConnect() (*config.ClusterConfig, *nats.Conn, error) { } nodeConfig := cfg.Nodes[cfg.Node] - nc, err := utils.ConnectNATS(nodeConfig.NATS.Host, nodeConfig.NATS.ACL.Token, nodeConfig.NATS.CACert) + nc, err := utils.ConnectNATS(admin.DialTarget(nodeConfig.NATS.Host), nodeConfig.NATS.ACL.Token, nodeConfig.NATS.CACert) if err != nil { return nil, nil, fmt.Errorf("failed to connect to NATS: %w", err) } diff --git a/spinifex/services/viperblockd/viperblockd.go b/spinifex/services/viperblockd/viperblockd.go index cae94b3f7..2c5b287b0 100644 --- a/spinifex/services/viperblockd/viperblockd.go +++ b/spinifex/services/viperblockd/viperblockd.go @@ -12,6 +12,7 @@ import ( "syscall" "time" + "github.com/mulgadc/spinifex/spinifex/admin" "github.com/mulgadc/spinifex/spinifex/nbd" "github.com/mulgadc/spinifex/spinifex/types" "github.com/mulgadc/spinifex/spinifex/utils" @@ -170,7 +171,7 @@ func (svc *Service) Reload() (err error) { func launchService(cfg *Config) (err error) { // Connect to NATS - nc, err := utils.ConnectNATS(cfg.NatsHost, cfg.NatsToken, cfg.NatsCACert) + nc, err := utils.ConnectNATS(admin.DialTarget(cfg.NatsHost), cfg.NatsToken, cfg.NatsCACert) if err != nil { slog.Error("Failed to connect to NATS", "err", err) return err @@ -404,7 +405,7 @@ func launchService(cfg *Config) (err error) { Region: cfg.Region, AccessKey: cfg.AccessKey, SecretKey: cfg.SecretKey, - Host: cfg.S3Host, + Host: admin.DialTarget(cfg.S3Host), } // TODO: Improve based on system availability. Default 128MB cache @@ -530,7 +531,7 @@ func launchService(cfg *Config) (err error) { PidFile: nbdPidFile, PluginPath: cfg.PluginPath, BaseDir: cfg.BaseDir, - Host: cfg.S3Host, + Host: admin.DialTarget(cfg.S3Host), Verbose: false, Size: utils.SafeUint64ToInt64(vb.GetVolumeSize()), Volume: ebsRequest.Name, diff --git a/spinifex/services/vpcd/vpcd.go b/spinifex/services/vpcd/vpcd.go index bbc95492d..d64222649 100644 --- a/spinifex/services/vpcd/vpcd.go +++ b/spinifex/services/vpcd/vpcd.go @@ -11,6 +11,7 @@ import ( "strings" "syscall" + "github.com/mulgadc/spinifex/spinifex/admin" "github.com/mulgadc/spinifex/spinifex/utils" ) @@ -274,7 +275,7 @@ func launchService(cfg *Config) error { slog.Info("OVN preflight passed (br-int exists, ovn-controller running)") // Connect to NATS - nc, err := utils.ConnectNATS(cfg.NatsHost, cfg.NatsToken, cfg.NatsCACert) + nc, err := utils.ConnectNATS(admin.DialTarget(cfg.NatsHost), cfg.NatsToken, cfg.NatsCACert) if err != nil { slog.Error("Failed to connect to NATS", "err", err) return err