Module worker

Source
Expand description

Redis/Apalis worker initialization.

This module contains all Apalis-specific worker creation logic for the Redis queue backend, including WorkerBuilder configurations, Monitor setup, backoff strategies, and token swap cron workers.

Structs§

HasherRng
Re-exports from [tower::util] A [Rng] implementation that uses a Hasher to generate the random values. The implementation uses an internal counter to pass to the hasher for each iteration of [Rng::next_u64].

Functions§

initialize_redis_token_swap_workers
Initializes swap workers for Solana and Stellar relayers. This function creates and registers workers for relayers that have swap enabled and cron schedule set.
initialize_redis_workers
Initializes Redis/Apalis workers and starts the lifecycle monitor.