Struct TriggerBinding 

pub struct TriggerBinding {
    pub id: String,
    pub revision: u64,
    pub source: String,
    pub event_type: String,
    pub instance_id: InstanceId,
    pub predicate: Value,
    pub ordering: OrderingPolicy,
    pub starts_at: Option<DateTime<Utc>>,
    pub expires_at: Option<DateTime<Utc>>,
    pub gap_wait_ms: u64,
    pub gap_limit: u32,
}

Subscription of an instance to a source event type, with a JSON-containment predicate.

Fields

id: String

Stable identifier of this record.

revision: u64

Monotonic revision number.

source: String

Source the binding subscribes to.

event_type: String

Stable machine-readable event type.

instance_id: InstanceId

Workflow instance this record refers to.

predicate: Value

JSON object the event payload must contain (@>) to create a delivery.

ordering: OrderingPolicy

How out-of-order source sequences are handled.

starts_at: Option<DateTime<Utc>>

Earliest time the binding or instance is active.

expires_at: Option<DateTime<Utc>>

When the record stops being valid.

gap_wait_ms: u64

How long a missing source sequence may block before it is reported as a gap.

gap_limit: u32

Maximum buffered out-of-order deliveries before the source is blocked.

Implementations

impl TriggerBinding

pub fn validate(&self) -> Result<(), ContractError>

Reject blank identifiers, out-of-range gap settings and inverted windows.

Trait Implementations

impl Clone for TriggerBinding

fn clone(&self) -> TriggerBinding

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TriggerBinding

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TriggerBinding

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TriggerBinding

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for TriggerBinding

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TriggerBinding