Crate graphrefly 

GraphReFly — Rust clean-slate package (graphrefly-rs, lib graphrefly)

Reactive universal reduction layer: high fan-in/fan-out → information reduction → push. Not LLM-limited; performance first-class (D1).

Authority — the truth lives in ~/src/graphrefly

This crate is the Rust implementation. The language-neutral authority — protocol spec, decisions, formal model, conformance scenarios — is in the graphrefly design repo. On any disagreement, that repo wins.

Concern	Source of truth
Decisions (D#)	~/src/graphrefly/decisions/decisions.jsonl
Protocol rules (宪法)	~/src/graphrefly/spec/rules.jsonl
Conformance (parity)	~/src/graphrefly/spec/conformance.jsonl
Formal model	~/src/graphrefly/formal/*.tla
Phase plan	~/src/graphrefly/plan/phases.jsonl

Sibling self-contained packages: @graphrefly/ts (~/src/graphrefly-ts), @graphrefly/py (~/src/graphrefly-py). Cross-language = a coarse wire bridge, never in-process (D32, no cross-language peer-deps).

Rust package docs are intentionally package-local: rustdoc, examples, crate README material, release notes, and docs.rs output live with this repo. The shared public website/blog/docs architecture for graphrefly.dev lives in ~/src/graphrefly under D563; this crate may link there, but does not mirror shared public docs by hand.

Floor (cite, never violate)

• D22 — a graph is a single-thread causal/concurrency domain. This crate is therefore !Send + !Sync: state lives behind Rc<RefCell<…>>, not Arc<Mutex<…>>. The actor model is dropped. Parallelism = pool callback or multi-graph + wire bridge.
• F-SYNC-CORE — the wave-protocol core is synchronous; dispatcher.invoke is fn(&Ctx) returning (). Async lives only in pools (LocalAsync) and the wire bridge.
• F-DISPATCH-ALL — every node fn goes through the dispatcher; no inline-fn bypass.
• D4 — 8-verb closed set (node/graph/batch/state + producer/derived/effect/ mount). Operators are node sugar, per-language, never in parity (D6/D24).
• D8 — the fn boundary is ctx.up(msgs) / ctx.down(msgs); one msgs array = one wave. ctx.up is control-tier only (R-ctx-up).

Clean-slate scope (what this crate builds)

A self-contained Rust package (D32): protocol + node + dispatcher (LocalSync + LocalAsync pools) + ctx + batch + rewire, graph-layer Rust API, graph-owned 8-verb sugar, find/describe/observe/profile, operators, sources, storage helpers, app-infra helpers, environment adapters, and wire-bridge helpers. Operators remain per-language graph-layer sugar (D6/D24), not protocol verbs.

Status: the Rust package-local API surface is implemented in this crate; the language-neutral authority remains ~/src/graphrefly. Use this rustdoc for Rust API syntax and package-local behavior notes, and use the shared authority repo for protocol rules and cross-runtime conformance status.

Re-exports

pub use adapters::agentic_memory_storage::agentic_memory_record_change_frame;

pub use adapters::agentic_memory_storage::agentic_memory_record_snapshot_frame;

pub use adapters::agentic_memory_storage::agentic_memory_records_snapshot_key;

pub use adapters::agentic_memory_storage::load_agentic_memory_records_state;

pub use adapters::agentic_memory_storage::open_persistent_agentic_memory_records;

pub use adapters::agentic_memory_storage::persist_agentic_memory_records;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsPersistence;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceCursor;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceErrorFact;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceStatus;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsPersistenceStatusFact;

pub use adapters::agentic_memory_storage::AgenticMemoryRecordsRestoreState;

pub use adapters::agentic_memory_storage::LoadAgenticMemoryRecordsStateOptions;

pub use adapters::agentic_memory_storage::OpenPersistentAgenticMemoryRecords;

pub use adapters::agentic_memory_storage::OpenPersistentAgenticMemoryRecordsOptions;

pub use adapters::agentic_memory_storage::PersistAgenticMemoryRecordsOptions;

pub use adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_CHANGE_FORMAT;

pub use adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_SNAPSHOT_FORMAT;

pub use adapters::agentic_memory_storage::AGENTIC_MEMORY_RECORD_STORAGE_FRAME_VERSION;

pub use adapters::bridge::remote_call;

pub use adapters::bridge::remote_call_with_options;

pub use adapters::bridge::remote_responder;

pub use adapters::bridge::remote_responder_handler;

pub use adapters::bridge::wire_bridge;

pub use adapters::bridge::wire_bridge_envelope;

pub use adapters::bridge::wire_bridge_idempotency_key;

pub use adapters::bridge::wire_edge_group;

pub use adapters::bridge::RemoteCallBundle;

pub use adapters::bridge::RemoteCallError;

pub use adapters::bridge::RemoteCallOptions;

pub use adapters::bridge::RemoteCallRequest;

pub use adapters::bridge::RemoteCallResponse;

pub use adapters::bridge::RemoteCallResult;

pub use adapters::bridge::RemoteCallStatus;

pub use adapters::bridge::RemoteCallStatusState;

pub use adapters::bridge::RemoteCallTimeout;

pub use adapters::bridge::RemoteResponderBundle;

pub use adapters::bridge::RemoteResponderEvent;

pub use adapters::bridge::RemoteResponderHandlerDefinition;

pub use adapters::bridge::RemoteResponderOptions;

pub use adapters::bridge::RemoteResponderStatus;

pub use adapters::bridge::RemoteResponderStatusState;

pub use adapters::bridge::WireBridgeAck;

pub use adapters::bridge::WireBridgeAttempt;

pub use adapters::bridge::WireBridgeBundle;

pub use adapters::bridge::WireBridgeCommand;

pub use adapters::bridge::WireBridgeEnvelope;

pub use adapters::bridge::WireBridgeEnvelopeError;

pub use adapters::bridge::WireBridgeEnvelopeInput;

pub use adapters::bridge::WireBridgeEnvelopeType;

pub use adapters::bridge::WireBridgeEvent;

pub use adapters::bridge::WireBridgeInbound;

pub use adapters::bridge::WireBridgeIngress;

pub use adapters::bridge::WireBridgeMetadata;

pub use adapters::bridge::WireBridgeNack;

pub use adapters::bridge::WireBridgeOptions;

pub use adapters::bridge::WireBridgePayload;

pub use adapters::bridge::WireBridgeReceipt;

pub use adapters::bridge::WireBridgeStatus;

pub use adapters::bridge::WireBridgeStatusState;

pub use adapters::bridge::WireEdgeGroupBundle;

pub use adapters::bridge::WireEdgeGroupEdge;

pub use adapters::bridge::WireEdgeGroupIssue;

pub use adapters::bridge::WireEdgeGroupIssueCode;

pub use adapters::bridge::WireEdgeGroupOptions;

pub use adapters::bridge::WireEdgeGroupStatus;

pub use adapters::bridge::WireEdgeGroupStatusState;

pub use adapters::bridge_protobuf::decode_canonical_wire_bridge_envelope;

pub use adapters::bridge_protobuf::decode_canonical_wire_edge_frame;

pub use adapters::bridge_protobuf::decode_wire_bridge_protobuf_bytes;

pub use adapters::bridge_protobuf::encode_canonical_wire_bridge_envelope;

pub use adapters::bridge_protobuf::encode_canonical_wire_edge_frame;

pub use adapters::bridge_protobuf::encode_wire_bridge_protobuf_bytes;

pub use adapters::bridge_protobuf::CanonicalProtobufError;

pub use adapters::bridge_protobuf::CanonicalProtobufErrorCategory;

pub use adapters::bridge_protobuf::CanonicalWireBridgeDataBody;

pub use adapters::bridge_protobuf::CanonicalWireBridgeEnvelope;

pub use adapters::bridge_protobuf::CanonicalWireBridgeMetadata;

pub use adapters::bridge_protobuf::CanonicalWireBridgePayload;

pub use adapters::bridge_protobuf::CanonicalWireEdgeFrame;

pub use adapters::bridge_protobuf::CanonicalWireEdgeKind;

pub use adapters::bridge_protobuf::WireBridgeProtobufDataBody;

pub use adapters::bridge_protobuf::WireBridgeProtobufDecode;

pub use adapters::bridge_protobuf::WireBridgeProtobufEncode;

pub use adapters::bridge_protobuf::WireBridgeProtobufEnvelope;

pub use adapters::bridge_protobuf::WireBridgeProtobufHelperShape;

pub use adapters::bridge_protobuf::WireBridgeProtobufIssue;

pub use adapters::bridge_protobuf::WireBridgeProtobufPayload;

pub use adapters::bridge_protobuf::WireBridgeProtobufStatus;

pub use adapters::bridge_protobuf::WireBridgeProtobufStatusKind;

pub use adapters::bridge_protobuf::WIRE_BRIDGE_PROTOBUF_HELPER_SHAPE;

pub use adapters::environment::to_http;

pub use adapters::environment::to_http_with_options;

pub use adapters::environment::to_process;

pub use adapters::environment::to_process_with_options;

pub use adapters::environment::to_websocket;

pub use adapters::environment::to_websocket_with_options;

pub use adapters::environment::websocket_session;

pub use adapters::environment::websocket_session_with_options;

pub use adapters::environment::OutboundAdapterOptions;

pub use adapters::environment::OutboundBundle;

pub use adapters::environment::OutboundEvent;

pub use adapters::environment::OutboundState;

pub use adapters::environment::OutboundStatus;

pub use adapters::environment::WebSocketSessionBundle;

pub use adapters::environment::WebSocketSessionCommand;

pub use adapters::environment::WebSocketSessionInbound;

pub use adapters::environment::WebSocketSessionLifecycle;

pub use adapters::environment::WebSocketSessionOptions;

pub use adapters::environment::WebSocketSessionOutbound;

pub use adapters::environment::WebSocketSessionSendPolicy;

pub use adapters::environment::WebSocketSessionStateKind;

pub use adapters::environment::WebSocketSessionStatus;

pub use adapters::reactive_collection_storage::open_persistent_reactive_index;

pub use adapters::reactive_collection_storage::open_persistent_reactive_list;

pub use adapters::reactive_collection_storage::open_persistent_reactive_log;

pub use adapters::reactive_collection_storage::open_persistent_reactive_map;

pub use adapters::reactive_collection_storage::persist_reactive_index;

pub use adapters::reactive_collection_storage::persist_reactive_list;

pub use adapters::reactive_collection_storage::persist_reactive_log;

pub use adapters::reactive_collection_storage::persist_reactive_map;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveIndex;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveIndexOptions;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveList;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveListOptions;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveLog;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveLogOptions;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveMap;

pub use adapters::reactive_collection_storage::OpenPersistentReactiveMapOptions;

pub use adapters::reactive_collection_storage::PersistReactiveCollectionOptions;

pub use adapters::reactive_collection_storage::ReactiveCollectionPersistence;

pub use adapters::reactive_collection_storage::ReactiveCollectionPersistenceCursor;

pub use adapters::reactive_collection_storage::ReactiveCollectionPersistenceErrorFact;

pub use adapters::reactive_collection_storage::ReactiveCollectionPersistenceStatus;

pub use adapters::reactive_collection_storage::ReactiveCollectionPersistenceStatusFact;

pub use async_driver::TokioLocalDriver;

pub use async_driver::DriverCancel;

pub use async_driver::LocalAsyncDriver;

pub use batch::batch;

pub use batch::BatchCtx;

pub use cascading_cache::reactive_cascading_cache;

pub use cascading_cache::CascadingCacheEvent;

pub use cascading_cache::CascadingCachePolicy;

pub use cascading_cache::CascadingCacheStatus;

pub use cascading_cache::ReactiveCascadingCache;

pub use cascading_cache::ReactiveCascadingCacheLoadFn;

pub use cascading_cache::ReactiveCascadingCacheOptions;

pub use checkpoint::default_restore_registry;

pub use checkpoint::restore_graph;

pub use checkpoint::restore_registry;

pub use checkpoint::restored_opts;

pub use checkpoint::GraphCheckpoint;

pub use checkpoint::GraphCheckpointCtxState;

pub use checkpoint::GraphCheckpointEdge;

pub use checkpoint::GraphCheckpointFactory;

pub use checkpoint::GraphCheckpointJson;

pub use checkpoint::GraphCheckpointLifecycle;

pub use checkpoint::GraphCheckpointMount;

pub use checkpoint::GraphCheckpointNode;

pub use checkpoint::GraphCheckpointTerminal;

pub use checkpoint::GraphCheckpointValue;

pub use checkpoint::GraphRestoreDefinition;

pub use checkpoint::GraphRestoreDescriptor;

pub use checkpoint::GraphRestoreEntry;

pub use checkpoint::GraphRestoreError;

pub use checkpoint::GraphRestoreRegistry;

pub use checkpoint::GraphRestoreResult;

pub use checkpoint::MapJsonRestoreDescriptor;

pub use checkpoint::RestoreDefineCtx;

pub use checkpoint::RestoreGraphOptions;

pub use checkpoint::RestoreNodeDefinition;

pub use checkpoint::RestoreNodeKind;

pub use checkpoint::StateRestoreDescriptor;

pub use checkpoint::GRAPH_CHECKPOINT_VERSION;

pub use combinators::buffer;

pub use combinators::buffer_count;

pub use combinators::combine;

pub use combinators::combine_latest;

pub use combinators::concat;

pub use combinators::race;

pub use combinators::sample;

pub use combinators::take_until;

pub use combinators::with_latest_from;

pub use combinators::zip;

pub use composition::pipe;

pub use composition::stratify;

pub use composition::stratify_branch;

pub use composition::Pipe;

pub use composition::Stratified;

pub use composition::StratifyOptions;

pub use composition::StratifyRule;

pub use cqrs::cqrs;

pub use cqrs::cqrs_command_handler;

pub use cqrs::cqrs_projection;

pub use cqrs::cqrs_with_options;

pub use cqrs::CqrsAuditOutcome;

pub use cqrs::CqrsAuditRecord;

pub use cqrs::CqrsBundle;

pub use cqrs::CqrsCommand;

pub use cqrs::CqrsCommandHandlerDefinition;

pub use cqrs::CqrsCursor;

pub use cqrs::CqrsDedupePolicy;

pub use cqrs::CqrsDedupeSnapshot;

pub use cqrs::CqrsDedupeWindow;

pub use cqrs::CqrsError;

pub use cqrs::CqrsErrorCode;

pub use cqrs::CqrsEvent;

pub use cqrs::CqrsEventDraft;

pub use cqrs::CqrsOptions;

pub use cqrs::CqrsProjection;

pub use cqrs::CqrsProjectionError;

pub use cqrs::CqrsProjectionErrorCode;

pub use cqrs::CqrsProjectionFrame;

pub use cqrs::CqrsProjectionOptions;

pub use cqrs::CqrsProjectionReducer;

pub use cqrs::CqrsProjectionStatus;

pub use cqrs::CqrsProjectionStatusState;

pub use cqrs::CqrsRuntimeFact;

pub use cqrs::CqrsStatus;

pub use cqrs::CqrsStatusState;

pub use ctx::Ctx;

pub use ctx::DeferredCtx;

pub use ctx::DepTerminal;

pub use ctx::WaveData;

pub use data_structures::merge_reactive_logs;

pub use data_structures::reactive_index;

pub use data_structures::reactive_list;

pub use data_structures::reactive_log;

pub use data_structures::reactive_map;

pub use data_structures::restore_reactive_index;

pub use data_structures::restore_reactive_list;

pub use data_structures::restore_reactive_log;

pub use data_structures::restore_reactive_map;

pub use data_structures::scan_log;

pub use data_structures::IndexChange;

pub use data_structures::IndexRow;

pub use data_structures::ListChange;

pub use data_structures::LogChange;

pub use data_structures::MapChange;

pub use data_structures::ReactiveIndex;

pub use data_structures::ReactiveIndexOptions;

pub use data_structures::ReactiveList;

pub use data_structures::ReactiveListOptions;

pub use data_structures::ReactiveLog;

pub use data_structures::ReactiveLogOptions;

pub use data_structures::ReactiveMap;

pub use data_structures::ReactiveMapOptions;

pub use data_structures::ReactiveView;

pub use diagnostics::explain_path;

pub use diagnostics::profile_summary;

pub use diagnostics::profile_summary_from_snapshots;

pub use diagnostics::reachable;

pub use diagnostics::topology_diff;

pub use diagnostics::validate_no_islands;

pub use diagnostics::CausalChain;

pub use diagnostics::CausalStep;

pub use diagnostics::DescribeChangeset;

pub use diagnostics::DescribeEvent;

pub use diagnostics::ExplainPathOptions;

pub use diagnostics::ExplainPathReason;

pub use diagnostics::IslandReport;

pub use diagnostics::ProfileSummary;

pub use diagnostics::ProfileSummaryNode;

pub use diagnostics::ProfileSummaryOptions;

pub use diagnostics::ProfileSummaryStatus;

pub use diagnostics::ReachableDirection;

pub use diagnostics::ReachableOptions;

pub use diagnostics::ReachableResult;

pub use diagnostics::ValidateNoIslandsResult;

pub use dispatcher::default_dispatcher;

pub use dispatcher::Dispatcher;

pub use dispatcher::PoolKind;

pub use environment::TokioHttpDriver;

pub use environment::TokioHttpStreamDriver;

pub use environment::TokioProcessDriver;

pub use environment::TokioWebSocketDriver;

pub use environment::EnvironmentDrivers;

pub use environment::HttpRequest;

pub use environment::HttpResponse;

pub use environment::HttpStreamDriverEvent;

pub use environment::HttpStreamHead;

pub use environment::LocalHttpDriver;

pub use environment::LocalHttpStreamDriver;

pub use environment::LocalProcessDriver;

pub use environment::LocalSseDriver;

pub use environment::LocalWebSocketDriver;

pub use environment::LocalWebSocketSession;

pub use environment::LocalWebhookDriver;

pub use environment::ProcessCommand;

pub use environment::ProcessResult;

pub use environment::SseDriverEvent;

pub use environment::SseEvent;

pub use environment::SseRequest;

pub use environment::WebSocketDriverEvent;

pub use environment::WebSocketEvent;

pub use environment::WebSocketRequest;

pub use environment::WebSocketSend;

pub use environment::WebSocketSendResult;

pub use environment::WebhookDriverEvent;

pub use environment::WebhookEvent;

pub use environment::WebhookRegistration;

pub use graph::graph;

pub use graph::graph_opts;

pub use graph::DescribeEdge;

pub use graph::DescribeNode;

pub use graph::DescribeOpts;

pub use graph::DescribeSnapshot;

pub use graph::DescribeValue;

pub use graph::Explain;

pub use graph::Graph;

pub use graph::GraphNode;

pub use graph::GraphNodeOpts;

pub use graph::GraphObserver;

pub use graph::GraphOptions;

pub use graph::GraphTopologyObserver;

pub use graph::NodeProfile;

pub use graph::ObserveEvent;

pub use graph::ObserveMessage;

pub use graph::ObserveStream;

pub use graph::Profile;

pub use graph::RestoreFactoryMeta;

pub use graph::TopologyEvent;

pub use graph::TopologyEventKind;

pub use graph::TopologyGroup;

pub use graph::TopologyGroupOptions;

pub use graph::TopologyStream;

pub use graph::Values;

pub use higher_order::concat_map;

pub use higher_order::exhaust_map;

pub use higher_order::flat_map;

pub use higher_order::merge_map;

pub use higher_order::merge_map_with_options;

pub use higher_order::repeat;

pub use higher_order::switch_map;

pub use higher_order::MergeMapOptions;

pub use json::assert_decimal_integer_string;

pub use json::assert_non_negative_decimal_integer_string;

pub use json::decimal_string_to_i128;

pub use json::i128_to_decimal_string;

pub use json::is_decimal_integer_string;

pub use json::is_non_negative_decimal_integer_string;

pub use json::json_codec_for;

pub use json::non_negative_decimal_string_to_u128;

pub use json::stable_json_string;

pub use json::strict_canonical_json_bytes;

pub use json::strict_json_codec_for;

pub use json::strict_json_decode;

pub use json::u128_to_non_negative_decimal_string;

pub use json::Codec;

pub use json::DecimalIntegerString;

pub use json::JsonCodec;

pub use json::JsonCodecError;

pub use json::JsonCodecResult;

pub use json::JsonValue;

pub use json::NonNegativeDecimalIntegerString;

pub use json::StrictJsonCodec;

pub use messaging::event_message;

pub use messaging::is_json_schema_valid;

pub use messaging::message_bus;

pub use messaging::to_topic;

pub use messaging::validate_json_schema;

pub use messaging::validate_topic_message_payload;

pub use messaging::DataIssue;

pub use messaging::EventMessage;

pub use messaging::EventMessageOptions;

pub use messaging::JsonSchema;

pub use messaging::JsonSchemaAdditionalProperties;

pub use messaging::JsonSchemaItems;

pub use messaging::JsonSchemaType;

pub use messaging::JsonSchemaTypeSpec;

pub use messaging::JsonSchemaValidationError;

pub use messaging::JsonSchemaValidationResult;

pub use messaging::MessageBus;

pub use messaging::MessageBusAvailablePage;

pub use messaging::MessageBusAvailableParams;

pub use messaging::MessageBusCatalogEntry;

pub use messaging::MessageBusCatalogPage;

pub use messaging::MessageBusCatalogParams;

pub use messaging::MessageBusCommand;

pub use messaging::MessageBusCursor;

pub use messaging::MessageBusDeadLetterEntry;

pub use messaging::MessageBusDeadLetterPage;

pub use messaging::MessageBusDeadLetterParams;

pub use messaging::MessageBusDedupeAction;

pub use messaging::MessageBusDedupePolicy;

pub use messaging::MessageBusOptions;

pub use messaging::MessageBusPullProjection;

pub use messaging::MessageBusRetentionPolicy;

pub use messaging::MessageBusStatus;

pub use messaging::MessageBusStatusKind;

pub use messaging::MessageBusSubscription;

pub use messaging::MessageBusSubscriptionFrom;

pub use messaging::MessageBusSubscriptionOptions;

pub use messaging::MessageBusTopicPage;

pub use messaging::MessageBusTopicParams;

pub use messaging::MessageBusTopicPolicy;

pub use messaging::MessageBusTopicProjection;

pub use messaging::MessageEnvelope;

pub use messaging::ToTopicBundle;

pub use messaging::TopicMessage;

pub use messaging::CONTEXT_TOPIC;

pub use messaging::DEFERRED_TOPIC;

pub use messaging::INJECTIONS_TOPIC;

pub use messaging::PROMPTS_TOPIC;

pub use messaging::RESPONSES_TOPIC;

pub use messaging::SPAWNS_TOPIC;

pub use messaging::STANDARD_TOPICS;

pub use messaging::TODOS_TOPIC;

pub use node::Core;

pub use node::Node;

pub use node::NodeOpts;

pub use node::Pausable;

pub use node::Status;

pub use operators::catch_error;

pub use operators::distinct_until_changed;

pub use operators::element_at;

pub use operators::filter;

pub use operators::find;

pub use operators::first;

pub use operators::first_any;

pub use operators::init_node;

pub use operators::last;

pub use operators::last_any;

pub use operators::map;

pub use operators::merge;

pub use operators::on_first_data;

pub use operators::on_first_data_where;

pub use operators::pairwise;

pub use operators::reduce;

pub use operators::rescue;

pub use operators::scan;

pub use operators::settle;

pub use operators::settle_by;

pub use operators::skip;

pub use operators::take;

pub use operators::take_while;

pub use operators::tap;

pub use operators::tap_first;

pub use operators::valve;

pub use operators::Operator;

pub use patterns::admission_filter_3d;

pub use patterns::admission_scored;

pub use patterns::cosine_similarity;

pub use patterns::filter_memory_fragments;

pub use patterns::knowledge_graph_reducer_bundle;

pub use patterns::memory_fragment_matches_query;

pub use patterns::memory_fragment_valid_at;

pub use patterns::memory_retrieval_bundle;

pub use patterns::shard_by_tenant;

pub use patterns::validate_memory_fragment;

pub use patterns::AdmissionScore3DFn;

pub use patterns::AdmissionScore3DOptions;

pub use patterns::AdmissionScoreFn;

pub use patterns::AdmissionScoredOptions;

pub use patterns::AdmissionScores;

pub use patterns::AdmissionThresholds;

pub use patterns::CollectionEntry;

pub use patterns::FactId;

pub use patterns::FactStore;

pub use patterns::KnowledgeAssertion;

pub use patterns::KnowledgeAssertionObject;

pub use patterns::KnowledgeGraphCursor;

pub use patterns::KnowledgeGraphEntity;

pub use patterns::KnowledgeGraphError;

pub use patterns::KnowledgeGraphErrorCode;

pub use patterns::KnowledgeGraphIndex;

pub use patterns::KnowledgeGraphPolicy;

pub use patterns::KnowledgeGraphReducerBundle;

pub use patterns::KnowledgeGraphReducerBundleOptions;

pub use patterns::KnowledgeGraphRelation;

pub use patterns::KnowledgeGraphSnapshot;

pub use patterns::KnowledgeGraphStatus;

pub use patterns::KnowledgeGraphStatusState;

pub use patterns::KnowledgeGraphTopic;

pub use patterns::MemoryAnswer;

pub use patterns::MemoryFragment;

pub use patterns::MemoryFragmentValidation;

pub use patterns::MemoryQuery;

pub use patterns::MemoryRetrievalBundle;

pub use patterns::MemoryRetrievalBundleOptions;

pub use patterns::MemoryRetrievalCursor;

pub use patterns::MemoryRetrievalError;

pub use patterns::MemoryRetrievalErrorCode;

pub use patterns::MemoryRetrievalFact;

pub use patterns::MemoryRetrievalIndex;

pub use patterns::MemoryRetrievalQuery;

pub use patterns::MemoryRetrievalSnapshot;

pub use patterns::MemoryRetrievalStatus;

pub use patterns::MemoryRetrievalStatusState;

pub use patterns::OutcomeSignal;

pub use patterns::RankedCollectionEntry;

pub use patterns::RetrievalEntry;

pub use patterns::RetrievalEntrySource;

pub use patterns::RetrievalQuery;

pub use patterns::RetrievalTrace;

pub use patterns::ShardByFn;

pub use patterns::ShardByTenantConfig;

pub use patterns::ShardByTenantOptions;

pub use patterns::ShardKey;

pub use patterns::StoreReadHandle;

pub use patterns::TenantShardFn;

pub use patterns::VectorSearchResult;

pub use process::process_bundle;

pub use process::process_effect_runner;

pub use process::ProcessAuditOutcome;

pub use process::ProcessAuditRecord;

pub use process::ProcessBundle;

pub use process::ProcessBundleOptions;

pub use process::ProcessCursor;

pub use process::ProcessEffectCommandPayload;

pub use process::ProcessEffectCommandType;

pub use process::ProcessEffectOutcome;

pub use process::ProcessEffectOutcomeKind;

pub use process::ProcessEffectRequest;

pub use process::ProcessEffectRequestDraft;

pub use process::ProcessEffectRunnerBundle;

pub use process::ProcessEffectRunnerError;

pub use process::ProcessEffectRunnerErrorCode;

pub use process::ProcessEffectRunnerOptions;

pub use process::ProcessEffectRunnerStatus;

pub use process::ProcessEffectRunnerStatusState;

pub use process::ProcessError;

pub use process::ProcessErrorCode;

pub use process::ProcessEvent;

pub use process::ProcessEventDraft;

pub use process::ProcessReducer;

pub use process::ProcessReducerFn;

pub use process::ProcessReduction;

pub use process::ProcessRuntimeFact;

pub use process::ProcessStatus;

pub use process::ProcessStatusState;

pub use protocol::AnyValue;

pub use protocol::GraphError;

pub use protocol::Handle;

pub use protocol::LockId;

pub use protocol::Message;

pub use protocol::PullDemand;

pub use protocol::Tier;

pub use protocol::Wave;

pub use render::describe_to_ascii;

pub use render::describe_to_d2;

pub use render::describe_to_d2_with_direction;

pub use render::describe_to_json;

pub use render::describe_to_mermaid;

pub use render::describe_to_mermaid_url;

pub use render::describe_to_mermaid_with_direction;

pub use render::describe_to_pretty;

pub use render::mermaid_live_url;

pub use render::DiagramDirection;

pub use resilience::breaker_status_node;

pub use resilience::rate_limit_bundle;

pub use resilience::retry_status_node;

pub use resilience::timeout_bundle;

pub use resilience::BackoffPolicy;

pub use resilience::BreakerState;

pub use resilience::BreakerStatus;

pub use resilience::RateLimitBundle;

pub use resilience::RateLimitStatus;

pub use resilience::RetryEvent;

pub use resilience::RetryPolicy;

pub use resilience::RetryState;

pub use resilience::RetryStatus;

pub use resilience::TimeoutBundle;

pub use resilience::TimeoutStatus;

pub use scheduled_readiness::parse_scheduled_readiness_requested;

pub use scheduled_readiness::scheduled_readiness_projector;

pub use scheduled_readiness::ScheduledReadinessAuditRecord;

pub use scheduled_readiness::ScheduledReadinessBundle;

pub use scheduled_readiness::ScheduledReadinessClock;

pub use scheduled_readiness::ScheduledReadinessOptions;

pub use scheduled_readiness::ScheduledReadinessOverdue;

pub use scheduled_readiness::ScheduledReadinessPending;

pub use scheduled_readiness::ScheduledReadinessReady;

pub use scheduled_readiness::ScheduledReadinessRequested;

pub use scheduled_readiness::ScheduledReadinessStatus;

pub use scheduled_readiness::ScheduledReadinessStatusState;

pub use scheduled_readiness::ScheduledReadinessViews;

pub use scheduled_readiness::SourceRef;

pub use solutions::agentic_memory_bundle;

pub use solutions::agentic_memory_consolidation_bundle;

pub use solutions::agentic_memory_context_packing_bundle;

pub use solutions::agentic_memory_kg_projection_bundle;

pub use solutions::agentic_memory_record_frame;

pub use solutions::agentic_memory_record_frame_codec;

pub use solutions::agentic_memory_retention_bundle;

pub use solutions::validate_agentic_memory_artifact_kind;

pub use solutions::validate_agentic_memory_kind;

pub use solutions::validate_agentic_memory_persistence_level;

pub use solutions::validate_agentic_memory_record;

pub use solutions::validate_agentic_memory_scope;

pub use solutions::AgenticMemoryArtifactKind;

pub use solutions::AgenticMemoryBundle;

pub use solutions::AgenticMemoryBundleOptions;

pub use solutions::AgenticMemoryConsolidationBundle;

pub use solutions::AgenticMemoryConsolidationBundleOptions;

pub use solutions::AgenticMemoryConsolidationCommand;

pub use solutions::AgenticMemoryConsolidationCommandKind;

pub use solutions::AgenticMemoryConsolidationCursor;

pub use solutions::AgenticMemoryConsolidationOutcome;

pub use solutions::AgenticMemoryConsolidationRecordDraft;

pub use solutions::AgenticMemoryConsolidationRequest;

pub use solutions::AgenticMemoryConsolidationResult;

pub use solutions::AgenticMemoryConsolidationResultState;

pub use solutions::AgenticMemoryConsolidationSnapshot;

pub use solutions::AgenticMemoryConsolidationStatus;

pub use solutions::AgenticMemoryContext;

pub use solutions::AgenticMemoryContextEntry;

pub use solutions::AgenticMemoryContextPackingBundle;

pub use solutions::AgenticMemoryContextPackingBundleOptions;

pub use solutions::AgenticMemoryContextPackingCursor;

pub use solutions::AgenticMemoryContextPackingPolicy;

pub use solutions::AgenticMemoryContextPackingSnapshot;

pub use solutions::AgenticMemoryContextPackingStatus;

pub use solutions::AgenticMemoryCursor;

pub use solutions::AgenticMemoryError;

pub use solutions::AgenticMemoryErrorCode;

pub use solutions::AgenticMemoryFieldValidation;

pub use solutions::AgenticMemoryKgAssertionDraft;

pub use solutions::AgenticMemoryKgProjectionBundle;

pub use solutions::AgenticMemoryKgProjectionBundleOptions;

pub use solutions::AgenticMemoryKgProjectionCursor;

pub use solutions::AgenticMemoryKgProjectionSnapshot;

pub use solutions::AgenticMemoryKgProjectionStatus;

pub use solutions::AgenticMemoryKind;

pub use solutions::AgenticMemoryPackedContext;

pub use solutions::AgenticMemoryPersistenceLevel;

pub use solutions::AgenticMemoryProjection;

pub use solutions::AgenticMemoryRecord;

pub use solutions::AgenticMemoryRecordFrame;

pub use solutions::AgenticMemoryRecordFrameCodec;

pub use solutions::AgenticMemoryRecordMetadata;

pub use solutions::AgenticMemoryRecordValidation;

pub use solutions::AgenticMemoryRetentionBundle;

pub use solutions::AgenticMemoryRetentionBundleOptions;

pub use solutions::AgenticMemoryRetentionCommand;

pub use solutions::AgenticMemoryRetentionCommandKind;

pub use solutions::AgenticMemoryRetentionCursor;

pub use solutions::AgenticMemoryRetentionSnapshot;

pub use solutions::AgenticMemoryRetentionStatus;

pub use solutions::AgenticMemoryScope;

pub use solutions::AgenticMemorySourceProjection;

pub use solutions::AgenticMemoryStatus;

pub use solutions::AgenticMemoryStatusState;

pub use solutions::AgenticMemoryTextProjection;

pub use solutions::AGENTIC_MEMORY_RECORD_FRAME_FORMAT;

pub use solutions::AGENTIC_MEMORY_RECORD_FRAME_VERSION;

pub use sources::empty;

pub use sources::first_sync_value_from;

pub use sources::from_cron;

pub use sources::from_cron_with_options;

pub use sources::from_fs_watch;

pub use sources::from_fs_watch_with_options;

pub use sources::from_git_hook;

pub use sources::from_git_hook_with_options;

pub use sources::from_http;

pub use sources::from_http_with_options;

pub use sources::from_iter;

pub use sources::from_process;

pub use sources::from_sse;

pub use sources::from_sse_with_options;

pub use sources::from_timer;

pub use sources::from_webhook;

pub use sources::from_webhook_with_options;

pub use sources::from_websocket;

pub use sources::from_websocket_with_options;

pub use sources::future_local;

pub use sources::interval;

pub use sources::matches_cron;

pub use sources::never;

pub use sources::of;

pub use sources::parse_cron;

pub use sources::run_process;

pub use sources::run_process_with_options;

pub use sources::single_sync_value_from;

pub use sources::stream_local;

pub use sources::throw_error;

pub use sources::timer;

pub use sources::CronInstant;

pub use sources::CronParseError;

pub use sources::CronSchedule;

pub use sources::CronTick;

pub use sources::FromCronOptions;

pub use sources::FromFsWatchOptions;

pub use sources::FromGitHookOptions;

pub use sources::FsEvent;

pub use sources::FsEventKind;

pub use sources::GitEvent;

pub use sources::GitHookType;

pub use sources::SyncValueFromError;

pub use storage::append_log_key;

pub use storage::append_log_storage;

pub use storage::assert_wal_frame;

pub use storage::change_envelope_codec;

pub use storage::codec_kv_storage;

pub use storage::content_addressed_kv;

pub use storage::content_addressed_storage;

pub use storage::dict_kv;

pub use storage::envelope_change;

pub use storage::file_append_log;

pub use storage::file_backend;

pub use storage::file_kv;

pub use storage::load_reactive_index_state;

pub use storage::load_reactive_list_state;

pub use storage::load_reactive_log_state;

pub use storage::load_reactive_map_state;

pub use storage::memory_append_log;

pub use storage::memory_kv;

pub use storage::memory_multi_writer_append_log;

pub use storage::multi_writer_append_log_storage;

pub use storage::now_ns;

pub use storage::observe_event_frame;

pub use storage::observe_event_frame_codec;

pub use storage::reactive_collection_change_frame;

pub use storage::reactive_collection_change_frame_codec;

pub use storage::reactive_collection_snapshot_frame;

pub use storage::reactive_collection_snapshot_frame_codec;

pub use storage::reactive_collection_snapshot_key;

pub use storage::read_append_log_page;

pub use storage::read_observe_event_log_page;

pub use storage::read_through_kv;

pub use storage::tiered_read_through;

pub use storage::verify_wal_frame_checksum;

pub use storage::wal_frame;

pub use storage::wal_frame_checksum;

pub use storage::wal_frame_codec;

pub use storage::wal_frame_key;

pub use storage::wal_frame_prefix;

pub use storage::AppendLogEntry;

pub use storage::AppendLogPage;

pub use storage::AppendLogReadOptions;

pub use storage::AppendLogStorage;

pub use storage::AppendLogStorageTier;

pub use storage::ByteStorageBackend;

pub use storage::ChangeEnvelope;

pub use storage::ChangeEnvelopeCodec;

pub use storage::ChangeEnvelopeOptions;

pub use storage::ChangeLifecycle;

pub use storage::CodecKvStorage;

pub use storage::ContentAddressedKeyContext;

pub use storage::ContentAddressedKv;

pub use storage::ContentAddressedKvOptions;

pub use storage::ContentAddressedMode;

pub use storage::ContentAddressedStorage;

pub use storage::ContentAddressedStorageOptions;

pub use storage::FileAppendLogOptions;

pub use storage::FileBackend;

pub use storage::FileBackendOptions;

pub use storage::FileKv;

pub use storage::KvGeneration;

pub use storage::KvStorageTier;

pub use storage::KvVersionedRead;

pub use storage::LoadReactiveCollectionStateOptions;

pub use storage::MemoryKv;

pub use storage::MultiWriterAppendLogStorage;

pub use storage::ObserveEventFrame;

pub use storage::ObserveEventFrameCodec;

pub use storage::ObserveEventFrameOptions;

pub use storage::ObserveEventLogPage;

pub use storage::PromotionPolicy;

pub use storage::ReactiveCollectionChangeFrame;

pub use storage::ReactiveCollectionChangeFrameCodec;

pub use storage::ReactiveCollectionChangesRestoreMeta;

pub use storage::ReactiveCollectionKind;

pub use storage::ReactiveCollectionRestoreSource;

pub use storage::ReactiveCollectionRestoreState;

pub use storage::ReactiveCollectionSnapshotFrame;

pub use storage::ReactiveCollectionSnapshotFrameCodec;

pub use storage::ReactiveCollectionSnapshotRestoreMeta;

pub use storage::ReactiveIndexRestoreState;

pub use storage::ReactiveListRestoreState;

pub use storage::ReactiveLogRestoreState;

pub use storage::ReactiveMapRestoreState;

pub use storage::ReadThroughErrorContext;

pub use storage::ReadThroughErrorFn;

pub use storage::ReadThroughErrorStage;

pub use storage::ReadThroughLoadFn;

pub use storage::ReadThroughLookupFact;

pub use storage::ReadThroughLookupTier;

pub use storage::ReadThroughMissContext;

pub use storage::ReadThroughMissFn;

pub use storage::ReadThroughOutcome;

pub use storage::ReadThroughPromotionFact;

pub use storage::StorageError;

pub use storage::StorageResult;

pub use storage::TieredReadThroughOptions;

pub use storage::TieredReadThroughResult;

pub use storage::TieredReadThroughStatus;

pub use storage::WalFrame;

pub use storage::WalFrameBody;

pub use storage::WalFrameCodec;

pub use storage::WalFrameOptions;

pub use storage::WalFrameTimestampNs;

pub use storage::APPEND_LOG_SEQ_PAD;

pub use storage::REACTIVE_COLLECTION_CHANGE_FORMAT;

pub use storage::REACTIVE_COLLECTION_FRAME_VERSION;

pub use storage::REACTIVE_COLLECTION_SNAPSHOT_FORMAT;

pub use storage::WAL_FORMAT_VERSION;

pub use storage::WAL_FRAME_SEQ_PAD;

pub use storage::WAL_KEY_SEGMENT;

pub use time::audit;

pub use time::audit_time;

pub use time::buffer_time;

pub use time::debounce;

pub use time::debounce_time;

pub use time::delay;

pub use time::throttle;

pub use time::throttle_time;

pub use time::timeout;

pub use work_queue::readiness::work_queue_lease_expiration_command;

pub use work_queue::readiness::work_queue_lease_expiration_command_projector;

pub use work_queue::readiness::work_queue_readiness_handoff_projector;

pub use work_queue::readiness::work_queue_scheduled_readiness_projector;

pub use work_queue::readiness::WorkQueueLeaseExpirationCommandProjectorOptions;

pub use work_queue::readiness::WorkQueueReadinessCandidate;

pub use work_queue::readiness::WorkQueueReadinessCandidateKind;

pub use work_queue::readiness::WorkQueueReadinessHandoffBundle;

pub use work_queue::readiness::WorkQueueReadinessHandoffOptions;

pub use work_queue::readiness::WorkQueueReadinessScheduleKind;

pub use work_queue::readiness::WorkQueueReadinessStatus;

pub use work_queue::readiness::WorkQueueReadinessStatusState;

pub use work_queue::readiness::WorkQueueReadinessViews;

pub use work_queue::readiness::WorkQueueScheduledReadinessBundle;

pub use work_queue::readiness::WorkQueueScheduledReadinessOptions;

pub use work_queue::work_queue;

pub use work_queue::WorkQueue;

pub use work_queue::WorkQueueActiveLease;

pub use work_queue::WorkQueueAvailableItem;

pub use work_queue::WorkQueueAvailablePage;

pub use work_queue::WorkQueueAvailableParams;

pub use work_queue::WorkQueueAvailableProjection;

pub use work_queue::WorkQueueClaimOptions;

pub use work_queue::WorkQueueCommand;

pub use work_queue::WorkQueueDeadLetterPage;

pub use work_queue::WorkQueueDeadLetterParams;

pub use work_queue::WorkQueueDerivedState;

pub use work_queue::WorkQueueMessageBusRef;

pub use work_queue::WorkQueueOptions;

pub use work_queue::WorkQueueProjection;

pub use work_queue::WorkQueueRecord;

pub use work_queue::WorkQueueStatus;

pub use work_queue::WorkQueueStatusKind;

pub use work_queue::WorkQueueSubmit;

pub use work_queue::WorkQueueSubmitOptions;

pub use work_queue::WorkQueueWorkSnapshot;

pub use worker::worker_derived;

Modules

adapters

Capability adapters that bridge graph-runtime egress to external systems (D125).

async_driver

Injectable local async/time driver boundary (D111).

batch

Batch — declarative transactional wave grouping (D12 / L2.E).

cascading_cache

Graph-layer reactive cascading cache helper (D104/D105/D107/D123).

checkpoint

Fresh graph checkpoint/restore (R-snapshot/R-restore, D83/D94/D116).

combinators

Static-dep combinators (D6/D24/B53).

composition

Graph-layer composition helpers (B70 / D56).

cqrs

Graph-visible CQRS application infrastructure (D142 / B67).

ctx

The fn-body context — the substrate↔user-fn boundary (D8).

data_structures

Reactive data structures (B53 / D54 / D60), starting with reactive_list.

diagnostics

Pure graph diagnostics over DescribeSnapshot (D39/R-describe).

dispatcher

The dispatcher — first-class invoke funnel + pool host (D20 / D21).

environment

Graph-owned environment driver bag (D130/D131).

graph

Graph-layer Rust API: graph-owned factories, topology, and inspection.

higher_order

Higher-order operator factories (D6/D24/B53).

json

Neutral JSON/encoding helpers shared by checkpoint and passive storage (D96).

messaging

Graph-visible messaging application infrastructure.

node

The node — the thinnest substrate primitive (D5 / R-node-thin).

operators

Free-standing operator factories (D6/D24/D40).

patterns

Horizontal graph-visible patterns.

process

Graph-visible process orchestration bundle (D136 / B84).

protocol

Wave-protocol data types — the decision-locked, language-neutral core.

render

Pure renderers over DescribeSnapshot (D39/D40).

resilience

Passive resilience policies for environment adapters (D130).

scheduled_readiness

Graph-visible scheduled readiness projector (D424/D432/D433).

solutions

Vertical graph-visible solutions.

sources

Source factories (D43/D40/D111).

storage

Passive storage/read-through helpers for Rust product completeness (D123).

time

Wall-clock time operator factories (D52/D111/B53).

work_queue

MessageBus-backed generic work lifecycle infrastructure.

worker

Graph-helper-first worker compute (D137/D138).

Enums

NodeVersion

NodeVersion variants.

NodeVersioningPolicy

NodeVersioningPolicy variants.

ResolvedNodeVersioningPolicy

ResolvedNodeVersioningPolicy variants.

Functions

default_node_version_hash

Creates or computes default_node_version_hash.

Type Aliases

NodeVersionHashFn

NodeVersionHashFn type alias.