newrelic

Documentation

Index

• func ConfigAdd(path string)
• func NewPublisherRegister() ginats.PublisherMiddleware
• func NewPublisherRegisterWithConfigPath(path string) (ginats.PublisherMiddleware, error)
• func NewPublisherRegisterWithOptions(options *Options) ginats.PublisherMiddleware
• func Register(msgHandler nats.MsgHandler) nats.MsgHandler
• type Options
  • func NewOptions() (*Options, error)
  • func NewOptionsWithPath(path string) (opts *Options, err error)
• type Publisher
  • func (p *Publisher) After(ctx context.Context) error
  • func (p *Publisher) Before(ctx context.Context, conn *nats.Conn, msg *nats.Msg) (context.Context, error)
• type Subscriber
  • func NewSubscriber() *Subscriber
  • func NewSubscriberWithConfigPath(path string) (*Subscriber, error)
  • func NewSubscriberWithOptions(options *Options) *Subscriber
  • func (p *Subscriber) Register(msgHandler nats.MsgHandler) nats.MsgHandler

Functions

func ConfigAdd

func ConfigAdd(path string)

func NewPublisherRegister

func NewPublisherRegister() ginats.PublisherMiddleware

func NewPublisherRegisterWithConfigPath

func NewPublisherRegisterWithConfigPath(path string) (ginats.PublisherMiddleware, error)

func NewPublisherRegisterWithOptions

func NewPublisherRegisterWithOptions(options *Options) ginats.PublisherMiddleware

func Register

func Register(msgHandler nats.MsgHandler) nats.MsgHandler

Types

type Options

type Options struct {
	Enabled bool
}

func NewOptions

func NewOptions() (*Options, error)

func NewOptionsWithPath

func NewOptionsWithPath(path string) (opts *Options, err error)

type Publisher

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

func (*Publisher) After

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

func (*Publisher) Before

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

type Subscriber

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

func NewSubscriber

func NewSubscriber() *Subscriber

func NewSubscriberWithConfigPath

func NewSubscriberWithConfigPath(path string) (*Subscriber, error)

func NewSubscriberWithOptions

func NewSubscriberWithOptions(options *Options) *Subscriber

func (*Subscriber) Register

func (p *Subscriber) Register(msgHandler nats.MsgHandler) nats.MsgHandler