We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f9465d1 commit 2892ddeCopy full SHA for 2892dde
1 file changed
internal/utils/nats.go
@@ -39,6 +39,22 @@ func NewNatsConn() *NatsContext {
39
//NoSigs: true,
40
}
41
42
+ authEnabled := viper.GetBool("api.auth_enabled")
43
+ if authEnabled {
44
+ // enable TLS Authentication
45
+ caFile := viper.GetString("tls.ca")
46
+ certFile := viper.GetString("tls.cert")
47
+ keyFile := viper.GetString("tls.key")
48
+
49
+ opts.TLS = true
50
+ opts.TLSCert = certFile
51
+ opts.TLSKey = keyFile
52
+ opts.TLSCaCert = caFile
53
+ opts.TLSVerify = true
54
55
+ log.Println("NATS server TLS authentication enabled.")
56
+ }
57
58
log.Println("Starting embedded NATS server with JetStream...")
59
natsServer, err := server.NewServer(opts)
60
if err != nil {
0 commit comments