middleware

README

Here are a couple of example middlewares for natsmicromw. The middlewares are:

• requestid.go: Request ID middleware that parses the header for a request id (storing it into the request context), or generates a unique ID for each request using the header tag 'request_id' or a specified header tag.
• metrics.go: Metrics middleware that collects Prometheus metrics for NATS messages including the total number of messages received, duration of requests, and size of payloads.

Documentation

Index

• func MetricsContextMiddleware(next natsmicromw.ContextHandlerFunc) natsmicromw.ContextHandlerFunc
• func MetricsMiddleware(next micro.Handler) micro.Handler
• func RequestIdFromContext(ctx context.Context) string
• func RequestIdMiddleware(tags ...string) func(next natsmicromw.ContextHandlerFunc) natsmicromw.ContextHandlerFunc

Functions

func MetricsContextMiddleware

func MetricsContextMiddleware(next natsmicromw.ContextHandlerFunc) natsmicromw.ContextHandlerFunc

Same middleware but with context support

func MetricsMiddleware

func MetricsMiddleware(next micro.Handler) micro.Handler

Middleware that increments the message count metric

func RequestIdFromContext

func RequestIdFromContext(ctx context.Context) string

Get current request Id from the context

func RequestIdMiddleware

func RequestIdMiddleware(tags ...string) func(next natsmicromw.ContextHandlerFunc) natsmicromw.ContextHandlerFunc

An example request id middleware