core

Documentation

Index

• Constants
• Variables
• func ApiError(code codes.Code, msg any) []byte
• func Call[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, middleware []Handler, ...) error
• func CallServerAPI[T proto.Message, U proto.Message](ctx context.Context, panicRecovery bool, errorHandler ErrorHandler, ...) error
• func ErrorResponse(m *nats.Msg, code codes.Code, msg any)
• func Listen[T proto.Message, U proto.Message](con *nats.Conn, panicRecovery bool, subList *sync.Map, middleware []Handler, ...) error
• func RecoverAPIpanic(msg *nats.Msg)
• type ErrorHandler
• type Handler

Constants

const (
	ErrorPrefix    = "ERR\x01" // ErrorPrefix ERR(Start of Heading) Denotes an API error.
	ErrorSeparator = "\x02"    // ErrorSeparator (Start of Text) Denotes the start of the API error message.
)

Variables

var DefaultHandler = make([]Handler, 0)

Functions

func ApiError

func ApiError(code codes.Code, msg any) []byte

func Call

func Call[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, middleware []Handler, errorHandler ErrorHandler, subject string, command T, ret U) error

Call provides the functionality to call NATS req/rep APIs

func CallServerAPI

func CallServerAPI[T proto.Message, U proto.Message](ctx context.Context, panicRecovery bool, errorHandler ErrorHandler, container T, msg *nats.Msg, fn func(ctx context.Context, req T) (U, error)) error

func ErrorResponse

func ErrorResponse(m *nats.Msg, code codes.Code, msg any)

func Listen

func Listen[T proto.Message, U proto.Message](con *nats.Conn, panicRecovery bool, subList *sync.Map, middleware []Handler, errorHandler ErrorHandler, subject string, req T, fn func(ctx context.Context, req T) (U, error)) error

func RecoverAPIpanic

func RecoverAPIpanic(msg *nats.Msg)

Types

type ErrorHandler

type ErrorHandler func(err error, msg *nats.Msg) error

var DefaultErrorHandler ErrorHandler = func(err error, msg *nats.Msg) error {
	c := codes.Unknown
	ErrorResponse(msg, c, err.Error())
	return fmt.Errorf("API call: %w", err)
}

type Handler

type Handler func(ctx context.Context, msg *nats.Msg) (context.Context, error)