Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NatsConn (0.21 sec)

  1. internal/event/target/nats.go

    		if target.stanConn == nil || target.stanConn.NatsConn() == nil {
    			target.stanConn, connErr = target.args.connectStan()
    		} else if !target.stanConn.NatsConn().IsConnected() {
    			return false, store.ErrNotConnected
    		}
    	} else {
    		if target.natsConn == nil {
    			target.natsConn, connErr = target.args.connectNats()
    		} else if !target.natsConn.IsConnected() {
    			return false, store.ErrNotConnected
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 27 18:11:55 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  2. docs/bucket/notifications/README.md

        if stanConnection == nil || stanConnection.NatsConn() == nil ||  !stanConnection.NatsConn().IsConnected() {
         stanConnection, _ = stan.Connect("test-cluster", "test-client", stan.NatsURL("nats://yourusername:yoursecret@0.0.0.0:4222"), stan.SetConnectionLostHandler(func(c stan.Conn, _ error) {
          if c.NatsConn() != nil {
           c.NatsConn().Close()
          }
          _ = c.Close()
         }))
    Plain Text
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
Back to top