| import asyncio | |
| import nats | |
| async def run(): | |
| # With stream and pull consumer created as follows via the NATS Cli: | |
| # | |
| # - Stream: | |
| # | |
| # $ nats stream create | |
| # ? Stream Name foo |
| package main | |
| import ( | |
| "context" | |
| "encoding/json" | |
| "errors" | |
| "math" | |
| "time" | |
| "log" |
| func ExampleContext() { | |
| nc, err := nats.Connect("localhost") | |
| if err != nil { | |
| log.Fatal(err) | |
| } | |
| // Base context | |
| ctx := nats.Context(context.Background()) | |
| js, err := nc.JetStream() |
| package main | |
| import ( | |
| "bytes" | |
| "fmt" | |
| "strings" | |
| "testing" | |
| "github.com/nats-io/nats.go" | |
| "github.com/nats-io/nuid" |
| FROM golang:1.16-alpine AS builder | |
| WORKDIR $GOPATH/src/github.com/nats-io/nats-server | |
| MAINTAINER Waldemar Quevedo <[email protected]> | |
| RUN apk add --update git | |
| COPY . . |
| #!/bin/bash | |
| # | |
| # chkconfig: 35 90 12 | |
| # description: nats-server | |
| # | |
| # Get function from functions library | |
| . /etc/init.d/functions | |
| # Start the service nats-server |
| system_account: sys | |
| accounts { | |
| sys { users = [{user: sys, pass: sys}] } | |
| } | |
| leaf { | |
| port = 7422 | |
| authorization { | |
| users = [ |
| --- | |
| apiVersion: v1 | |
| kind: ConfigMap | |
| metadata: | |
| name: stan-config | |
| data: | |
| stan.conf: | | |
| port: 4222 | |
| http: 8222 |
With the following, you can create a 3-node NATS Server cluster:
kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/b55687a97a5fd55485e1af302fbdbe43d2d3b968/nats-server/leafnodes/nats-cluster.yamlThe configuration map from the NATS cluster that was created can be found below.
| <!doctype html> | |
| <html> | |
| <head> | |
| <meta charset="utf-8"> | |
| </head> | |
| <body> | |
| <script type="module"> | |
| import { connect, StringCodec } from "/nats.mjs"; | |
| document.addEventListener("DOMContentLoaded", function() { |