Struct PollingTriggerConfig 

pub struct PollingTriggerConfig {
    pub interval: Duration,
    pub probe: Box<dyn PollingProbe>,
    pub workflow_name: String,
    pub dedup: bool,
}

Configuration for a PollingTrigger.

Examples

use std::time::Duration;
use ironflow_runtime::trigger::polling::{
    PollingTriggerConfig, PollingProbe, ProbeFuture, ProbeResult,
};

struct Stub;
impl PollingProbe for Stub {
    fn name(&self) -> &str { "stub" }
    fn poll(&self) -> ProbeFuture<'_> {
        Box::pin(async { Ok(Some(ProbeResult::new(serde_json::json!(null)))) })
    }
}

let config = PollingTriggerConfig {
    interval: Duration::from_secs(60),
    probe: Box::new(Stub),
    workflow_name: "my-workflow".to_string(),
    dedup: true,
};

Fields

interval: Duration

How often to poll.

probe: Box<dyn PollingProbe>

The probe to execute.

workflow_name: String

The workflow to trigger when the probe detects new data.

dedup: bool

When true, skip triggering if the probe result hash matches the previous one.