Reconnect to NATS Streaming

reconnect-nats-streaming.go

func Connect() error {
  
  var nc *nats.Conn
  
  // Connect to NATS
  nc, err := nats.Connect(eb.host,
  	nats.PingInterval(10*time.Second),
  	nats.MaxPingsOutstanding(3),
  	nats.MaxReconnects(-1),
  	nats.ReconnectHandler(func(natsConn *nats.Conn) {
  	  log.Println("Connected to NATS server")

      // Re-connect to NATS Streaming  	  
  	  _Connect(nc)
  	}),
  	nats.DisconnectHandler(func(natsConn *nats.Conn) {
  	  log.Println("Disconnected from NATS server")
  	}),
  )
  if err != nil {
  	return err
  }
  
  // Connect to NATS Streaming with NATS connection
  _Connect(nc)
  
  return nil
}

func _Connect(nc *nats.Conn) (stan.Conn, error) {

  return stan.Connect(
  	"test-cluster",
  	"myclient",
  	stan.NatsConn(nc),
  )
}