natscli

Dec 20, 2024

Changes in this version

+ func RequestGo(subj string, data any, timeout time.Duration) (*nats.Msg, error)

type Option

+ func WithJetStream(enable bool) Option

type Options

+ EnableJetStream bool

Dec 2, 2024

Changes in this version

type Option

+ func WithNKey(seedFile string) Option

+ func WithToken(token string) Option

+ func WithUserAndPass(username, password string) Option

Dec 2, 2024

Changes in this version

+ func NewZlogLoggerWithNATS(level string, subj string)

Dec 1, 2024

Changes in this version

+ func AddConsumer(streamName string, config *nats.ConsumerConfig) (err error)

+ func AddStream(streamName string, subjects []string) error

+ func Connect(clientName string, servers []string, options ...Option)

+ func DelConsumer(stream, consumer string) (err error)

+ func DelStream(streamName string) (err error)

+ func JsPub(subj string, data []byte) (err error)

+ func JsQueueSubscribe(subject, queueName string, handler nats.MsgHandler) (err error)

+ func JsSub(subj string, handler nats.MsgHandler) (err error)

+ func Pub(ctx context.Context, subj string, data []byte)

+ func PubGo(ctx context.Context, subj string, data any)

+ func QueueSub(subj, queue string, handler nats.MsgHandler) (err error)

+ func QueueSubSyncWithChan(subject, queueName string, handler chan *nats.Msg) (sub *nats.Subscription, err error)

+ func Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)

+ func Sub(subj string, handler nats.MsgHandler) (err error)

+ type Option func(*Options)

+ type Options struct

+ NKeySeedFile string

+ Password string

+ Token string

+ Username string