Struct JobBuilder 

pub struct JobBuilder<P> { /* private fields */ }

Fluent builder for a scheduled Job.

Requires Self::name before Self::build. Identity is optional via Self::with_actor_json (default remains Job::new’s Null).

Errors

Fallible setters and Self::build return ChrononError variants documented on each method. Error messages must not embed full actor_json or params_json payloads.

Implementations

impl<P> JobBuilder<P>

where P: Serialize,

pub fn new(handle: &ScriptHandle<P>) -> JobBuilder<P>

Create a new job builder for the given script handle.

pub fn name(self, name: impl Into<String>) -> JobBuilder<P>

Set the job name (unique per deployment).

pub fn with_actor_json(self, actor_json: Value) -> JobBuilder<P>

Set opaque identity JSON persisted on Job::actor_json.

Use an identity snapshot only — do not store secrets. Unified Field hosts with Valence should prefer L1 chronon_coordinator::JobBuilder::with_valence instead.

pub fn cron(self, expr: &str) -> Result<JobBuilder<P>, ChrononError>

Set the cron schedule.

Errors

Returns ChrononError::InvalidCron when expr is not a valid cron expression.

pub fn timezone(self, tz: impl Into<String>) -> JobBuilder<P>

Set the timezone for cron evaluation.

pub const fn run_once_at(self, at: DateTime<Utc>) -> JobBuilder<P>

Schedule a one-time execution at the specified time.

pub const fn manual(self) -> JobBuilder<P>

Set the job to manual-only (no automatic scheduling).

pub fn params(self, params: P) -> JobBuilder<P>

Set the script parameters.

pub fn pool(self, pool: impl Into<String>) -> JobBuilder<P>

Set the execution pool (for distributed mode).

pub fn region(self, region: impl Into<String>) -> JobBuilder<P>

Set the target region (for distributed mode).

pub const fn concurrency(self, max: i32) -> JobBuilder<P>

Set maximum concurrent runs.

pub const fn timeout_ms(self, ms: i64) -> JobBuilder<P>

Set execution timeout in milliseconds.

pub const fn retry_policy(self, policy: RetryPolicy) -> JobBuilder<P>

Set the retry policy for failed runs.

pub const fn misfire_policy(self, policy: MisfirePolicy) -> JobBuilder<P>

Set the misfire policy for missed runs.

pub const fn disabled(self) -> JobBuilder<P>

Disable the job (it won’t run until enabled).

pub fn build(self) -> Result<Job, ChrononError>

Build the final Job payload.

Errors

• ChrononError::ParamError when Self::name was not set
• ChrononError::InvalidCron / ChrononError::InvalidTimezone when cron fields are invalid
• ChrononError::ParamError when params fail to serialize