apiworker

Documentation

Index

• func NewRequestFromMessage(msg *nats.Msg, subscribePath, handlerPath string) (*http.Request, error)
• func NewStdResponseWriter(w io.Writer) *stdResponseWriter
• type Option
  • 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
  • func NewWorker(ctx context.Context, serverURL string, routes []apiserv.Route, ...) (Worker, error)

Functions

func NewRequestFromMessage

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

func NewStdResponseWriter

func NewStdResponseWriter(w io.Writer) *stdResponseWriter

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithContextName

func WithContextName(contextName string) Option

func WithCreds

func WithCreds(creds string) Option

func WithMetricsAddress

func WithMetricsAddress(address string) Option

func WithNKey

func WithNKey(nkey string) Option

func WithPassword

func WithPassword(password string) Option

func WithTLSCA

func WithTLSCA(tlsca string) Option

func WithTLSCert

func WithTLSCert(tlscert string) Option

func WithTLSKey

func WithTLSKey(tlskey string) Option

func WithURL

func WithURL(url string) Option

func WithUser

func WithUser(user string) Option

type Worker

type Worker interface {
	ListenAndServe(ctx context.Context) error
	Shutdown(ctx context.Context) error
}

func NewWorker

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