natsrouter

Jan 15, 2024

Changes in this version

type RouterOption

+ func WithNatsOption(options ...nats.Option) RouterOption

Apr 8, 2023

Changes in this version

+ var ErrUnsupportedEncoding = errors.New("unsupported encoding")

Mar 19, 2023

Changes in this version

+ type EncodedMiddleware struct

+ func NewEncodedMiddleware(cb Handler, encType string) (*EncodedMiddleware, error)

+ func (e *EncodedMiddleware) EncodedMiddleware(NatsCtxHandler) NatsCtxHandler

+ type Handler interface

Mar 17, 2023

Changes in this version

type NatsRouter

+ func Connect(url string, options ...RouterOption) (*NatsRouter, error)

+ func (n *NatsRouter) Drain()

type RouterOption

+ func WithNatsOptions(nopts nats.Options) RouterOption

type RouterOptions

+ ErrorConfig *ErrorConfig

+ NatsOptions nats.Options

+ RequestIdTag string

+ func GetDefaultRouterOptions() RouterOptions

+ func (r RouterOptions) Connect() (*NatsRouter, error)

Mar 9, 2023

Changes in this version

type NatsRouter

+ func (n *NatsRouter) ChanQueueSubscribe(subject, group string, ch chan *NatsMsg) (*nats.Subscription, error)

+ func (n *NatsRouter) ChanSubscribe(subject string, ch chan *NatsMsg) (*nats.Subscription, error)

type Queue

+ func (q *Queue) ChanSubscribe(subject string, ch chan *NatsMsg) (*nats.Subscription, error)

type Subject

+ func (s *Subject) ChanSubscribe(ch chan *NatsMsg) (*nats.Subscription, error)

Mar 5, 2023

Changes in this version

+ const ALL_SUBJECT

+ const ANY_SUBJECT

+ var ErrNonLastAllSubject = errors.New("'all' subject must be last in subject chain")

+ func Version() string

+ type ErrorConfig struct

+ Format string

+ Tag string

+ type HandlerError struct

+ Code int

+ Message string

+ func (e *HandlerError) Error() string

+ type NatsCtxHandler func(*NatsMsg) error

+ type NatsMiddlewareFunc func(NatsCtxHandler) NatsCtxHandler

+ type NatsMsg struct

+ func (n *NatsMsg) Context() context.Context

+ func (n *NatsMsg) Respond(data []byte) error

+ func (n *NatsMsg) RespondWithHeaders(data []byte, headers map[string]string) error

+ func (n *NatsMsg) RespondWithOriginalHeaders(data []byte, headers ...string) error

+ func (n *NatsMsg) WithContext(ctx context.Context) *NatsMsg

+ type NatsRouter struct

+ func NewRouter(nc *nats.Conn, options ...RouterOption) *NatsRouter

+ func NewRouterWithAddress(addr string, options ...RouterOption) (*NatsRouter, error)

+ func (n *NatsRouter) Close()

+ func (n *NatsRouter) Conn() *nats.Conn

+ func (n *NatsRouter) Publish(subject string, data []byte) error

+ func (n *NatsRouter) Queue(group string) *Queue

+ func (n *NatsRouter) QueueSubscribe(subject, group string, handler NatsCtxHandler) (*nats.Subscription, error)

+ func (n *NatsRouter) Subject(subjects ...string) *Subject

+ func (n *NatsRouter) Subscribe(subject string, handler NatsCtxHandler) (*nats.Subscription, error)

+ func (n *NatsRouter) Use(fns ...NatsMiddlewareFunc) *NatsRouter

+ func (n *NatsRouter) Wiretap() *Subject

+ func (n *NatsRouter) WithMiddleware(fns ...NatsMiddlewareFunc) *NatsRouter

+ type Queue struct

+ func (q *Queue) Subject(subjects ...string) *Subject

+ func (q *Queue) Subscribe(subject string, handler NatsCtxHandler) (*nats.Subscription, error)

+ func (q *Queue) Use(fns ...NatsMiddlewareFunc) *Queue

+ func (q *Queue) WithMiddleware(fns ...NatsMiddlewareFunc) *Queue

+ type RouterOption func(options *RouterOptions)

+ func WithErrorConfig(ec *ErrorConfig) RouterOption

+ func WithErrorConfigString(tag, format string) RouterOption

+ func WithRequestIdTag(tag string) RouterOption

+ type RouterOptions struct

+ type Subject struct

+ func (s *Subject) All() *Subject

+ func (s *Subject) Any() *Subject

+ func (s *Subject) Queue(group string) *Subject

+ func (s *Subject) Subject(subjects ...string) *Subject

+ func (s *Subject) Subscribe(handler NatsCtxHandler) (*nats.Subscription, error)