gaffer_postgres (gaffer v0.4.1)
View SourcePure SQL query builder and serializer for Postgres drivers.
Summary
Functions
Query that fetches the currently applied migration versions.
Queries to create the migrations history table if it does not exist.
Query that fetches the full migrations history, oldest first.
Query that aggregates job counts and timestamps per state.
Query to atomically claim available jobs for execution.
Query to delete a job by ID.
Query to fetch a job by ID.
Query to list jobs matching the given filters.
Query to delete jobs older than per-state cutoffs for a queue.
Returns upsert queries for a single encoded job.
Queries to roll back a migration and record a down event.
Queries to apply a migration and record an up event.
Sorted list of all schema migrations as {Version, Up, Down} tuples.
Query to delete a queue by name.
Query to check whether a queue name exists.
Query to register a queue name. No-op if already registered.
Query to list all registered queue names.
Types
Functions
-spec applied_versions() -> queries().
Query that fetches the currently applied migration versions.
-spec ensure_migrations_table() -> queries().
Queries to create the migrations history table if it does not exist.
-spec history() -> queries().
Query that fetches the full migrations history, oldest first.
-spec info(gaffer:queue()) -> queries().
Query that aggregates job counts and timestamps per state.
Query to atomically claim available jobs for execution.
Query to delete a job by ID.
Query to fetch a job by ID.
Query to list jobs matching the given filters.
-spec job_prune(gaffer:queue(), map()) -> queries().
Query to delete jobs older than per-state cutoffs for a queue.
Returns upsert queries for a single encoded job.
-spec migrate_down({pos_integer(), _, queries()}) -> queries().
Queries to roll back a migration and record a down event.
-spec migrate_up({pos_integer(), queries(), _}) -> queries().
Queries to apply a migration and record an up event.
-spec migrations(Opts :: map()) -> [{Version :: pos_integer(), Up :: queries(), Down :: queries()}].
Sorted list of all schema migrations as {Version, Up, Down} tuples.
-spec queue_delete(gaffer:queue()) -> queries().
Query to delete a queue by name.
-spec queue_exists(gaffer:queue()) -> queries().
Query to check whether a queue name exists.
-spec queue_insert(gaffer:queue()) -> queries().
Query to register a queue name. No-op if already registered.
-spec queue_list() -> queries().
Query to list all registered queue names.