testutils

Oct 27, 2025

Changes in this version

+ var ErrPublishTimeout = eris.New("publish operation timed out")

+ var ErrServerStartTimeout = eris.New("NATS server failed to start within timeout")

+ var ErrSubscriberTimeout = eris.New("timeout waiting for subscribers")

+ type NATS struct

+ Client *nats.Conn

+ Server *server.Server

+ func NewNATS(t *testing.T) *NATS

+ func (n *NATS) Publish(subject string, data []byte) error

+ func (n *NATS) PublishWithReply(subject string, data []byte, timeout time.Duration) ([]byte, error)

+ func (n *NATS) QueueSubscribeSync(subject, queue string) *nats.Subscription

+ func (n *NATS) Shutdown()

+ func (n *NATS) SubscribeSync(subject string) *nats.Subscription

+ func (n *NATS) WaitForMessage(sub *nats.Subscription, timeout time.Duration) *nats.Msg

+ func (n *NATS) WaitForSubscribers(numSubscribers int, timeout time.Duration) bool