Struct SignalReceivedEvent 

pub struct SignalReceivedEvent {
    pub signal_id: Uuid,
    pub name: String,
    pub key: String,
    pub resumed_runs: Vec<Uuid>,
    pub at: DateTime<Utc>,
}

Payload of the Event::SignalReceived event.

Emitted once per stored signal; a duplicate (same idempotency ID) emits nothing.

Examples

use chrono::Utc;
use ironflow_engine::notify::SignalReceivedEvent;
use uuid::Uuid;

let payload = SignalReceivedEvent {
    signal_id: Uuid::now_v7(),
    name: "ci.pipeline_finished".to_string(),
    key: "4f2a9c1".to_string(),
    resumed_runs: vec![Uuid::now_v7()],
    at: Utc::now(),
};
assert_eq!(payload.resumed_runs.len(), 1);

Fields

signal_id: Uuid

Stored signal identifier.

name: String

Signal name.

key: String

Occurrence key.

resumed_runs: Vec<Uuid>

Runs whose waiting step the signal resolved.

at: DateTime<Utc>

When the signal was received.

Trait Implementations

impl Clone for SignalReceivedEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SignalReceivedEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SignalReceivedEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SignalReceivedEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.