MnemosyneEcto.Queries.IngestionQueries (mnemosyne_ecto v0.2.0)

Ecto query builders for durable source ingestion records.

Summary

Filters ingestion records by tenant, repository, and source.

source(map)

Returns the {table_name, schema} source tuple for ingestion records.

@spec for_source(map(), String.t()) :: Ecto.Query.t()

Filters ingestion records by tenant, repository, and source.

@spec source(map()) :: {String.t(), module()}

Returns the {table_name, schema} source tuple for ingestion records.