common

Documentation

Index

• func AddNATSPublishVarsToReplacer(repl *caddy.Replacer, req *http.Request)
• func AddNatsSubscribeVarsToReplacer(repl *caddy.Replacer, msg *nats.Msg)
• func NatsMsgForHttpRequest(r *http.Request, subject string) (*nats.Msg, error)
• type ExtraNatsMsgHeaders
  • func ExtraNatsMsgHeadersFromContext(ctx context.Context) ExtraNatsMsgHeaders
  • func (h ExtraNatsMsgHeaders) StoreInCtx(ctx context.Context) context.Context
• type NatsHandler
• type NoopResponseWriter
  • func (n NoopResponseWriter) Header() http.Header
  • func (NoopResponseWriter) Write(p []byte) (int, error)
  • func (NoopResponseWriter) WriteHeader(statusCode int)

Functions

func AddNATSPublishVarsToReplacer

func AddNATSPublishVarsToReplacer(repl *caddy.Replacer, req *http.Request)

func AddNatsSubscribeVarsToReplacer

func AddNatsSubscribeVarsToReplacer(repl *caddy.Replacer, msg *nats.Msg)

func NatsMsgForHttpRequest

func NatsMsgForHttpRequest(r *http.Request, subject string) (*nats.Msg, error)

NatsMsgForHttpRequest creates a nats.Msg from an existing http.Request: the HTTP Request Body is transferred to the NATS message Data, and the headers are transferred as well.

Three special headers are added for the request method, URL path, and raw query.

Types

type ExtraNatsMsgHeaders

type ExtraNatsMsgHeaders map[string]string

func ExtraNatsMsgHeadersFromContext

func ExtraNatsMsgHeadersFromContext(ctx context.Context) ExtraNatsMsgHeaders

func (ExtraNatsMsgHeaders) StoreInCtx

func (h ExtraNatsMsgHeaders) StoreInCtx(ctx context.Context) context.Context

type NatsHandler

type NatsHandler interface {
	Subscribe(conn *nats.Conn) error
	Unsubscribe(conn *nats.Conn) error
}

type NoopResponseWriter

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

func (NoopResponseWriter) Header

func (n NoopResponseWriter) Header() http.Header

func (NoopResponseWriter) Write

func (NoopResponseWriter) Write(p []byte) (int, error)

func (NoopResponseWriter) WriteHeader

func (NoopResponseWriter) WriteHeader(statusCode int)