Struct PollingTrigger 

pub struct PollingTrigger { /* private fields */ }

A trigger that periodically polls an external source.

See the module-level documentation for usage examples.

Examples

use std::time::Duration;
use ironflow_runtime::trigger::polling::{
    PollingTrigger, 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 trigger = PollingTrigger::new(PollingTriggerConfig {
    interval: Duration::from_secs(30),
    probe: Box::new(Stub),
    workflow_name: "ingest".to_string(),
    dedup: false,
});

Implementations

impl PollingTrigger

pub fn new(config: PollingTriggerConfig) -> Self

Create a new polling trigger.

Examples

use std::time::Duration;
use ironflow_runtime::trigger::polling::{
    PollingTrigger, 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 trigger = PollingTrigger::new(PollingTriggerConfig {
    interval: Duration::from_secs(10),
    probe: Box::new(Stub),
    workflow_name: "check".to_string(),
    dedup: true,
});

Trait Implementations

impl Trigger for PollingTrigger

fn name(&self) -> &str

Human-readable name for logging.

fn start<'a>( &'a self, sink: TriggerSink, token: &'a CancellationToken, ) -> TriggerFuture<'a>

Start the trigger.