Struct TaskTtlConfig 

pub struct TaskTtlConfig { /* private fields */ }

Per-task-type TTL configuration for result expiration

Allows setting different TTLs for different task types, with a fallback to a default TTL when no per-task override is configured.

Example

use celers_backend_redis::TaskTtlConfig;
use std::time::Duration;

let mut config = TaskTtlConfig::with_default(Duration::from_secs(3600));
config.set_task_ttl("long_running_task", Duration::from_secs(86400));
config.set_task_ttl("ephemeral_task", Duration::from_secs(60));

assert_eq!(config.get_ttl("long_running_task"), Some(Duration::from_secs(86400)));
assert_eq!(config.get_ttl("unknown_task"), Some(Duration::from_secs(3600)));

Implementations

impl TaskTtlConfig

pub fn new() -> TaskTtlConfig

Create a new empty TTL configuration (no default, no per-task overrides)

pub fn with_default(ttl: Duration) -> TaskTtlConfig

Create a TTL configuration with a default TTL for all tasks

pub fn set_task_ttl(&mut self, task_name: &str, ttl: Duration)

Set a per-task-type TTL override

pub fn get_ttl(&self, task_name: &str) -> Option<Duration>

Get the TTL for a specific task type

Returns the per-task TTL if one is set, otherwise falls back to the default TTL. Returns None if neither is configured.

pub fn is_empty(&self) -> bool

Check if this configuration has any TTLs configured

pub fn default_ttl(&self) -> Option<Duration>

Get the default TTL

pub fn set_default_ttl(&mut self, ttl: Duration)

Set the default TTL

pub fn remove_task_ttl(&mut self, task_name: &str) -> Option<Duration>

Remove the per-task TTL override for a specific task type

pub fn task_ttl_count(&self) -> usize

Get the number of per-task TTL overrides

Trait Implementations

impl Clone for TaskTtlConfig

fn clone(&self) -> TaskTtlConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskTtlConfig

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

Formats the value using the given formatter.

impl Default for TaskTtlConfig

fn default() -> TaskTtlConfig

Returns the “default value” for a type.