diff --git a/cmd/membershipd/main.go b/cmd/membershipd/main.go index 6ed2d59..a26428e 100644 --- a/cmd/membershipd/main.go +++ b/cmd/membershipd/main.go @@ -40,9 +40,15 @@ func main() { storeDir = flag.String("store-dir", "./local_files/blobs", "blob store directory") natsPort = flag.Int("nats-port", 4250, "embedded NATS listen port (when --nats-url empty)") natsStore = flag.String("nats-store", "./local_files/jetstream", "embedded JetStream store dir") + busAuth = flag.String("bus-auth", "off", "control-plane auth rollout: off|soft|enforce (feature flag bus-auth)") ) flag.Parse() + authMode, err := membership.ParseAuthMode(*busAuth) + if err != nil { + log.Fatalf("%v", err) + } + log.SetFlags(log.LstdFlags | log.Lmsgprefix) log.SetPrefix("[membershipd] ") @@ -78,7 +84,8 @@ func main() { } log.Printf("blob store: %s", *storeDir) - srv := membership.NewServer(store, blobs) + srv := membership.NewServer(store, blobs, authMode) + log.Printf("control-plane auth: %s", authMode) addr := *bind + ":" + *httpPort httpSrv := &http.Server{Addr: addr, Handler: srv}