DripDrop.Ingest.Correlation (DripDrop v0.1.0)

Copy Markdown View Source

Shared message-event correlation queries.

Summary

Functions

by_out_message_id(normalized, ids)

Finds a step execution by RFC outbound Message-ID candidates.

by_provider_message_id(normalized)

Finds a step execution by provider-specific message id.

Functions

by_out_message_id(normalized, ids)

@spec by_out_message_id(map(), [binary()]) :: Ecto.Schema.t() | nil

Finds a step execution by RFC outbound Message-ID candidates.

by_provider_message_id(normalized)

@spec by_provider_message_id(map()) :: Ecto.Schema.t() | nil

Finds a step execution by provider-specific message id.