Kubernetes での NATS ストリーミング用の非常に基本的なアプリケーションをテストしたかったのです。そのために、公式の NATS-docs のコマンドに従いました。
それは基本的に実行に帰着します
kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-server/single-server-nats.yml
kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-streaming-server/single-server-stan.yml
クラスターにアクセスできる端末で(私の場合は一種のクラスターです)。
stan.go
NATS-streaming-client として使用しました。NATS-streaming-server に接続しようとしたコードは次のとおりです。
package main
import stan "github.com/nats-io/stan.go"
func main() {
sc, err := stan.Connect("stan", "test-client")
if err != nil {
panic(err)
}
if err := sc.Publish("test-subject", []byte("This is a test-message!")); err != nil {
panic(err)
}
}
これは私が得ているエラーです:
panic: nats: no servers available for connection
goroutine 1 [running]:
main.main()
/Users/thilt/tmp/main.go:9 +0x15d
exit status 2
そのため、クラスターなどに別の名前が使用されたと思います。上記の docs.nats-link から提供された例を使用するとnats-box
、それも機能しません! ここでどこが間違っていたのですか?
必要に応じて、喜んでさらに情報を提供します。