natsconn

Apr 13, 2026

Changes in this version

type Config

+ Replicas int

type ReloadableConnection

+ Replicas int

Apr 6, 2026

Changes in this version

+ type Config struct

+ Name string

+ Token string

+ URI string

+ type ReloadableConnection struct

+ func New(cfg *Config, logger log.Logger) (*ReloadableConnection, func(), error)

+ func (rc *ReloadableConnection) Broadcast()

+ func (rc *ReloadableConnection) Subscribe(ctx context.Context) <-chan struct{}