palimpsest-dataflow 0.1.1

A Postgres WAL-backed live query sync engine.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! Palimpsest-specific dataflow runtime extensions.

pub mod build_plan;
pub mod compaction;
pub mod compile_mir;
pub mod cte;
pub mod dataflow_host;
pub mod eval;
pub mod materialization;
pub mod metrics;
pub mod relational;
pub mod shared;
pub mod time;
pub mod toast;
pub mod upquery;
pub mod wal;
pub mod worker;

pub use build_plan::{
    BuildPlan, BuildPlanRegistry, PlanAlreadyRegistered, ProbeHandle, RegisteredPlan, TraceHandle,
};
pub use compaction::{LsnWatermarks, SubscriberId};
pub use compile_mir::{
    compile_mir, install_plan, CompileError, CompiledPlan, NodeRecipe, TableSchemaLookup,
};
pub use cte::{CteAlreadyRegistered, CteRegistry};
pub use dataflow_host::{snapshot_run, AggregateDelta, PersistentHost};
pub use eval::{
    compile_int_extractor, compile_predicate, compile_scalar, EvalError, IntExtractor, PredicateFn,
    ScalarFn, ScalarSchema,
};
pub use materialization::{
    ArrangementAlreadyTracked, BatchLookup, KeyStatus, LookupOutcome, MaterializationTracker,
    MaterializedKeys,
};
pub use metrics::{Metrics, OperatorMemory, OperatorSnapshot, UpqueryCounters};
pub use relational::{
    aggregate_i64, distinct, equi_join, filter, left_join, project, topk, union, union_distinct,
    AggregateFunc, AggregateValue, SortDirection,
};
pub use shared::{
    SharedSubgraphAcquire, SharedSubgraphId, SharedSubgraphRegistry, SharedSubgraphRelease,
};
pub use time::{Lsn, LsnSummary};
pub use toast::{
    ArrangementCache, ColumnLocation, PointSelect, RowKey, ToastOutcome, ToastResolver, ToastStats,
};
pub use upquery::{
    base_tables, plan_upquery, referenced_columns, PrimaryKeyResolver, StaticPrimaryKeys,
    UpqueryPlan, UpqueryRequest,
};
pub use wal::{Row, RowContainer, WalSourceState, WalTransaction, WalUpdate};
pub use worker::{
    spawn_worker, LocalTimelyWorker, StepLoopConfig, WorkerCommand, WorkerError, WorkerHandle,
    WorkerStats,
};