natsutil

Documentation

Index

• Constants
• func Connect(clusterId string, clientId string, natsUrl string, logger *zap.SugaredLogger) (*stan.Conn, error)
• func JetStreamConnect(jetStreamUrl string, logger *zap.SugaredLogger) (*nats.Conn, error)

Constants

const (
	//  StreamName is the name of StreamConfig for JetStream
	StreamName = "K-ORDERS"

	// MaxPending is the maximum outstanding async publishes that can be inflight at one time.
	MaxPending = 256
)

Functions

func Connect

func Connect(clusterId string, clientId string, natsUrl string, logger *zap.SugaredLogger) (*stan.Conn, error)

Connect creates a new NATS-Streaming connection

func JetStreamConnect

func JetStreamConnect(jetStreamUrl string, logger *zap.SugaredLogger) (*nats.Conn, error)

JetStreamConnect creates a new NATS JetStream connection