nats

func NewRegistry ¶

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

func Options ¶ added in v0.7.0

func Options(nopts nats.Options) registry.Option

Options allow to inject a nats.Options struct for configuring the nats connection

func QueryTopic ¶

func QueryTopic(s string) registry.Option

QueryTopic allows to set a custom nats topic on which service registries query (survey) other services. All registries listen on this topic and then respond to the query message.

func Quorum ¶

func Quorum(n int) registry.Option

func WatchTopic ¶

func WatchTopic(s string) registry.Option

WatchTopic allows to set a custom nats topic on which registries broadcast changes (e.g. when services are added, updated or removed). Since we don't have a central registry service, each service typically broadcasts in a determined frequency on this topic.