natslink

package module

Go to main page

Versions in this module

v1

v1.8.4

Oct 23, 2026

v1.8.3

Oct 15, 2026

v1.8.2

Oct 15, 2026

v1.8.0

Oct 14, 2026

Changes in this version

+ var ErrQueueFull = errors.New("natslink: every endpoint send queue is full")

type Stats

+ QueueDropped uint64

v1.7.0

Oct 14, 2026

Changes in this version

+ type DedupSet struct

+ func NewDedupSet(entries int, window time.Duration) *DedupSet

+ func (d *DedupSet) Entries() int

+ func (d *DedupSet) Seen(data []byte) bool

+ func (d *DedupSet) SeenKey(key uint64) bool

+ func (d *DedupSet) Window() time.Duration

type PublisherPool

+ func NewMirroredPublisher(urls []string, o PublisherOptions) (*PublisherPool, error)

type Stats

+ Deduped uint64

type SubscriberOptions

+ Dedup *DedupSet

+ DedupKey func(msg *nats.Msg) (key uint64, ok bool)

v1.6.1

Oct 7, 2026

v1.6.0

Oct 6, 2026

Changes in this version

+ const GoPerMessage

+ const SyncMode

+ const Version

+ var ErrAlreadyStarted = errors.New("natslink: already started")

+ var ErrNoConn = errors.New("natslink: no usable connection (rebuilding)")

+ var ErrNotRunning = errors.New("natslink: not running")

+ var ErrOversized = errors.New("natslink: payload exceeds MaxPayload")

+ var ErrStopped = errors.New("natslink: already stopped; create a new instance")

+ func MustProbe(natsURL string)

+ func MustProbeEach(natsURLs ...string)

+ func Probe(natsURL string) error

+ type Handler func(msg *nats.Msg)

+ type Logger interface

+ Error func(msg string, ctx ...any)

+ Info func(msg string, ctx ...any)

+ Warn func(msg string, ctx ...any)

+ type Options struct

+ ExtraNatsOptions []nats.Option

+ Logger Logger

+ Name string

+ ReportInterval time.Duration

+ Topic string

+ URL string

+ type Publisher struct

+ func NewPublisher(o PublisherOptions) (*Publisher, error)

+ func (l *Publisher) Conn() *nats.Conn

+ func (l *Publisher) IsConnected() bool

+ func (l *Publisher) Stats() Stats

+ func (l *Publisher) Topic() string

+ func (l *Publisher) WaitConnected(timeout time.Duration) error

+ func (p *Publisher) MustStart()

+ func (p *Publisher) Publish(data []byte) error

+ func (p *Publisher) Start() error

+ func (p *Publisher) Stop()

+ type PublisherOptions struct

+ MaxPayload int

+ type PublisherPool struct

+ func NewMirroredPublisherPool(urls []string, n int, o PublisherOptions) (*PublisherPool, error)

+ func NewPublisherPool(n int, o PublisherOptions) (*PublisherPool, error)

+ func (p *PublisherPool) ConnectedCount() int

+ func (p *PublisherPool) Dropped() uint64

+ func (p *PublisherPool) Endpoints() int

+ func (p *PublisherPool) MustStart()

+ func (p *PublisherPool) Publish(data []byte) error

+ func (p *PublisherPool) Size() int

+ func (p *PublisherPool) Start() error

+ func (p *PublisherPool) Stats() []Stats

+ func (p *PublisherPool) Stop()

+ func (p *PublisherPool) WaitConnected(timeout time.Duration) error

+ type Stats struct

+ Cluster string

+ Connected bool

+ Diverged int

+ Dropped uint64

+ Gated uint64

+ InBytes uint64

+ InMsgs uint64

+ Name string

+ OutBytes uint64

+ OutMsgs uint64

+ Paused bool

+ Pauses uint64

+ QueueCap int

+ QueueLen int

+ Rebuilds uint64

+ Reconnects uint64

+ Running bool

+ Server string

+ SlowConsumers uint64

+ Status string

+ type Subscriber struct

+ func NewMirroredSubscriber(urls []string, o SubscriberOptions) (*Subscriber, error)

+ func NewSubscriber(o SubscriberOptions) (*Subscriber, error)

+ func (s *Subscriber) Conn() *nats.Conn

+ func (s *Subscriber) Endpoints() int

+ func (s *Subscriber) IsConnected() bool

+ func (s *Subscriber) IsPaused() bool

+ func (s *Subscriber) MustStart()

+ func (s *Subscriber) Pause() error

+ func (s *Subscriber) Resume() error

+ func (s *Subscriber) Start() error

+ func (s *Subscriber) Stats() Stats

+ func (s *Subscriber) Stop()

+ func (s *Subscriber) Topic() string

+ func (s *Subscriber) WaitConnected(timeout time.Duration) error

+ type SubscriberOptions struct

+ Gate func() bool

+ Handler Handler

+ PendingBytesLimit int

+ PendingMsgLimit int

+ QueueGroup string

+ QueueSize int

+ Workers int

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL