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 invalid_records: InvalidRecordPolicy,
    pub oversize: OversizePolicy,
}

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.

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 falls back to the default projection, and is skipped when there is none.

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.

invalid_records: InvalidRecordPolicy

What happens to a record the destination or the extraction deterministically rejects. Block, the default, holds the partition at the record until an operator skips it. DeadLetter skips it through an ordered control record, so every replica skips the same record, and sends it to the dead-letter topic. A destination rejection counts only after the destination accepted other records of the batch and refused this one twice. Skipped on the wire at its default.

oversize: OversizePolicy

What a whole-record binding does with a body larger than its backend stores. Block, the default, holds the partition at the record. Reference keeps the row without the body, which the source log still holds, and requires MirrorLog retention. Skipped on the wire at its default.

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) -> Self

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

Formats the value using the given formatter.

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

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for ProjectionBinding

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ProjectionBinding

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ProjectionBinding

impl Validate for ProjectionBinding

fn validate(&self) -> Result<(), InvalidError>

Reject a request that violates a pinned cap or a structural rule.