ingestdriver

Documentation

Index

• func NewIngestEventsHandler(op operation.Operation[ingest.IngestEventsRequest, bool], ...) httptransport.Handler[ingest.IngestEventsRequest, bool]
• type ErrorInvalidContentType
  • func (e ErrorInvalidContentType) Details() map[string]any
  • func (e ErrorInvalidContentType) Error() string
  • func (e ErrorInvalidContentType) Message() string
• type ErrorInvalidEvent
  • func (e ErrorInvalidEvent) Error() string
  • func (e ErrorInvalidEvent) Message() string

Functions

func NewIngestEventsHandler

func NewIngestEventsHandler(
	op operation.Operation[ingest.IngestEventsRequest, bool],
	namespaceDecoder namespacedriver.NamespaceDecoder,
	commonErrorEncoder httptransport.ErrorEncoder,
	errorHandler httptransport.ErrorHandler,
) httptransport.Handler[ingest.IngestEventsRequest, bool]

NewIngestEventsHandler returns a new HTTP handler that wraps the given operation.Operation.

Types

type ErrorInvalidContentType

type ErrorInvalidContentType struct {
	ContentType string
}

func (ErrorInvalidContentType) Details

func (e ErrorInvalidContentType) Details() map[string]any

func (ErrorInvalidContentType) Error

func (e ErrorInvalidContentType) Error() string

func (ErrorInvalidContentType) Message

func (e ErrorInvalidContentType) Message() string

type ErrorInvalidEvent

type ErrorInvalidEvent struct {
	Err error
}

func (ErrorInvalidEvent) Error

func (e ErrorInvalidEvent) Error() string

func (ErrorInvalidEvent) Message

func (e ErrorInvalidEvent) Message() string