peanats

type AccessLogMiddlewareOption func(*loggingPublisher)

type AccessLogger interface {
	Println(v ...any)
}

type ChanSubscriber interface {
	ChanSubscribe(subj string, ch chan *nats.Msg) (Unsubscriber, error)
	ChanQueueSubscribe(subj, queue string, ch chan *nats.Msg) (Unsubscriber, error)
}

type Codec interface {
	Encode(v any) ([]byte, error)
	Decode(data []byte, vPtr any) error
}

type Connection interface {
	PublisherMsg
	RequesterMsg
	Subscriber
	ChanSubscriber
	Drain() error
}

type Error struct {
	Code    int
	Message string
	Cause   error
}

type Handler interface {
	Serve(Publisher, Request) error
}

type HandlerFunc func(Publisher, Request) error

type JsonCodec struct{}

type Middleware func(next Handler) Handler

type ProtoCodec struct{}

type ProtojsonCodec struct{}

type PrototextCodec struct{}

type Publisher interface {
	PublisherMsg
	Subject() string
	WithSubject(subject string) Publisher
	Header() *nats.Header
	Publish(data []byte) error
}

type PublisherMsg interface {
	PublishMsg(msg *nats.Msg) error
}

type Request interface {
	Context() context.Context
	Subject() string
	Reply() string
	Header() nats.Header
	Data() []byte
}

type RequesterMsg interface {
	RequestMsg(ctx context.Context, msg *nats.Msg) (*nats.Msg, error)
}

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

type Server struct {
	Conn           Connection
	Handler        Handler
	BaseContext    context.Context
	Concurrency    int
	QueueName      string
	ListenSubjects []string
	// contains filtered or unexported fields
}

type Subscriber interface {
	Subscribe(subj string) (Subscription, error)
	QueueSubscribe(subj, queue string) (Subscription, error)
}

type Subscription interface {
	Unsubscriber
	NextMsg(ctx context.Context) (*nats.Msg, error)
}

type TypedHandler[ArgT, ResT any] interface {
	Serve(TypedPublisher[ResT], TypedRequest[ArgT]) error
}

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

type TypedPublisher[ResT any] interface {
	Header() *nats.Header
	Publish(*ResT) error
}

type TypedRequest[T any] interface {
	Context() context.Context
	Header() nats.Header
	Payload() *T
}

type UIDGenerator interface {
	Next() string
}

type Unsubscriber interface {
	Unsubscribe() error
}