natsworker

Apr 21, 2024

Changes in this version

+ func NewRequestFromMessage(msg *nats.Msg, subscribePath, handlerPath string) (*http.Request, error)

+ func NewStdResponseWriter(w io.Writer) *stdResponseWriter

+ type Option interface

+ func WithContextName(contextName string) Option

+ func WithCreds(creds string) Option

+ func WithMetricsAddress(address string) Option

+ func WithNKey(nkey string) Option

+ func WithPassword(password string) Option

+ func WithTLSCA(tlsca string) Option

+ func WithTLSCert(tlscert string) Option

+ func WithTLSKey(tlskey string) Option

+ func WithURL(url string) Option

+ func WithUser(user string) Option

+ type Worker interface

+ ListenAndServe func(ctx context.Context) error

+ Shutdown func(ctx context.Context) error

+ func NewWorker(ctx context.Context, serverURL string, routes []apiserv.Route, ...) (Worker, error)