NATS Server

A Go package for running an embedded NATS server.

Usage

nats-server/examples/auth-none/main.go

Lines 21 to 63 in b542d33

	package main
	import (
	"log/slog"
	"os"
	"os/signal"
	"syscall"
	"time"
	natsserver "github.com/nats-io/nats-server/v2/server"
	"github.com/osapi-io/nats-server/pkg/server"
	)
	func main() {
	debug := true
	trace := debug
	logger := slog.Default()
	opts := &server.Options{
	Options: &natsserver.Options{
	JetStream: true,
	Debug: debug,
	Trace: trace,
	StoreDir: ".nats/jetstream/",
	NoSigs: true,
	NoLog: false,
	},
	ReadyTimeout: 5 * time.Second,
	}
	s := server.New(logger, opts)
	err := s.Start()
	if err != nil {
	logger.Error("failed to start server", "error", err)
	os.Exit(1)
	}
	quit := make(chan os.Signal, 1)
	signal.Notify(quit, os.Interrupt, syscall.SIGTERM)
	<-quit
	s.Stop()
	}

See the examples section for additional use cases.

Documentation

See the generated documentation for details on available packages and functions.

Contributing

See the Development guide for prerequisites, setup, and conventions. See the Contributing guide before submitting a PR.

License

The MIT License.