natsserver

Documentation

Index

• type NatsPublisher
• type NatsServer
  • func New(opts *server.Options, logger *log.Logger) *NatsServer
  • func (n *NatsServer) MessageLogger(msg *nats.Msg)
  • func (n *NatsServer) Publish(subject string, v interface{}) error
  • func (n *NatsServer) Shutdown()
  • func (n *NatsServer) Start(ctx context.Context) error
  • func (n *NatsServer) Subscribe(subject string, cb nats.Handler) (*nats.Subscription, error)

Types

type NatsPublisher

type NatsPublisher interface {
	Publish(subject string, v interface{}) error
}

type NatsServer

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

func New

func New(opts *server.Options, logger *log.Logger) *NatsServer

func (*NatsServer) MessageLogger

func (n *NatsServer) MessageLogger(msg *nats.Msg)

func (*NatsServer) Publish

func (n *NatsServer) Publish(subject string, v interface{}) error

func (*NatsServer) Shutdown

func (n *NatsServer) Shutdown()

func (*NatsServer) Start

func (n *NatsServer) Start(ctx context.Context) error

func (*NatsServer) Subscribe

func (n *NatsServer) Subscribe(subject string, cb nats.Handler) (*nats.Subscription, error)