neilalexander
commented
10 months ago Certainly a NATS Server node should work the same whether it is standalone or embedded, although configuring via nats.Options is certainly more difficult.
This snippet works to start a cluster node that joins an existing cluster from the provided configuration file:
package main
import (
"fmt"
"time"
natsserver "github.com/nats-io/nats-server/v2/server"
natsclient "github.com/nats-io/nats.go"
)
func main() {
var opts natsserver.Options
if err := opts.ProcessConfigFile("/Users/neil/Workspace/nats-cluster/n1-c1.conf"); err != nil {
panic(err)
}
server, err := natsserver.NewServer(&opts)
if err != nil {
panic(err)
}
server.ConfigureLogger()
server.Start()
if !server.ReadyForConnections(time.Second * 10) {
panic("NATS server didn't start")
}
client, err := natsclient.Connect("", natsclient.InProcessServer(server))
if err != nil {
panic(err)
}
js, err := client.JetStream()
if err != nil {
panic(err)
}
kv, err := js.CreateKeyValue(&natsclient.KeyValueConfig{
Bucket: "test",
})
if err != nil {
panic(err)
}
for k, v := range map[string]string{
"foo": "bar",
"baz": "qux",
} {
if _, err := kv.PutString(k, v); err != nil {
panic(err)
}
}
keys, err := kv.Keys()
if err != nil {
panic(err)
}
fmt.Println("Found keys:", keys)
server.WaitForShutdown()
}Config file:
server_name=n1-c1
listen=4221
prof_port=6221
monitor_port=7221
jetstream {
store_dir="."
}
accounts: {
$SYS: {
users: [{user: sys, password: sys}]
}
}
cluster {
name: C1
listen: 127.0.0.1:5221
routes: [
nats-route://127.0.0.1:5222
nats-route://127.0.0.1:5223
nats-route://127.0.0.1:5224
nats-route://127.0.0.1:5225
nats-route://127.0.0.1:5226
nats-route://127.0.0.1:5227
nats-route://127.0.0.1:5228
nats-route://127.0.0.1:5229
]
}
adoublef
ripienaar
Observed behavior
I am failing to get a JetStream Cluster running with an embedded nats-server. The error I get when creating a KV Store is
context deadline exceededthus I am unsure what is the exact cause without going into the nats-server source code.According to the offical docs here it should be possible to run NATS inside a Go binary.
Here it mentions how to setup a JetStream cluster, requiring at least 3 nodes to be connected due to the use of the RAFT algorithm.
I haven't seen any indication that this is not possible nor have I seen anything in the Slack channels or on issues of similar experiments.
Expected behavior
To run the same as the client/server version. I am using identical configurations thus I am unsure if there is anything extra I would need to look out for.
Ideally I would want to use the
server.Optionstruct directly, but understanding how the config file maps to the struct proved to be a bit more challenging so for now will be happy to get the config file working.Server and client version
Embedded into a Go binary (Go v1.21.3)
Host environment
WSL2 Debian 12 (via Windows 11 Home) Docker Engine: 24.0.6
Steps to reproduce
I have attached a link to the issue.
To reproduce, will just need to run the steps listed in the
README.md