Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for connectStan (0.05 sec)

  1. 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 != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
Back to top