nats

Documentation

Overview

Example (Handler)

cb := func(ctx context.Context, sub string, data []byte) ([]byte, error) {
	return nil, nil
}

tele := tel.NewNull()
mw := New(tele, false)

conn, _ := nats.Connect("example.com")
_, _ = conn.QueueSubscribe("sub", "queue", mw.Handler(cb))
_, _ = conn.QueueSubscribe("sub2", "queue", mw.Handler(cb))

Index

• type MiddleWare
  • func New(tele tel.Telemetry, reply bool) *MiddleWare
  • func (n *MiddleWare) Handler(next PostFn) func(*nats.Msg)
• type PostFn

Examples

• Package (Handler)

Types

type MiddleWare

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

MiddleWare helper

func New

func New(tele tel.Telemetry, reply bool) *MiddleWare

New nats middleware

func (*MiddleWare) Handler

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

Handler is entry point perform recovery, debug logging and perform tracing

type PostFn

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

PostFn callback function which got new instance of tele inside ctx and msg sub + data