Struct WakeCondition 

pub struct WakeCondition {
    pub condition_id: WakeConditionId,
    pub run_id: RunId,
    pub filter: EventFilter,
    pub timeout_millis: Option<u64>,
    pub resume_with: ResumeInputPolicy,
    pub idempotency_key: IdempotencyKey,
    pub policy_refs: Vec<PolicyRef>,
}

Holds wake condition application-layer state or configuration. Use it with the documented coordinator methods; run, journal, event, provider, or port effects are called out on those methods rather than on construction.

Fields

condition_id: WakeConditionId

Stable condition id used for typed lineage, lookup, or dedupe.

run_id: RunId

Run identifier used for lineage, filtering, replay, and dedupe.

filter: EventFilter

Filter used by this record or request.

timeout_millis: Option<u64>

Time value in milliseconds for timeout millis. Use it for timeout, ordering, or diagnostic calculations.

resume_with: ResumeInputPolicy

Resume with used by this record or request.

idempotency_key: IdempotencyKey

Idempotency setting or key for deduping retries. Use it to prevent duplicate side effects during replay or repair.

policy_refs: Vec<PolicyRef>

Policy references that govern admission, projection, execution, or delivery.

Implementations

impl WakeCondition

pub fn new( condition_id: WakeConditionId, run_id: RunId, filter: EventFilter, idempotency_key: IdempotencyKey, ) -> Self

Creates a new application::agent_pool value with explicit caller-provided inputs. This constructor is data-only and performs no I/O or external side effects.

pub fn timeout_millis(self, timeout_millis: u64) -> Self

Returns an updated value with timeout millis configured. This updates the wake timeout on the condition value and performs no scheduling by itself.

pub fn policy_ref(self, policy_ref: PolicyRef) -> Self

Returns an updated value with policy ref configured. This sets the policy reference on the coordination value and performs no I/O.

pub fn compile_envelope_filter(&self) -> Result<CompiledEventFilter, AgentError>

Computes or returns compile envelope filter for the application::agent_pool contract without external I/O or side effects.

Trait Implementations

impl Clone for WakeCondition

fn clone(&self) -> WakeCondition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WakeCondition

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WakeCondition

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WakeCondition

fn eq(&self, other: &WakeCondition) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WakeCondition

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for WakeCondition

impl StructuralPartialEq for WakeCondition