server

Documentation

Index

• type AbandonOpError
  • func Abandon(err error) *AbandonOpError
  • func (w *AbandonOpError) Error() string
• type Server
  • func New(js nats.JetStreamContext, logger *zap.Logger, res *resource.Resource, ...) *Server
  • func (s *Server) Listen() error

Types

type AbandonOpError

type AbandonOpError struct {
	Err error
}

func Abandon

func Abandon(err error) *AbandonOpError

func (*AbandonOpError) Error

func (w *AbandonOpError) Error() string

type Server

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

func New

func New(js nats.JetStreamContext, logger *zap.Logger, res *resource.Resource, exp *jaeger.Exporter) *Server

func (*Server) Listen

func (s *Server) Listen() error