newrelic

Documentation

Index

• func IsEnabled() bool
• func NewPublisherRegister() ginats.PublisherMiddleware
• func SubscriberRegister(msgHandler nats.MsgHandler) nats.MsgHandler
• type PublisherRegister
  • func (p *PublisherRegister) After(ctx context.Context) error
  • func (p *PublisherRegister) Before(ctx context.Context, conn *nats.Conn, msg *nats.Msg) (context.Context, error)

Functions

func IsEnabled

func IsEnabled() bool

func NewPublisherRegister

func NewPublisherRegister() ginats.PublisherMiddleware

func SubscriberRegister

func SubscriberRegister(msgHandler nats.MsgHandler) nats.MsgHandler

Types

type PublisherRegister

type PublisherRegister struct {
}

func (*PublisherRegister) After

func (p *PublisherRegister) After(ctx context.Context) error

func (*PublisherRegister) Before

func (p *PublisherRegister) Before(ctx context.Context, conn *nats.Conn, msg *nats.Msg) (context.Context, error)