wallyqs

First, create a few volumes so that state is persisted across restarts:

docker volume create nats1
docker volume create nats2
docker volume create nats3

Now create a docker-compose.yaml with the following:

wallyqs

Approach 1

Steps

$ rm go.sum 
$ rm go.mod

$ go run examples/stan-pub/main.go 
examples/stan-pub/main.go:24:2: no required module provides package github.com/nats-io/nats.go: go.mod file not found in current directory or any parent directory; see 'go help modules'

wallyqs

import asyncio

import nats
from nats.errors import TimeoutError


async def main():
    nc = await nats.connect("localhost")

    # Create JetStream context.

wallyqs

import asyncio

import nats
from nats.errors import TimeoutError


async def main():
    nc = await nats.connect("localhost")

    # Create JetStream context.

wallyqs

import argparse
import asyncio
import sys
import time
from random import randint

import nats

try:
  import uvloop

wallyqs

nats:
  image: nats:alpine

  jetstream:
    enabled: true

    memStorage:
      enabled: true
      size: "2Gi"

wallyqs

require 'nats'

# Connect to server that has JetStream support, e.g.
# 
#   nats-server -js
# 
# To include in Gemfile:
#
#   source "https://rubygems.org"
#

wallyqs

 nats:
    image: nats:2.4.0-alpine

    limits:
      maxConnections:
      maxSubscriptions:
      maxControlLine:
      maxPayload:
      writeDeadline:
      maxPending:

wallyqs

Mixed Auth via Leafnodes

Server A starts with basic auth:

port = 4222

leaf {
  port = 7422
}

wallyqs

package main

import (
	"fmt"
	"log"

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

func main() {