natsjsregistry

package

v1.0.0 Latest Latest Go to latest Published: Feb 24, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Package natsjsregistry implements a registry using natsjs kv store

This section is empty.

This section is empty.

func DefaultTTL(t time.Duration) registry.Option

DefaultTTL allows setting a default register TTL for services

func NewRegistry(opts ...registry.Option) registry.Registry

NewRegistry returns a new natsjs registry

func StoreOptions(opts []store.Option) registry.Option

StoreOptions sets the options for the underlying store

type NatsWatcher interface {
	WatchAll(bucket string, opts ...nats.WatchOpt) (<-chan *natsjskv.StoreUpdate, func() error, error)
}

NatsWatcher is the watcher of the nats interface

type Watcher struct {
	// contains filtered or unexported fields
}

Watcher is used to keep track of changes in the registry

func NewWatcher(s *storeregistry) (*Watcher, error)

NewWatcher returns a new watcher

func (w *Watcher) Next() (*registry.Result, error)

Next returns the next result. It is a blocking call

func (w *Watcher) Stop()

Stop stops the watcher