peanats

package module

Go to main page

Versions in this module

v0

v0.10.1

Jan 31, 2025

v0.10.0

Jan 31, 2025

v0.9.4

Jan 30, 2025

Changes in this version

type TypedPublisher

+ func NewTypedPublisher[RS any](codec Codec, pub Publisher) TypedPublisher[RS]

v0.9.3

Dec 12, 2024

v0.9.2

Nov 29, 2024

v0.9.1

Oct 24, 2024

v0.9.0

Oct 24, 2024

v0.8.2

Oct 24, 2024

v0.8.1

Oct 24, 2024

v0.8.0

Oct 23, 2024

Changes in this version

+ type Matcher interface

+ Match func(string) bool

+ func NewMatcher(pat string) Matcher

v0.7.3

Oct 23, 2024

v0.7.2

Oct 23, 2024

v0.7.1

Oct 17, 2024

v0.7.0

Oct 17, 2024

v0.6.4

Oct 16, 2024

v0.6.3

Oct 16, 2024

v0.6.2

Oct 16, 2024

v0.6.1

Oct 16, 2024

v0.6.0

Oct 16, 2024

Changes in this version

type TypedPublisher

+ Subject func() string

+ WithSubject func(string) TypedPublisher[ResT]

v0.5.0

Jun 19, 2024

Changes in this version

+ const HeaderErrorCode

+ const HeaderErrorMessage

+ const HeaderRequestUID

+ var ErrMuxNotFound = errors.New("not found")

+ func PublishError(pub Publisher, err error) error

+ type AccessLogMiddlewareOption func(*loggingPublisher)

+ func AccessLogMiddlewareWithLogger(log AccessLogger) AccessLogMiddlewareOption

+ func AccessLogMiddlewareWithWriter(w io.Writer) AccessLogMiddlewareOption

+ type AccessLogger interface

+ Println func(v ...any)

+ type ChanSubscriber interface

+ ChanQueueSubscribe func(subj, queue string, ch chan *nats.Msg) (Unsubscriber, error)

+ ChanSubscribe func(subj string, ch chan *nats.Msg) (Unsubscriber, error)

+ type Codec interface

+ Decode func(data []byte, vPtr any) error

+ Encode func(v any) ([]byte, error)

+ type Connection interface

+ Drain func() error

+ func NATS(nc *nats.Conn) Connection

+ type Error struct

+ Cause error

+ Code int

+ Message string

+ func (e Error) Error() string

+ func (e Error) Unwrap() error

+ type Handler interface

+ Serve func(Publisher, Request) error

+ func ChainMiddleware(h Handler, mw ...Middleware) Handler

+ func ErrorHandlerMiddleware(next Handler) Handler

+ func RequestUIDMiddleware(next Handler) Handler

+ func Typed[ArgT, ResT any](c Codec, f TypedHandler[ArgT, ResT]) Handler

+ type HandlerFunc func(Publisher, Request) error

+ func (f HandlerFunc) Serve(pub Publisher, req Request) error

+ type JsonCodec struct

+ func (JsonCodec) Decode(data []byte, vPtr any) error

+ func (JsonCodec) Encode(v any) ([]byte, error)

+ type Middleware func(next Handler) Handler

+ func MakeAccessLogMiddleware(opts ...AccessLogMiddlewareOption) Middleware

+ func MakePublishSubjectMiddleware(subject string) Middleware

+ type ProtoCodec struct

+ func (ProtoCodec) Decode(data []byte, vPtr any) error

+ func (ProtoCodec) Encode(v any) ([]byte, error)

+ type ProtojsonCodec struct

+ func (ProtojsonCodec) Decode(data []byte, vPtr any) error

+ func (ProtojsonCodec) Encode(v any) ([]byte, error)

+ type PrototextCodec struct

+ func (PrototextCodec) Decode(data []byte, vPtr any) error

+ func (PrototextCodec) Encode(v any) ([]byte, error)

+ type Publisher interface

+ Header func() *nats.Header

+ Publish func(data []byte) error

+ Subject func() string

+ WithSubject func(subject string) Publisher

+ func NewPublisher(p PublisherMsg) Publisher

+ func NewPublisherWithSubject(p PublisherMsg, subject string) Publisher

+ type PublisherMsg interface

+ PublishMsg func(msg *nats.Msg) error

+ type Request interface

+ Context func() context.Context

+ Data func() []byte

+ Header func() nats.Header

+ Reply func() string

+ Subject func() string

+ type RequesterMsg interface

+ RequestMsg func(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)

+ type ServeMux struct

+ func (m *ServeMux) Handle(f Handler, subjects ...string) error

+ func (m *ServeMux) HandleFunc(f func(Publisher, Request) error, subjects ...string) error

+ func (m *ServeMux) Serve(pub Publisher, req Request) error

+ type Server struct

+ BaseContext context.Context

+ BufferSize int

+ Concurrency int

+ Conn Connection

+ Handler Handler

+ ListenSubjects []string

+ QueueName string

+ func (s *Server) Shutdown()

+ func (s *Server) Start() error

+ func (s *Server) Wait()

+ type Subscriber interface

+ QueueSubscribe func(subj, queue string) (Subscription, error)

+ Subscribe func(subj string) (Subscription, error)

+ type Subscription interface

+ NextMsg func(ctx context.Context) (*nats.Msg, error)

+ type TypedHandler interface

+ Serve func(TypedPublisher[ResT], TypedRequest[ArgT]) error

+ type TypedHandlerFunc func(TypedPublisher[ResT], TypedRequest[ArgT]) error

+ func (f TypedHandlerFunc[ArgT, ResT]) Serve(pub TypedPublisher[ResT], req TypedRequest[ArgT]) error

+ type TypedPublisher interface

+ Header func() *nats.Header

+ Publish func(*ResT) error

+ type TypedRequest interface

+ Context func() context.Context

+ Header func() nats.Header

+ Payload func() *T

+ type UIDGenerator interface

+ Next func() string

+ type Unsubscriber interface

+ Unsubscribe func() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL