httpingest

Documentation

Index

• type Handler
  • func NewHandler(config HandlerConfig) (*Handler, error)
  • func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request, namespace string)
• type HandlerConfig

Types

type Handler

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

Handler receives an event in CloudEvents format and forwards it to a {Collector}.

func NewHandler

func NewHandler(config HandlerConfig) (*Handler, error)

func (Handler) ServeHTTP

func (h Handler) ServeHTTP(w http.ResponseWriter, r *http.Request, namespace string)

type HandlerConfig

type HandlerConfig struct {
	Collector        ingest.Collector
	NamespaceManager *namespace.Manager
	Logger           *slog.Logger
	ErrorHandler     errorsx.Handler
}