Struct PostgresResultBackend 

pub struct PostgresResultBackend { /* private fields */ }

PostgreSQL-backed result storage.

Results are stored in the kojin_results table as JSONB with a configurable TTL (default 24 hours). Group state is tracked in kojin_groups.

Important: call migrate() before first use to create the required tables and indexes.

Implementations

impl PostgresResultBackend

pub fn new(pool: PgPool) -> Self

Create a new PostgreSQL result backend from an existing connection pool.

The default result TTL is 24 hours; override with with_ttl. You must call migrate() before storing results.

pub async fn connect(url: &str) -> TaskResult<Self>

Connect to PostgreSQL by URL and create the backend.

This is a convenience wrapper around PgPool::connect + new.

pub fn with_ttl(self, ttl: Duration) -> Self

Override the result TTL (time-to-live).

Expired results are not automatically deleted; they are filtered out at read time. Run periodic cleanup queries against kojin_results.expires_at if storage reclamation is needed. Defaults to 24 hours if not called.

pub async fn migrate(&self) -> TaskResult<()>

Run migrations to create the required tables (kojin_results, kojin_groups) and indexes. Safe to call multiple times — all statements use IF NOT EXISTS.

Trait Implementations

impl ResultBackend for PostgresResultBackend

fn store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 TaskId, result: &'life2 Value, ) -> Pin<Box<dyn Future<Output = TaskResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store a task result.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = TaskResult<Option<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a stored result.

fn wait<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, timeout: Duration, ) -> Pin<Box<dyn Future<Output = TaskResult<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Wait for a result to be available, with timeout.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 TaskId, ) -> Pin<Box<dyn Future<Output = TaskResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete a stored result.

fn init_group<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, total: u32, ) -> Pin<Box<dyn Future<Output = TaskResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Initialize a group with the expected total count.

fn complete_group_member<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, group_id: &'life1 str, task_id: &'life2 TaskId, result: &'life3 Value, ) -> Pin<Box<dyn Future<Output = TaskResult<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Mark a group member as complete and return the number of completed members.

fn get_group_results<'life0, 'life1, 'async_trait>( &'life0 self, group_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = TaskResult<Vec<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all results for a group.