middleware

Documentation

Index

• Constants
• type Chain
  • func GetChains(chains ...Chain) []Chain
• type MessageChain
  • func GetMessageChains(chains ...MessageChain) []MessageChain
• type MessageMiddleware
  • func NewMessageMiddleware(chains ...MessageChain) *MessageMiddleware
  • func (m *MessageMiddleware) AddChain(chain MessageChain)
  • func (m *MessageMiddleware) Copy() *MessageMiddleware
  • func (m *MessageMiddleware) Merge(middlewares ...*MessageMiddleware)
  • func (m *MessageMiddleware) Then(next corenats.MessageHandler) corenats.MessageHandler
• type MessageRecovery
  • func NewMessageRecovery() *MessageRecovery
  • func (r *MessageRecovery) Call(next corenats.MessageHandler) corenats.MessageHandler
• type Metrics
  • func CreateMeasures() *Metrics
  • func CreateMeasuresWithClient(client *metrics.Client) *Metrics
• type Middleware
  • func NewMiddleware(c ...Chain) *Middleware
  • func (m *Middleware) Then(next subscriber.MsgHandler) subscriber.MsgHandler
• type Recovery
  • func NewRecovery() *Recovery
  • func (t *Recovery) Call(next subscriber.MsgHandler) subscriber.MsgHandler
• type SubMetrics
  • func NewMetrics(m *Metrics) *SubMetrics
  • func (t *SubMetrics) Call(next subscriber.MsgHandler) subscriber.MsgHandler
• type Tracer
  • func NewTracer() *Tracer
  • func (t *Tracer) Call(next subscriber.MsgHandler) subscriber.MsgHandler

Constants

const (
	Count         = "nats.count"
	ContentLength = "nats.content_length"
	Latency       = "nats.duration"
)

const (
	TracerName = "nats"
)

Types

type Chain

type Chain func(h subscriber.MsgHandler) subscriber.MsgHandler

Chain composes legacy NATS SDK-shaped handlers.

Legacy: use MessageChain for new code.

func GetChains

func GetChains(chains ...Chain) []Chain

GetChains prepends legacy recovery middleware.

Legacy: use GetMessageChains for new code.

type MessageChain

type MessageChain func(h corenats.MessageHandler) corenats.MessageHandler

MessageChain composes core-owned NATS message handlers.

func GetMessageChains

func GetMessageChains(chains ...MessageChain) []MessageChain

GetMessageChains prepends the default recovery chain to core-owned message middleware.

type MessageMiddleware

type MessageMiddleware struct {
	// contains filtered or unexported fields
}

MessageMiddleware contains core-owned middleware chains for NATS messages.

func NewMessageMiddleware

func NewMessageMiddleware(chains ...MessageChain) *MessageMiddleware

NewMessageMiddleware creates middleware without exposing NATS SDK message types.

func (*MessageMiddleware) AddChain

func (m *MessageMiddleware) AddChain(chain MessageChain)

AddChain appends a core-owned message middleware chain.

func (*MessageMiddleware) Copy

func (m *MessageMiddleware) Copy() *MessageMiddleware

Copy returns a copy of the middleware chain.

func (*MessageMiddleware) Merge

func (m *MessageMiddleware) Merge(middlewares ...*MessageMiddleware)

Merge appends chains from other message middleware values.

func (*MessageMiddleware) Then

func (m *MessageMiddleware) Then(next corenats.MessageHandler) corenats.MessageHandler

Then wraps the handler with all configured message chains.

type MessageRecovery

type MessageRecovery struct{}

MessageRecovery recovers panics in core-owned message handlers.

func NewMessageRecovery

func NewMessageRecovery() *MessageRecovery

NewMessageRecovery creates panic recovery middleware for core-owned messages.

func (*MessageRecovery) Call

func (r *MessageRecovery) Call(next corenats.MessageHandler) corenats.MessageHandler

Call wraps a core-owned message handler with panic recovery.

type Metrics

type Metrics struct {
	// contains filtered or unexported fields
}

func CreateMeasures

func CreateMeasures() *Metrics

CreateMeasures creates NATS metrics middleware state from the package-level metrics default.

func CreateMeasuresWithClient

func CreateMeasuresWithClient(client *metrics.Client) *Metrics

CreateMeasuresWithClient creates NATS metrics middleware state from an explicit client.

type Middleware

type Middleware struct {
	// contains filtered or unexported fields
}

Middleware contains legacy NATS SDK-shaped middleware chains.

Legacy: use MessageMiddleware for new code.

func NewMiddleware

func NewMiddleware(c ...Chain) *Middleware

NewMiddleware creates legacy NATS SDK-shaped middleware.

Legacy: use NewMessageMiddleware for new code.

func (*Middleware) Then

func (m *Middleware) Then(next subscriber.MsgHandler) subscriber.MsgHandler

Then wraps a legacy NATS SDK-shaped handler.

Legacy: use MessageMiddleware.Then for new code.

type Recovery

type Recovery struct{}

func NewRecovery

func NewRecovery() *Recovery

func (*Recovery) Call

func (t *Recovery) Call(next subscriber.MsgHandler) subscriber.MsgHandler

type SubMetrics

type SubMetrics struct {
	*Metrics
}

SubMetrics implement Middleware interface

func NewMetrics

func NewMetrics(m *Metrics) *SubMetrics

func (*SubMetrics) Call

func (t *SubMetrics) Call(next subscriber.MsgHandler) subscriber.MsgHandler

type Tracer

type Tracer struct{}

Tracer for subscribers implementing Middleware

func NewTracer

func NewTracer() *Tracer

func (*Tracer) Call

func (t *Tracer) Call(next subscriber.MsgHandler) subscriber.MsgHandler