nacl

README

nacl

Client helper for NATS/STAN

Documentation

Index

• Variables
• func FinalizeNats(subscriptions *[]*NatsSubscription) error
• func FinalizeStan(subscriptions *[]Subscription) error
• func SetupNats(host string, port int, user string, pass string, ...) error
• func SetupStan(clusterName string, clientId string, host string, port int, user string, ...) (err error)
• type Msg
• type NatsMsg
• type NatsSubscription
• type Subscription

Variables

var (
	NatsClient *nats.Conn
	StanClient stan.Conn
)

Functions

func FinalizeNats

func FinalizeNats(subscriptions *[]*NatsSubscription) error

func FinalizeStan

func FinalizeStan(subscriptions *[]Subscription) error

func SetupNats

func SetupNats(host string, port int, user string, pass string, closeHandler *grawt.CloseHandler) error

func SetupStan

func SetupStan(clusterName string, clientId string, host string, port int, user string, pass string, closeHandler *grawt.CloseHandler) (err error)

Types

type Msg

type Msg = stan.Msg

type NatsMsg

type NatsMsg = nats.Msg

type NatsSubscription

type NatsSubscription = nats.Subscription

type Subscription

type Subscription = stan.Subscription