Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DetermineIdempotencyKey ¶
DetermineIdempotencyKey returns a deterministic key for deduplication. Precedence: 1) metadata[idempotency_key] 2) message ID 3) empty string if none available (caller may decide behavior)
func EnsureIdempotencyID ¶
EnsureIdempotencyID ensures the message has a stable ID set for sinks that use the message ID as the natural idempotency key (e.g., SQL primary key, etc.). If no ID or idempotency key is present, it generates a UUID as a defensive backstop to ensure the message is traceable and uniquely identifiable. Returns the key and whether it was set on the message.
func IdempotencyRequired ¶
func IdempotencyRequired() bool
IdempotencyRequired returns true if idempotency must be enforced (and missing keys should be reported). Controlled via HERMOD_IDEMPOTENCY_REQUIRED.
Types ¶
This section is empty.
Source Files