Module dataflows

Types and methods for building and shipping dataflow descriptions.

Dataflows are buildable from the coordinator’s catalog and indexes members, which respectively describe the collection backing identifiers and indicate which identifiers have arrangements available. This module isolates that logic from the rest of the somewhat complicated coordinator.

Structs

ComputeInstanceSnapshot

A reference-less snapshot of a compute instance. There is no guarantee instance_id continues to exist after this has been made.

DataflowBuilder

Borrows of catalog and indexes sufficient to build dataflow descriptions.

ExprPrepMaintained

Preparing an expression for maintained dataflow, e.g., index, materialized view, or subscribe. Produces errors for calls to unmaterializable functions.

ExprPrepNoop

A no-op expression preparer.

ExprPrepOneShot

Prepare an expression to run once at a logical time in a session. Calls to all unmaterializable functions are replaced with constants.

ExprPrepWebhookValidation

Prepare an expression for evaluation in a CHECK expression of a webhook source. Replaces calls to UnmaterializableFunc::CurrentTimestamp, others are left untouched.

Enums

EvalTime

Traits

ExprPrep

Behavior to prepare relation and scalar expressions for use in a dataflow.

Functions

dataflow_import_id_bundle

Returns an ID bundle with the given dataflows imports.

eval_unmaterializable_func 🔒

role_oid_memberships 🔒

role_oid_memberships_inner 🔒