ingestdriver

Documentation

Index

• func NewIngestEventsHandler(op operation.Operation[ingest.IngestEventsRequest, bool], ...) http.Handler
• 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
• type NamespaceDecoder
• type StaticNamespaceDecoder
  • func (d StaticNamespaceDecoder) GetNamespace(ctx context.Context) (string, bool)

Functions

func NewIngestEventsHandler

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

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

type NamespaceDecoder

type NamespaceDecoder interface {
	GetNamespace(ctx context.Context) (string, bool)
}

NamespaceDecoder gets the namespace from the request.

type StaticNamespaceDecoder

type StaticNamespaceDecoder string

func (StaticNamespaceDecoder) GetNamespace

func (d StaticNamespaceDecoder) GetNamespace(ctx context.Context) (string, bool)