Struct ProjectionBindingBuilder 

pub struct ProjectionBindingBuilder { /* private fields */ }

Fluent builder for a ProjectionBinding.

Implementations

impl ProjectionBindingBuilder

pub fn source(self, stream: impl Into<String>, topic: impl Into<String>) -> Self

Set the binding source. A source is always a (stream, topic) pair, and a topic only exists within a stream, so both are required.

pub fn selector(self, source: SourceSelector) -> Self

Set the binding source from a pre-built SourceSelector.

pub fn allow(self, projection: impl Into<ProjectionId>) -> Self

Allow records to route to this projection.

pub fn default_projection(self, projection: impl Into<ProjectionId>) -> Self

Projection used when a record carries no agdx.ref.

pub fn add_target(self, target: Target) -> Self

Add a materialization target. The first read_write target serves queries. Further targets are write-only mirrors.

pub fn retention(self, retention: RetentionPolicy) -> Self

Set how long the materialized rows live, independent of the source topic’s Iggy retention. Omit to inherit the managed backend’s default.

// Short-lived topic, permanent index:
let binding = ProjectionBinding::builder()
    .source("_agdx", "telemetry")
    .allow("telemetry.v1")
    .target_table("telemetry_rows")
    .retention(RetentionPolicy::Keep)
    .build();

pub fn target_table(self, table: impl Into<String>) -> Self

Materialize into a table of this name on the embedded backend: sugar for a single read_write, effectively_once target. The common case.

pub fn target_on( self, backend: impl Into<String>, table: impl Into<String>, ) -> Self

Materialize into table on a named backend: the read_write, effectively_once query-serving home. This is how a binding routes one index to a specific configured backend (e.g. an external warehouse declared as warehouse) while other bindings stay on embedded, so different topics materialize to and are served from different stores at once.

// orders -> external warehouse, events stay on the embedded engine.
let binding = ProjectionBinding::builder()
    .source("shop", "orders")
    .allow("orders.v1")
    .target_on("warehouse", "orders_rows")
    .build();

pub fn mirror_to( self, backend: impl Into<String>, table: impl Into<String>, ) -> Self

Add a write-only mirror of this binding’s rows into table on a named backend. The mirror does not serve queries (exactly one read_write target does) and is non-blocking, so one projection can fan the same rows to several backends at once (e.g. the embedded engine for low-latency reads plus an external warehouse for analytics).

pub fn notify(self) -> Self

Opt into the change feed: one ChangeRecord per committed projector batch for this binding, on the changes topic.

pub fn build(self) -> ProjectionBinding

Build the binding. Panics if .source(..) / .selector(..) was not set (programmer error, not user input). Prefer try_build for code paths that handle config-load failures gracefully.

pub fn try_build(self) -> Result<ProjectionBinding, InvalidError>

Build the binding, returning an error if required fields are missing instead of panicking.

Trait Implementations

impl Default for ProjectionBindingBuilder

fn default() -> ProjectionBindingBuilder

Returns the “default value” for a type.