Struct DefaultRunnerConfigBuilder 

pub struct DefaultRunnerConfigBuilder { /* private fields */ }

Builder for DefaultRunnerConfig.

Use this builder to create a customized configuration:

let config = DefaultRunnerConfig::builder()
    .max_concurrent_tasks(8)
    .enable_cron_scheduling(false)
    .build();

Implementations

impl DefaultRunnerConfigBuilder

pub fn max_concurrent_tasks(self, value: usize) -> Self

Sets the maximum number of concurrent task executions.

pub fn scheduler_poll_interval(self, value: Duration) -> Self

Sets the scheduler poll interval.

pub fn task_timeout(self, value: Duration) -> Self

Sets the task timeout.

pub fn workflow_timeout(self, value: Option<Duration>) -> Self

Sets the workflow timeout.

pub fn db_pool_size(self, value: u32) -> Self

Sets the database pool size.

pub fn enable_recovery(self, value: bool) -> Self

Enables or disables automatic recovery.

pub fn enable_cron_scheduling(self, value: bool) -> Self

Enables or disables cron scheduling.

pub fn cron_poll_interval(self, value: Duration) -> Self

Sets the cron poll interval.

pub fn cron_max_catchup_executions(self, value: usize) -> Self

Sets the maximum catchup executions for cron.

pub fn cron_enable_recovery(self, value: bool) -> Self

Enables or disables cron recovery.

pub fn cron_recovery_interval(self, value: Duration) -> Self

Sets the cron recovery interval.

pub fn cron_lost_threshold_minutes(self, value: i32) -> Self

Sets the cron lost threshold in minutes.

pub fn cron_max_recovery_age(self, value: Duration) -> Self

Sets the maximum cron recovery age.

pub fn cron_max_recovery_attempts(self, value: usize) -> Self

Sets the maximum cron recovery attempts.

pub fn enable_trigger_scheduling(self, value: bool) -> Self

Enables or disables trigger scheduling.

pub fn trigger_base_poll_interval(self, value: Duration) -> Self

Sets the trigger base poll interval.

pub fn trigger_poll_timeout(self, value: Duration) -> Self

Sets the trigger poll timeout.

pub fn enable_registry_reconciler(self, value: bool) -> Self

Enables or disables the registry reconciler.

pub fn registry_reconcile_interval(self, value: Duration) -> Self

Sets the registry reconcile interval.

pub fn registry_enable_startup_reconciliation(self, value: bool) -> Self

Enables or disables startup reconciliation.

pub fn registry_storage_path(self, value: Option<PathBuf>) -> Self

Sets the registry storage path.

pub fn registry_storage_backend(self, value: impl Into<String>) -> Self

Sets the registry storage backend.

pub fn runner_id(self, value: Option<String>) -> Self

Sets the runner identifier.

pub fn runner_name(self, value: Option<String>) -> Self

Sets the runner name.

pub fn routing_config(self, value: Option<RoutingConfig>) -> Self

Sets the routing configuration.

pub fn enable_claiming(self, value: bool) -> Self

Enables or disables task claiming for horizontal scaling.

pub fn heartbeat_interval(self, value: Duration) -> Self

Sets the heartbeat interval for claimed tasks.

pub fn build(self) -> Result<DefaultRunnerConfig, ConfigError>

Builds and validates the configuration.

Returns an error if any configuration value is out of bounds.

Trait Implementations

impl Clone for DefaultRunnerConfigBuilder

fn clone(&self) -> DefaultRunnerConfigBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultRunnerConfigBuilder

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

Formats the value using the given formatter.

impl Default for DefaultRunnerConfigBuilder

fn default() -> Self

Returns the “default value” for a type.