Struct EventIncludeCtx 

pub struct EventIncludeCtx {
    pub pool: Pool,
    pub rls_tenant: Option<String>,
    pub schema_override: Option<String>,
    pub dialect: Arc<dyn Dialect>,
    pub entity: ResolvedEntity,
    pub resolved: Vec<(String, IncludeSpec, ResolvedEntity)>,
    pub pk_column: String,
    pub pk_value: String,
}

Everything the publish task needs to re-read the row with its related entities expanded.

Owned rather than borrowed: the fetch happens inside the detached task, after the handler’s executor (and any RLS transaction) is gone.

Fields

pool: Pool

rls_tenant: Option<String>

Some(tenant) for RLS-strategy tenants — a fresh transaction with SET LOCAL is opened for the fetch. None for database-strategy tenants.

schema_override: Option<String>

dialect: Arc<dyn Dialect>

entity: ResolvedEntity

resolved: Vec<(String, IncludeSpec, ResolvedEntity)>

Every include named by any trigger on this entity, already resolved. Each trigger picks its own subset by name.

pk_column: String

pk_value: String

Primary-key value of the affected row, rendered for an RSQL == leaf.

Implementations

impl EventIncludeCtx

pub fn with_pk_value(&self, pk_value: String) -> Self

Same resolution pointed at a different row. Bulk paths publish one event per row but resolve the include set once for the whole batch — only the pk differs.

Trait Implementations

impl Clone for EventIncludeCtx

fn clone(&self) -> EventIncludeCtx

Returns a duplicate of the value.

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

Performs copy-assignment from source.