pub struct ResumeSignal {
pub signal_id: SignalId,
pub signal_name: String,
pub signal_category: String,
pub source_type: String,
pub source_identity: String,
pub correlation_id: String,
pub accepted_at: TimestampMs,
pub payload: Option<Vec<u8>>,
}Expand description
A signal that triggered a resume, readable by a worker after re-claim.
Returned by ClaimedTask::resume_signals when a suspended execution
is resumed because one or more matched signals satisfied its waitpoint’s
resume condition. The worker can then inspect signal_name to branch
behavior (approve / reject / etc.) and use payload for richer decision
data instead of inferring intent from stream frames.
Returned only for signals whose matcher slot in the waitpoint’s resume condition is marked satisfied. Pre-buffered-but-unmatched signals are not included.
Fields§
§signal_id: SignalId§signal_name: String§signal_category: String§source_type: String§source_identity: String§correlation_id: String§accepted_at: TimestampMsValkey-server now_ms timestamp at which ff_deliver_signal
accepted this signal. 0 if the stored accepted_at field is
missing or non-numeric (a Lua-side defect — not expected at
runtime).
payload: Option<Vec<u8>>Raw payload bytes, if the signal was delivered with one. None
for signals delivered without a payload. Note: the SDK’s current
signal-delivery path (FlowFabricWorker::deliver_signal) writes
payloads as UTF-8 (lossy) with payload_encoding="json"; callers
that invoke ff_deliver_signal directly via FCALL with non-UTF-8
bytes will receive those bytes verbatim here.
Trait Implementations§
Source§impl Clone for ResumeSignal
impl Clone for ResumeSignal
Source§fn clone(&self) -> ResumeSignal
fn clone(&self) -> ResumeSignal
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for ResumeSignal
impl Debug for ResumeSignal
Source§impl PartialEq for ResumeSignal
impl PartialEq for ResumeSignal
impl Eq for ResumeSignal
impl StructuralPartialEq for ResumeSignal
Auto Trait Implementations§
impl Freeze for ResumeSignal
impl RefUnwindSafe for ResumeSignal
impl Send for ResumeSignal
impl Sync for ResumeSignal
impl Unpin for ResumeSignal
impl UnsafeUnpin for ResumeSignal
impl UnwindSafe for ResumeSignal
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more