- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for connectStan (0.19 sec)
-
internal/event/target/nats.go
connOpts = append(connOpts, nats.ClientCert(n.ClientCert, n.ClientKey)) } return nats.Connect(n.Address.String(), connOpts...) } // To obtain a streaming connection from args. func (n NATSArgs) connectStan() (stan.Conn, error) { scheme := "nats" if n.Secure { scheme = "tls" } var addressURL string //nolint:gocritic if n.Username != "" && n.Password != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0)