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 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