From c1af7dd5ce6304056d0b694112a0cc6f28c773ff Mon Sep 17 00:00:00 2001 From: kobergj Date: Mon, 18 Dec 2023 10:17:48 +0100 Subject: [PATCH] use kv store in natsjs registry (#7987) Signed-off-by: jkoberg --- changelog/unreleased/kv-nats-registry.md | 5 +++++ ocis-pkg/natsjsregistry/registry.go | 6 +++--- 2 files changed, 8 insertions(+), 3 deletions(-) create mode 100644 changelog/unreleased/kv-nats-registry.md diff --git a/changelog/unreleased/kv-nats-registry.md b/changelog/unreleased/kv-nats-registry.md new file mode 100644 index 0000000000..12e01d7c8e --- /dev/null +++ b/changelog/unreleased/kv-nats-registry.md @@ -0,0 +1,5 @@ +Enhancement: Use kv store in natsjs registry + +Replaces the nats object store with the nats kv store in the natsjs registry + +https://github.com/owncloud/ocis/pull/7987 diff --git a/ocis-pkg/natsjsregistry/registry.go b/ocis-pkg/natsjsregistry/registry.go index 5f1e479fc4..1685515a21 100644 --- a/ocis-pkg/natsjsregistry/registry.go +++ b/ocis-pkg/natsjsregistry/registry.go @@ -1,4 +1,4 @@ -// Package natsjsregistry implements a registry using natsjs object store +// Package natsjsregistry implements a registry using natsjs kv store package natsjsregistry import ( @@ -7,7 +7,7 @@ import ( "errors" "time" - natsjs "github.com/go-micro/plugins/v4/store/nats-js" + natsjskv "github.com/go-micro/plugins/v4/store/nats-js-kv" "go-micro.dev/v4/registry" "go-micro.dev/v4/store" "go-micro.dev/v4/util/cmd" @@ -30,7 +30,7 @@ func NewRegistry(opts ...registry.Option) registry.Registry { exp, _ := options.Context.Value(expiryKey{}).(time.Duration) return &storeregistry{ opts: options, - store: natsjs.NewStore(storeOptions(options)...), + store: natsjskv.NewStore(storeOptions(options)...), typ: _registryName, expiry: exp, }