Documentation
¶
Overview ¶
Package processing defines how a domain processor's outcome is interpreted by the consume pipeline: emit exactly what the key's schema declares, or drop with a stated reason — never leak an undeclared shape to stdout.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DropMalformed ¶
DropMalformed signals that the payload could not be decoded into the shape this EventKey declares. The event is dropped instead of passing the raw envelope through to stdout, which would violate the declared output schema.
func IsDropMalformed ¶
IsDropMalformed reports whether err marks an event dropped for a malformed payload, letting the pipeline pick the right diagnostic without parsing error strings.
Types ¶
Click to show internal directories.
Click to hide internal directories.