msg

Documentation

Index

• Variables
• func BytesToTree(id62 string, bytes []byte)
• func Connect() (*nats.Conn, error)
• func ConnectNatsStreaming(clientID string) (stan.Conn, error)
• func ToTree(id62 string, msg interface{})

Variables

var NATS *nats.Conn

var STAN stan.Conn

Functions

func BytesToTree

func BytesToTree(id62 string, bytes []byte)

func Connect

func Connect() (*nats.Conn, error)

func ConnectNatsStreaming

func ConnectNatsStreaming(clientID string) (stan.Conn, error)

Connect to NATS-streaming (for persistent queue)

func ToTree

func ToTree(id62 string, msg interface{})