Struct RedisQueueLayer 

pub struct RedisQueueLayer { /* private fields */ }

Redis ZSET layer for queued runs ({prefix}:ready:{pool} or hash-tagged for cluster).

Used only as the claim hot path inside crate::PostgresRedisSchedulerStore — not a standalone SchedulerStore. Connect with Self::connect:

Knob	Effect
url / CHRONON_REDIS_URL	Standalone Redis
CHRONON_REDIS_CLUSTER_URLS	Comma-separated cluster nodes
CHRONON_REDIS_HASH_TAGS=1	Hash-tagged pool keys for slot affinity
key_prefix (default chronon)	Key namespace

Examples

use chronon_backend_redis::RedisQueueLayer;

let redis = RedisQueueLayer::connect("redis://127.0.0.1:6379", Some("myapp")).await?;

Implementations

impl RedisQueueLayer

pub async fn connect( url: &str, key_prefix: Option<&str>, ) -> Result<RedisQueueLayer, ChrononError>

Connect to Redis at url with optional key prefix (default chronon).

When CHRONON_REDIS_CLUSTER_URLS is set (comma-separated), uses Redis Cluster. When CHRONON_REDIS_HASH_TAGS=1, pool keys use hash tags for cluster slot affinity.

Errors

Returns a storage error when the connection cannot be established.

pub fn test_url() -> String

Redis URL for tests (CHRONON_TEST_REDIS_URL, then CHRONON_REDIS_URL, or local default).

pub async fn enqueue_run( &self, pool_id: &str, run_id: &str, scheduled_for: DateTime<Utc>, ) -> Result<(), ChrononError>

Enqueue a run id ordered by scheduled_for (ZADD score = epoch millis).

Errors

Returns a storage error when Redis commands fail.

pub async fn claim_next_run_id( &self, pool_id: &str, now: DateTime<Utc>, ) -> Result<Option<String>, ChrononError>

Atomically pop the earliest due run id (score <= now) from the pool queue.

Errors

Returns a storage error when Redis commands fail.

pub async fn claim_next_run_ids( &self, pool_id: &str, count: usize, now: DateTime<Utc>, ) -> Result<Vec<String>, ChrononError>

Pop up to count earliest due run ids (scheduled_for score ≤ now).

Errors

Returns a storage error when Redis commands fail.

pub async fn remove_run( &self, pool_id: &str, run_id: &str, ) -> Result<(), ChrononError>

Remove a run from the ready queue (e.g. after cancellation).

Errors

Returns a storage error when Redis commands fail.

pub async fn flush_keys(&self) -> Result<(), ChrononError>

Delete all keys with this layer’s prefix (test isolation).

Errors

Returns a storage error when Redis commands fail.

Trait Implementations

impl Debug for RedisQueueLayer

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

Formats the value using the given formatter.