Struct PgCrdtHookImpl 

pub struct PgCrdtHookImpl {
    pub crdt: Arc<PgLoroStore>,
    pub manifest: Arc<AppManifest>,
}

Bridge struct that lets PgTxStore (in pylon-storage) call back into the runtime’s CRDT machinery without a direct dependency. Lives only for the duration of a single mutation tx.

Fields

crdt: Arc<PgLoroStore>

Reference to the runtime’s PgLoroStore. Arc so the trait object can be cloned across the storage / runtime boundary.

manifest: Arc<AppManifest>

Shared with the runtime so we can resolve the field-shape for each CRDT entity (which Loro types each field uses).

Trait Implementations

impl PgCrdtHook for PgCrdtHookImpl

fn before_insert( &self, tx: &mut Transaction<'_>, entity: &str, data: &Value, ) -> Result<Option<Value>, DataError>

fn before_update( &self, tx: &mut Transaction<'_>, entity: &str, id: &str, data: &Value, ) -> Result<(), DataError>

fn before_delete( &self, tx: &mut Transaction<'_>, entity: &str, id: &str, ) -> Result<(), DataError>

fn after_commit(&self, entity: &str, id: &str)

Called after the surrounding tx commits successfully — runtime uses this to refresh its in-memory cache.

fn on_rollback(&self, entity: &str, id: &str)

Called when the surrounding tx rolls back — runtime uses this to evict any cache entries it touched in apply_patch.