# `DripDrop.Ingest.Correlation`
[🔗](https://github.com/agoodway/dripdrop/blob/v0.1.0/lib/dripdrop/ingest/correlation.ex#L1)

Shared message-event correlation queries.

# `by_out_message_id`

```elixir
@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`

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

Finds a step execution by provider-specific message id.

---

*Consult [api-reference.md](api-reference.md) for complete listing*