natstream

Mar 17, 2022

Changes in this version

+ type Option func(opt *Options)

+ func WithClientID(id string) Option

+ func WithClusterID(id string) Option

+ func WithContext(ctx context.Context) Option

+ func WithEncoder(encoder encoder.Encoder) Option

+ func WithErrorHandler(h nc.ErrorHandler) Option

+ func WithGroupName(name string) Option

+ func WithLogger(logger loggerInterface) Option

+ func WithNatsConn(nc *nats.Conn) Option

+ func WithNatsOptions(natsOpts ...nstream.Option) Option

+ func WithNatsURL(urlString string) Option

+ func WithPanicHandler(h nc.PanicHandler) Option

+ func WithTopics(topics ...string) Option

+ type Options struct

+ ClientID string

+ ClusterID string

+ Ctx context.Context

+ Encoder encoder.Encoder

+ ErrorHandler nc.ErrorHandler

+ GroupName string

+ Logger loggerInterface

+ NatsOptions []nstream.Option

+ NatsSubscriptions []nstream.Subscription

+ PanicHandler nc.PanicHandler

+ Topics []string

+ type Publisher struct

+ func MustNewPublisher(options ...Option) *Publisher

+ func NewPublisher(options ...Option) (*Publisher, error)

+ func (s *Publisher) Close() error

+ func (s *Publisher) Publish(ctx context.Context, messages ...any) (err error)

+ type Subscriber struct

+ func MustNewSubscriber(options ...Option) *Subscriber

+ func NewSubscriber(options ...Option) (*Subscriber, error)

+ func (s *Subscriber) Close() error

+ func (s *Subscriber) Listen(ctx context.Context) error