Struct CronContext 

pub struct CronContext {
    pub run_id: Uuid,
    pub cron_name: String,
    pub scheduled_time: DateTime<Utc>,
    pub execution_time: DateTime<Utc>,
    pub timezone: String,
    pub is_catch_up: bool,
    pub auth: AuthContext,
    pub log: CronLog,
    /* private fields */
}

Context available to cron handlers.

Fields

run_id: Uuid

Cron run ID.

cron_name: String

Cron name.

scheduled_time: DateTime<Utc>

Scheduled time (when the cron was supposed to run).

execution_time: DateTime<Utc>

Actual execution time.

timezone: String

Timezone of the cron.

is_catch_up: bool

Whether this is a catch-up run.

auth: AuthContext

Authentication context.

log: CronLog

Structured logger.

Implementations

impl CronContext

pub fn new( run_id: Uuid, cron_name: String, scheduled_time: DateTime<Utc>, timezone: String, is_catch_up: bool, db_pool: PgPool, http_client: Client, ) -> Self

Create a new cron context.

pub fn with_env_provider(self, provider: Arc<dyn EnvProvider>) -> Self

Set environment provider.

pub fn db(&self) -> &PgPool

Get the database pool.

pub fn http(&self) -> &Client

Get the HTTP client.

pub fn delay(&self) -> Duration

Get the delay between scheduled and actual execution time.

pub fn is_late(&self) -> bool

Check if the cron is running late (more than 1 minute delay).

pub fn with_auth(self, auth: AuthContext) -> Self

Set authentication context.

Trait Implementations

impl EnvAccess for CronContext

fn env_provider(&self) -> &dyn EnvProvider

Get the environment provider.

fn env(&self, key: &str) -> Option<String>

Get an environment variable.

fn env_or(&self, key: &str, default: &str) -> String

Get an environment variable with a default value.

fn env_require(&self, key: &str) -> Result<String>

Get a required environment variable.

fn env_parse<T: FromStr>(&self, key: &str) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it to the specified type.

fn env_parse_or<T: FromStr>(&self, key: &str, default: T) -> Result<T>

where T::Err: Display,

Get an environment variable and parse it, with a default.

fn env_contains(&self, key: &str) -> bool

Check if an environment variable is set.