nats

Documentation

Index

• func ErrorHandler(logger *logr.Logger, h HandlerWithErrors) micro.HandlerFunc
• func HandleNotify(s micro.Service, healthFuncs ...func(chan<- string, micro.Service)) error
• func RequestLogger(l *logr.Logger, subject string) (*logr.Logger, error)
• func SubjectToRequestID(s string) (string, error)
• type ClientError
• type ClientOpt
  • func SetGraphQLExecutableSchema(e graphql.ExecutableSchema) ClientOpt
  • func SetOptions(opts ...nats.Option) ClientOpt
  • func SetServers(s string) ClientOpt
  • func SetSubject(s string) ClientOpt
• type HandlerWithErrors
• type NATSClient
  • func NewNATSClient(subject string, servers []string, opts ...ClientOpt) *NATSClient
  • func (n *NATSClient) Connect() error
  • func (n *NATSClient) HandleAndLogRequests(m *nats.Msg)
  • func (n *NATSClient) Resolve(errChan chan<- error)
• type NATSGraph
• type NatsLogger
  • func NewNatsLogger(subject string, nc *nats.Conn) NatsLogger
  • func (n NatsLogger) Write(p []byte) (int, error)

Functions

func ErrorHandler

func ErrorHandler(logger *logr.Logger, h HandlerWithErrors) micro.HandlerFunc

ErrorHandler wraps a normal micro endpoint and allows for returning errors natively. Errors are checked and if an error is a client error, details are returned, otherwise a 500 is returned and logged

func HandleNotify

func HandleNotify(s micro.Service, healthFuncs ...func(chan<- string, micro.Service)) error

func RequestLogger

func RequestLogger(l *logr.Logger, subject string) (*logr.Logger, error)

func SubjectToRequestID

func SubjectToRequestID(s string) (string, error)

Types

type ClientError

type ClientError interface {
	Error() string
	Code() int
	Body() []byte
}

type ClientOpt

type ClientOpt func(*NATSClient)

func SetGraphQLExecutableSchema

func SetGraphQLExecutableSchema(e graphql.ExecutableSchema) ClientOpt

func SetOptions

func SetOptions(opts ...nats.Option) ClientOpt

func SetServers

func SetServers(s string) ClientOpt

func SetSubject

func SetSubject(s string) ClientOpt

type HandlerWithErrors

type HandlerWithErrors func(*logr.Logger, micro.Request) error

type NATSClient

type NATSClient struct {
	Subject string
	Servers string
	Options []nats.Option
	Conn    *nats.Conn
	JS      nats.JetStreamContext
	NATSGraph
}

func NewNATSClient

func NewNATSClient(subject string, servers []string, opts ...ClientOpt) *NATSClient

func (*NATSClient) Connect

func (n *NATSClient) Connect() error

func (*NATSClient) HandleAndLogRequests

func (n *NATSClient) HandleAndLogRequests(m *nats.Msg)

func (*NATSClient) Resolve

func (n *NATSClient) Resolve(errChan chan<- error)

type NATSGraph

type NATSGraph struct {
	ExecutableSchema graphql.ExecutableSchema
	Exec             *executor.Executor
}

type NatsLogger

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

func NewNatsLogger

func NewNatsLogger(subject string, nc *nats.Conn) NatsLogger

func (NatsLogger) Write

func (n NatsLogger) Write(p []byte) (int, error)