nacl

README

nacl

Client helper for NATS/STAN

examples

connect to NATS

package main

import (
    "fmt"
    "github.com/jar3b/grawt"
    "github.com/jar3b/nacl"
    "github.com/kelseyhightower/envconfig"
)

func main() {
    // get params
    conf := config.NewConfig()

	// init waiter (github.com/jar3b/grawt)
	var waiter = grawt.NewWaiter()

	// init nats
	var subscriptions []*nacl.NatsSubscription
	if err := nacl.SetupNats(conf.Nats.Host, conf.Nats.Port, conf.Nats.User, conf.Nats.Pass,
		// handler called before app closed
        // we need to terminate sub's properly and sometimes doing another actions (finalizers)
        waiter.AddCloseHandler(func() {
			nacl.FinalizeNats(&subscriptions)
		}, false),
	); err != nil {
		waiter.Halt(fmt.Errorf("cannot connect to nats: %v", err))
	}
	defer nacl.NatsClient.Close()
	
    // here we add some subscriptions and wait (using blocking call)
    // ...
}

Documentation

Index

• Variables
• func AddOrUpdateConsumer(stream string, consumer string, cfg *nats.ConsumerConfig, allowDelete bool, ...) (*nats.ConsumerInfo, error)
• func AddOrUpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)
• func FinalizeJetStream(subscriptions *[]*nats.Subscription) error
• func FinalizeNats(subscriptions *[]*nats.Subscription) error
• func SetupJetStream(host string, port int, credsFile string, appName string, ...) error
• func SetupNatsWithCreds(natsURL string, credsFile string, appName string, ...) error

Variables

var (
	JsClient nats.JetStreamContext
)

var (
	NatsClient *nats.Conn
)

Functions

func AddOrUpdateConsumer

func AddOrUpdateConsumer(stream string, consumer string, cfg *nats.ConsumerConfig, allowDelete bool, opts ...nats.JSOpt) (*nats.ConsumerInfo, error)

func AddOrUpdateStream

func AddOrUpdateStream(cfg *nats.StreamConfig, opts ...nats.JSOpt) (*nats.StreamInfo, error)

func FinalizeJetStream

func FinalizeJetStream(subscriptions *[]*nats.Subscription) error

func FinalizeNats

func FinalizeNats(subscriptions *[]*nats.Subscription) error

func SetupJetStream

func SetupJetStream(host string, port int, credsFile string, appName string, closeHandler *grawt.CloseHandler, opts ...nats.JSOpt) error

func SetupNatsWithCreds

func SetupNatsWithCreds(
	natsURL string,
	credsFile string,
	appName string,
	closeHandler *grawt.CloseHandler,
	errorHandler nats.ErrHandler,
) error