natstest

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 24, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package natstest starts an embedded, in-process nats-server with JetStream enabled for use in tests. It is a real server (no client mocks), satisfying the requirement that all tests run against a genuine nats-server.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

type Server struct {
	NS *natsserver.Server
	NC *nats.Conn
	JS jetstream.JetStream
}

Server is a running embedded nats-server with a connected client.

func Start 

func Start(t testing.TB) *Server

Start launches an embedded JetStream-enabled nats-server on a random port, returns a connected client and a JetStream context, and registers cleanup with the test.

func (*Server) Connect added in v0.2.0 

func (s *Server) Connect(t testing.TB) *nats.Conn

Connect opens a second, independent connection to the same server, closed when the test ends. Use it where the point under test is that two separate processes share only a NATS cluster: reusing s.NC would hide a dependency on in-process state that a real deployment does not have.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.