Struct WatchEvent 

pub struct WatchEvent {
    pub experience_id: ExperienceId,
    pub collective_id: CollectiveId,
    pub event_type: WatchEventType,
    pub timestamp: Timestamp,
    pub experience: Option<Experience>,
}

An event emitted when an experience changes.

Watch events are delivered in-process via bounded crossbeam channels. Each event identifies the experience, collective, mutation type, and when it occurred.

Example

use futures::StreamExt;
use pulsedb::WatchEventType;

let mut stream = db.watch_experiences(collective_id)?;
while let Some(event) = stream.next().await {
    match event.event_type {
        WatchEventType::Created => println!("New experience: {}", event.experience_id),
        WatchEventType::Deleted => println!("Removed: {}", event.experience_id),
        _ => {}
    }
}

Fields

experience_id: ExperienceId

The experience that changed.

collective_id: CollectiveId

The collective the experience belongs to.

event_type: WatchEventType

What kind of change occurred.

timestamp: Timestamp

When the change occurred.

experience: Option<Experience>

The full experience data (enriched event).

Populated for Created and Updated events when delivered via in-process watch subscriptions. None for Deleted events and events reconstructed from WAL records (cross-process polling).

Includes the embedding vector, enabling visualization tools (PulseVision) to update 3D positions without a follow-up fetch.

Trait Implementations

impl Clone for WatchEvent

fn clone(&self) -> WatchEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatchEvent

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

Formats the value using the given formatter.

impl From<WatchEventRecord> for WatchEvent

fn from(record: WatchEventRecord) -> Self

Converts to this type from the input type.