nats

// runNATSContainer {
ctx := context.Background()

natsContainer, err := nats.RunContainer(ctx,
	testcontainers.WithImage("nats:2.9"),
)
if err != nil {
	log.Fatalf("failed to start container: %s", err)
}

// Clean up the container
defer func() {
	if err := natsContainer.Terminate(ctx); err != nil {
		log.Fatalf("failed to terminate container: %s", err)
	}
}()
// }

state, err := natsContainer.State(ctx)
if err != nil {
	log.Fatalf("failed to get container state: %s", err) // nolint:gocritic
}

fmt.Println(state.Running)

Output:

true

package main

import (
	"context"
	"fmt"
	"log"

	natsgo "github.com/nats-io/nats.go"

	"github.com/testcontainers/testcontainers-go/modules/nats"
)

func main() {
	// natsConnect {
	ctx := context.Background()

	container, err := nats.RunContainer(ctx, nats.WithUsername("foo"), nats.WithPassword("bar"))
	if err != nil {
		log.Fatalf("failed to start container: %s", err)
	}

	// Clean up the container
	defer func() {
		if err := container.Terminate(ctx); err != nil {
			log.Fatalf("failed to terminate container: %s", err)
		}
	}()

	uri, err := container.ConnectionString(ctx)
	if err != nil {
		log.Fatalf("failed to get connection string: %s", err) // nolint:gocritic
	}

	nc, err := natsgo.Connect(uri, natsgo.UserInfo(container.User, container.Password))
	if err != nil {
		log.Fatalf("failed to connect to NATS: %s", err)
	}
	defer nc.Close()
	// }

	fmt.Println(nc.IsConnected())

}

Output:

true