processing

package
v1.0.87 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2026 License: MIT Imports: 3 Imported by: 0

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

func DropMalformed(eventType string) error

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

func IsDropMalformed(err error) bool

IsDropMalformed reports whether err marks an event dropped for a malformed payload, letting the pipeline pick the right diagnostic without parsing error strings.

Types

type APIClient

type APIClient interface {
	CallAPI(ctx context.Context, method, path string, body any) (json.RawMessage, error)
}

APIClient is the narrow API surface handed to domain hooks. Identity stays opaque on purpose so business code cannot bypass the pre-flight checks.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL