Module peek

Logic and types for creating, executing, and tracking peeks.

This module determines if a dataflow can be short-cut, by returning constant values or by reading out of existing arrangements, and implements the appropriate plan.

Structs

PeekDataflowPlan

PendingPeek 🔒

A peek is a request to read data from a maintained arrangement.

PlannedPeek

Enums

FastPathPlan

PeekPlan

Possible ways in which the coordinator could produce the result for a goal view.

PeekResponseUnary

The response from a Peek, with row multiplicities represented in unary.

Functions

create_fast_path_plan

Determine if the dataflow plan can be implemented without an actual dataflow.

mfp_to_safe_plan 🔒

Convert mfp to an executable, non-temporal plan. It should be non-temporal, as OneShot preparation populates mz_now.

permute_oneshot_mfp_around_index 🔒

If it can’t convert mfp into a SafeMfpPlan, this returns an internal error.