Struct TriggerSink 

pub struct TriggerSink { /* private fields */ }

Channel endpoint for triggers to emit TriggerEvents.

Obtained from TriggerSink::channel and passed to Trigger::start.

Examples

use ironflow_runtime::trigger::{TriggerSink, TriggerEvent};
use ironflow_store::entities::TriggerKind;
use serde_json::json;

let (sink, mut rx) = TriggerSink::channel(16);

sink.send(TriggerEvent {
    workflow_name: "deploy".to_string(),
    payload: json!({}),
    trigger_kind: TriggerKind::Manual,
}).await.unwrap();

let event = rx.recv().await.unwrap();
assert_eq!(event.workflow_name, "deploy");

Implementations

impl TriggerSink

pub fn channel(buffer: usize) -> (Self, Receiver<TriggerEvent>)

Create a sink/receiver pair with the given buffer capacity.

Examples

use ironflow_runtime::trigger::TriggerSink;

let (sink, rx) = TriggerSink::channel(32);
drop(rx);

pub async fn send(&self, event: TriggerEvent) -> Result<(), TriggerError>

Send a trigger event.

Errors

Returns an error if the receiver has been dropped.

Trait Implementations

impl Clone for TriggerSink

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.