Documentation ¶
Index ¶
- func DefaultNatsDisconnectErrHandler(logger Logger) nats.ConnErrHandler
- func DefaultNatsErrHandler(logger Logger) nats.ErrHandler
- func DefaultNatsReconnectHandler(logger Logger) nats.ConnHandler
- func NewNatsClient(cfg *Config, logger Logger) (*nats.Conn, error)
- func NewNatsJS(cfg *Config, nc *nats.Conn) (nats.JetStreamContext, error)
- type Config
- type Logger
- type Manager
- type Publisher
- type Service
- type Subscriber
- func (s *Subscriber) AddChanSyncSubscription(ctx context.Context, subject string, chanSize, msgLimit, bytesLimit int, ...)
- func (s *Subscriber) AddJsPullSubscription(ctx context.Context, subject, durable string, batch int, ...)
- func (s *Subscriber) AddSyncSubscription(ctx context.Context, subject string, msgLimit, bytesLimit int, ...)
- func (s *Subscriber) Run(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DefaultNatsDisconnectErrHandler ¶
func DefaultNatsDisconnectErrHandler(logger Logger) nats.ConnErrHandler
func DefaultNatsErrHandler ¶
func DefaultNatsErrHandler(logger Logger) nats.ErrHandler
func DefaultNatsReconnectHandler ¶
func DefaultNatsReconnectHandler(logger Logger) nats.ConnHandler
func NewNatsClient ¶
Types ¶
type Config ¶
type Config struct { NatsURL string ServiceName string ServiceVersion string ServiceSubjectPrefix string ConnectTimeout time.Duration ReconnectWait time.Duration TotalWait time.Duration ReconnectBufSize int PublishRetryWait time.Duration MaxWaitResp time.Duration MaxWaitJsPull time.Duration RatryFailedMsgChanSize int }
func DefaultConfig ¶
type Manager ¶
type Manager struct { NC *nats.Conn JS nats.JetStreamContext Pub *Publisher Sub *Subscriber Svc *Service // contains filtered or unexported fields }
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
func NewPublisher ¶
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) AddEndpoint ¶
type Subscriber ¶
type Subscriber struct {
// contains filtered or unexported fields
}
func NewSubscriber ¶
func NewSubscriber(cfg *Config, nc *nats.Conn, js nats.JetStreamContext, logger Logger) *Subscriber
func (*Subscriber) AddChanSyncSubscription ¶
func (s *Subscriber) AddChanSyncSubscription(ctx context.Context, subject string, chanSize, msgLimit, bytesLimit int, f func(m *nats.Msg))
func (*Subscriber) AddJsPullSubscription ¶
func (s *Subscriber) AddJsPullSubscription(ctx context.Context, subject, durable string, batch int, handler func(msgs []*nats.Msg), opts ...nats.SubOpt)
func (*Subscriber) AddSyncSubscription ¶
func (s *Subscriber) AddSyncSubscription(ctx context.Context, subject string, msgLimit, bytesLimit int, f func(m *nats.Msg))
Click to show internal directories.
Click to hide internal directories.