Struct TaskTables

pub struct TaskTables { /* private fields */ }

TaskTables is used for creating the necessary tables/views/functions in a postgres database. It implements TaskTableProvider and can be passed to crate::Task and crate::Worker that use it for finding out what postgres entities to use.

Use TaskTableBuilder to create it or use TaskTables::default() if you are OK with default set of postgres entities.

That default will create:

• table public.tasks
• view public.tasks_ready
• function public.notify
• function public.notify_done

Implementations

impl TaskTables

pub async fn exists(&self, pool: &Pool<Postgres>) -> Result<bool>

Check if the necessary postgres entities have been installed already.

pub async fn create(&self, pool: &Pool<Postgres>) -> Result<()>

Create the necessary postgres entities for the task queue in the connected postgres database. This function is idempotent and it will not error if the entities already exist.

pub async fn drop(self, pool: &Pool<Postgres>) -> Result<()>

Delete all postgres entities used by the task queue. This function is idempotent and will not error if the entities don’t exist.

Trait Implementations

impl Clone for TaskTables

fn clone(&self) -> TaskTables

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TaskTables

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TaskTables

fn default() -> Self

Returns the “default value” for a type.

impl TaskTableProvider for TaskTables

fn schema_name(&self) -> &str

fn tasks_table(&self) -> &str

fn tasks_ready_view(&self) -> &str

fn tasks_notify_fn(&self) -> &str

fn tasks_notify_done_fn(&self) -> &str

fn tasks_queue_name(&self) -> &str

fn tasks_queue_done_name(&self) -> String

fn tasks_table_full_name(&self) -> String

fn tasks_ready_view_full_name(&self) -> String

fn tasks_notify_fn_full_name(&self) -> String

fn tasks_notify_done_fn_full_name(&self) -> String