Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NatsConn (0.05 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
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K 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()
         }))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
Back to top