Struct ProjectionBinding 

pub struct ProjectionBinding {
    pub source: SourceSelector,
    pub allowed_projections: Vec<ProjectionId>,
    pub default_projection: Option<ProjectionId>,
    pub backend: Option<BackendBinding>,
    pub index: String,
    pub notify: bool,
    pub retention: Option<RetentionPolicy>,
    pub skip_rejected: bool,
}

Declares where a Projection is allowed to materialize. Bindings, not projections, tell the worker what to consume. A binding pairs a source selector (stream and topic) with a set of allowed projection refs, an optional default, and one operational index. The index uses the replica-local backend unless an exact backend resource generation is bound. Shared lakehouse materializations are independent MaterializationDestination declarations, never mirrors on this operational cursor.

Fields

source: SourceSelector

allowed_projections: Vec<ProjectionId>

Projections allowed to fire on messages from this source. A record stamped with an agdx.ref outside this set is either DLQ’d or skipped, per worker policy.

default_projection: Option<ProjectionId>

Default projection applied to records that do not carry an agdx.ref. None means such records are skipped.

backend: Option<BackendBinding>

Exact operational backend resource generation. None selects the replica-local backend.

index: String

Operational index name served by QueryTarget::Operational.

notify: bool

Opt this binding into the change feed: after each committed projector batch the managed backend publishes one ChangeRecord on the changes topic. Default off and skipped on the wire, so a deployment that never opts in emits nothing and a pre-feed binding encodes byte-identically.

retention: Option<RetentionPolicy>

Row lifetime for this binding, independent of the source topic’s Iggy retention. None inherits LaserData Cloud’s fleet-wide default (MirrorLog unless an operator changed it). Set it via retention.

skip_rejected: bool

Let the managed backend skip a record the destination or the extraction deterministically rejects, instead of holding the partition until the binding enables skipping. Operator skips also require this opt-in. The backend skips only after it proved the rejection: the destination accepted other records of the same batch and refused this one twice. Every skip is an ordered control record, so every replica skips the same record, and the record goes to the dead-letter topic. Default off and skipped on the wire.

Implementations

impl ProjectionBinding

pub fn builder() -> ProjectionBindingBuilder

Start building a binding (which topic feeds which projection).

Trait Implementations

impl Clone for ProjectionBinding

fn clone(&self) -> ProjectionBinding

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProjectionBinding

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProjectionBinding

fn deserialize<__D>( __deserializer: __D, ) -> Result<ProjectionBinding, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ProjectionBinding

fn eq(&self, other: &ProjectionBinding) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for ProjectionBinding

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ProjectionBinding