rocksgraph 0.1.0

A Gremlin-inspired property graph query engine written in Rust, backed by RocksDB
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

// Copyright (c) 2026 Austin Han <austinhan1024@gmail.com>
//
// This file is part of RocksGraph.
//
// RocksGraph is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 2 of the License, or
// (at your option) any later version.
//
// RocksGraph is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with RocksGraph.  If not, see <https://www.gnu.org/licenses/>.

//! Pull-based physical operators for the volcano execution engine.
//!
//! Each submodule is one physical step. Steps are wired into a chain by
//! [`PhysicalPlanBuilder`]: every step holds an optional upstream [`ConsumerIter`]
//! that it pulls from, and exposes a new `ConsumerIter` downstream callers pull
//! from in turn.
//!
//! The shared wiring protocol lives in [`traits`]:
//! - [`GremlinStep`] — the `Rc<RefCell<…>>` wrapper + `subscribe` factory.
//! - [`ConsumerIter`] — the opaque `Rc<dyn Step>` handle passed between steps.
//! - [`Step`] — the core pull trait: `next`, `reset`, `add_upper`.
//!
//! [`PhysicalPlanBuilder`]: crate::engine::volcano::builder::PhysicalPlanBuilder

// ── Physical step submodules ───────────────────────────────────────────────────
pub mod add_e;
pub mod add_v;
pub mod and_or;
pub mod as_select;
pub mod both;
pub mod choose;
pub mod coalesce;
pub mod constant;
pub mod count;
pub mod dedup;
pub mod degree;
pub mod drop;
pub mod e;
pub mod end_vertex_filter;
pub mod fold;
pub mod get_e;
pub mod group;
pub mod has_id;
pub mod has_label;
pub mod has_property;
pub mod has_rank;
pub mod id_step;
pub mod identity;
pub mod in_out;
pub mod in_v_out_v;
pub mod label_step;
pub mod limit;
pub mod local;
pub mod not;
pub mod numeric_reducers;
pub mod order;
pub mod other_v;
pub mod path;
pub mod property;
pub mod range_skip_tail;
pub mod rank_step;
pub mod repeat;
pub mod scalar_filter;
pub mod simple_cyclic_path;
#[cfg(test)]
mod tests;
pub mod traits;
pub mod unfold;
pub mod union;
pub mod v;
pub mod values;
pub mod vec_source;
pub mod r#where;

// ── Physical plan operators (storage-layer stubs) ─────────────────────────────

pub use traits::{CoreStep, StepRef};