make nats jetstream store dir configurable

2022-03-23 10:15:27 +01:00
parent 6d0ac681c8
commit 10f190d7f4
9 changed files with 54 additions and 43 deletions
@@ -38,9 +38,14 @@ func Server(cfg *config.Config) *cli.Command {
 			natsServer, err := nats.NewNATSServer(
 				ctx,
 				logging.NewLogWrapper(logger),
-				nats.Host(cfg.Nats.Host),
-				nats.Port(cfg.Nats.Port),
-				nats.ClusterID("ocis-cluster"),
+				[]nats.NatsOption{
+					nats.Host(cfg.Nats.Host),
+					nats.Port(cfg.Nats.Port),
+					nats.ClusterID("ocis-cluster"),
+				},
+				[]nats.JetStreamOption{
+					nats.JetStreamStoreDir(cfg.Nats.StoreDir),
+				},
 			)
 			if err != nil {
 				return err