Struct SyncPulse 

pub struct SyncPulse {
    pub pulse_id: EventId,
    pub tenant_id: TenantId,
    pub trigger: SyncTrigger,
    pub affected_agents: Vec<AgentId>,
    pub drift_meter: Option<DriftMeter>,
    pub reconciliation: Option<Reconciliation>,
    pub emitted_at: Timestamp,
}

A synchronization pulse emitted when agents need to reconcile.

Fields

pulse_id: EventId

Unique ID for this pulse (correlates with Event DAG entry).

tenant_id: TenantId

Tenant this pulse belongs to.

trigger: SyncTrigger

What triggered this synchronization pulse.

affected_agents: Vec<AgentId>

Agents affected by this pulse.

drift_meter: Option<DriftMeter>

Optional drift measurement that triggered the pulse.

reconciliation: Option<Reconciliation>

Reconciliation result (populated after resolution).

emitted_at: Timestamp

When this pulse was emitted.

Implementations

impl SyncPulse

pub fn from_drift(tenant_id: TenantId, drift_meter: DriftMeter) -> Self

Create a new SyncPulse from a drift threshold breach.

pub fn from_conflict( tenant_id: TenantId, branch_a: EventId, branch_b: EventId, affected_agents: Vec<AgentId>, ) -> Self

Create a new SyncPulse from a DAG conflict detection.

pub fn from_watermark_lag( tenant_id: TenantId, lagging_agent: AgentId, delta: i64, affected_agents: Vec<AgentId>, ) -> Self

Create a new SyncPulse from a watermark lag detection.

pub fn with_reconciliation(self, reconciliation: Reconciliation) -> Self

Attach a reconciliation result to this pulse.

Trait Implementations

impl Clone for SyncPulse

fn clone(&self) -> SyncPulse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ComposeSchema for SyncPulse

fn compose(generics: Vec<RefOr<Schema>>) -> RefOr<Schema>

impl Debug for SyncPulse

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncPulse

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SyncPulse

fn eq(&self, other: &SyncPulse) -> 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 SyncPulse

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl ToSchema for SyncPulse

fn name() -> Cow<'static, str>

Return name of the schema.

fn schemas(schemas: &mut Vec<(String, RefOr<Schema>)>)

Implement reference [utoipa::openapi::schema::Schema]s for this type.

impl StructuralPartialEq for SyncPulse