Struct TMinusEvent 

pub struct TMinusEvent {
    pub id: Uuid,
    pub kind: EventKind,
    pub scheduled_at: DateTime<Utc>,
    pub t_minus: Duration,
    pub organizer: AgentId,
    pub attendees: Vec<(AgentId, ResponseStatus)>,
    pub quorum: usize,
    pub payload: Value,
}

A T-minus countdown event for agent coordination.

Fields

id: Uuid

kind: EventKind

scheduled_at: DateTime<Utc>

t_minus: Duration

organizer: AgentId

attendees: Vec<(AgentId, ResponseStatus)>

quorum: usize

payload: Value

Implementations

impl TMinusEvent

pub fn fire_time(&self) -> DateTime<Utc>

The effective fire time: scheduled_at minus t_minus.

pub fn has_quorum(&self) -> bool

Whether the event has reached quorum (enough confirmations).

pub fn confirmed_count(&self) -> usize

Count of confirmed attendees.

pub fn pending_count(&self) -> usize

Count of pending attendees.

pub fn is_fired(&self, now: DateTime<Utc>) -> bool

Whether the event has fired (fire time has passed and quorum met).

pub fn is_missed(&self, now: DateTime<Utc>) -> bool

Whether the event has been missed (fire time passed without quorum).

pub fn time_remaining(&self, now: DateTime<Utc>) -> Duration

Time remaining until fire time.

Trait Implementations

impl Clone for TMinusEvent

fn clone(&self) -> TMinusEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TMinusEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TMinusEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TMinusEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.