nats

package module

Go to main page

Versions in this module

v1

v1.3.0

Nov 25, 2022

Changes in this version

+ const ContentLength

+ const Count

+ const Kind

+ const KindPub

+ const KindRequest

+ const KindRespond

+ const KindSub

+ const Latency

+ type CommonPublish struct

+ func NewCommonPublish(conn *nats.Conn) *CommonPublish

+ func (c *CommonPublish) PublishMsgWithContext(ctx context.Context, msg *nats.Msg) error

+ func (c *CommonPublish) PublishRequestWithContext(_ context.Context, subj, reply string, data []byte) error

+ func (c *CommonPublish) PublishWithContext(ctx context.Context, subj string, data []byte) error

+ func (c *CommonPublish) RequestMsgWithContext(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)

+ func (c *CommonPublish) RequestWithContext(ctx context.Context, subj string, data []byte) (*nats.Msg, error)

+ type ConnContext struct

+ func (c *ConnContext) BuildWrappedHandler(cb MsgHandler) nats.MsgHandler

+ func (c *ConnContext) Conn() *nats.Conn

+ func (c *ConnContext) JetStream(opts ...nats.JSOpt) (*JetStreamContext, error)

+ func (c *ConnContext) QueueSubscribe(subj, queue string, cb MsgHandler) (*nats.Subscription, error)

+ func (c *ConnContext) QueueSubscribeMW(subj, queue string, next PostFn) (*nats.Subscription, error)

+ func (c *ConnContext) Subscribe(subj string, cb MsgHandler) (*nats.Subscription, error)

+ func (c *ConnContext) SubscribeMW(subj string, cb PostFn) (*nats.Subscription, error)

+ func (c ConnContext) DefaultMiddleware() []Middleware

+ func (c ConnContext) DefaultPubMiddleware() []PubMiddleware

+ func (c ConnContext) Middleware() []Middleware

+ func (c ConnContext) PubMiddleware() []PubMiddleware

+ type Core struct

+ func (c Core) DefaultMiddleware() []Middleware

+ func (c Core) DefaultPubMiddleware() []PubMiddleware

+ func (c Core) Middleware() []Middleware

+ func (c Core) PubMiddleware() []PubMiddleware

+ type JetStreamContext struct

+ func (c JetStreamContext) DefaultMiddleware() []Middleware

+ func (c JetStreamContext) DefaultPubMiddleware() []PubMiddleware

+ func (c JetStreamContext) Middleware() []Middleware

+ func (c JetStreamContext) PubMiddleware() []PubMiddleware

+ func (j *JetStreamContext) JS() nats.JetStreamContext

+ func (j *JetStreamContext) PullSubscribe(subj, durable string, opts ...nats.SubOpt) (*nats.Subscription, error)

+ func (j *JetStreamContext) QueueSubscribe(subj, queue string, cb MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)

+ func (j *JetStreamContext) Subscribe(subj string, cb MsgHandler, opts ...nats.SubOpt) (*nats.Subscription, error)

+ type Logs struct

+ func NewLogs(cfg *config) *Logs

+ func (c Logs) DefaultMiddleware() []Middleware

+ func (c Logs) DefaultPubMiddleware() []PubMiddleware

+ func (c Logs) Middleware() []Middleware

+ func (c Logs) PubMiddleware() []PubMiddleware

+ type Middleware interface

+ type MsgHandler func(ctx context.Context, msg *nats.Msg) error

+ type NameFn func(msg *nats.Msg) string

type Option

+ func WithNameFunction(fn NameFn) Option

+ type PubMetric struct

+ func NewPubMetric(m *metrics) *PubMetric

+ func (p *PubMetric) PublishMsgWithContext(ctx context.Context, msg *nats.Msg) (err error)

+ func (p *PubMetric) PublishRequestWithContext(ctx context.Context, subj, reply string, data []byte) (err error)

+ func (p *PubMetric) PublishWithContext(ctx context.Context, subj string, data []byte) (err error)

+ func (p *PubMetric) RequestMsgWithContext(ctx context.Context, msg *nats.Msg) (resp *nats.Msg, err error)

+ func (p *PubMetric) RequestWithContext(ctx context.Context, subj string, data []byte) (resp *nats.Msg, err error)

+ type PubMiddleware interface

+ type PubTrace struct

+ func NewPubTrace(fn NameFn) *PubTrace

+ func (p *PubTrace) PublishMsgWithContext(cxt context.Context, msg *nats.Msg) (err error)

+ func (p *PubTrace) PublishRequestWithContext(ctx context.Context, subj, reply string, data []byte) error

+ func (p *PubTrace) PublishWithContext(cxt context.Context, subj string, data []byte) (err error)

+ func (p *PubTrace) RequestMsgWithContext(cxt context.Context, msg *nats.Msg) (resp *nats.Msg, err error)

+ func (p *PubTrace) RequestWithContext(ctx context.Context, subj string, data []byte) (*nats.Msg, error)

+ type Publish interface

+ PublishMsgWithContext func(ctx context.Context, msg *nats.Msg) error

+ PublishRequestWithContext func(ctx context.Context, subj, reply string, data []byte) error

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

+ RequestMsgWithContext func(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)

+ RequestWithContext func(ctx context.Context, subj string, data []byte) (*nats.Msg, error)

+ type Recovery struct

+ func NewRecovery() *Recovery

+ type SubMetrics struct

+ func NewMetrics(m *metrics) *SubMetrics

+ type SubscriptionStatMetric struct

+ func NewSubscriptionStatMetrics(opts ...Option) (*SubscriptionStatMetric, error)

+ func (s *SubscriptionStatMetric) Hook(sub *nats.Subscription, err error) (*nats.Subscription, error)

+ func (s *SubscriptionStatMetric) Register(sub ...*nats.Subscription)

+ type Tracer struct

+ func NewTracer(fn NameFn) *Tracer

v1.2.4

Nov 18, 2022

Changes in this version

+ const SubscriptionCountMsgs

+ const SubscriptionsDroppedMsgs

+ const SubscriptionsPendingBytes

+ const SubscriptionsPendingCount

+ type SubscriptionMetric struct

+ func NewSubscriptionMetrics(opts ...Option) (*SubscriptionMetric, error)

+ func (s *SubscriptionMetric) Register(sub ...*nats.Subscription)

v1.2.3

Nov 17, 2022

Changes in this version

type Option

+ func WithDumpPayloadOnError(enable bool) Option

+ func WithDumpRequest(enable bool) Option

+ func WithDumpResponse(enable bool) Option

v1.2.2

Oct 31, 2022

v1.2.1

Oct 20, 2022

v1.2.0

Oct 20, 2022

v1.1.0

Oct 1, 2022

v1.0.0

Sep 8, 2022

Changes in this version

+ const IsError

+ const ReadBytesKey

+ const RequestContentLength

+ const RequestCount

+ const ResponseContentLength

+ const ServerLatency

+ const Subject

+ const WroteBytesKey

+ func SemVersion() string

+ func Version() string

+ type MiddleWare struct

+ func New(opts ...Option) *MiddleWare

+ func (n *MiddleWare) Handler(next PostFn) func(*nats.Msg)

+ type Option interface

+ func WithPostHook(cb PostHook) Option

+ func WithReply(inject bool) Option

+ func WithTel(t tel.Telemetry) Option

+ type PostFn func(ctx context.Context, sub string, data []byte) ([]byte, error)

+ type PostHook func(ctx context.Context, msg *nats.Msg, data []byte) error

Other modules containing this package

github.com/tel-io/instrumentation/middleware/nats/v2

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