ArcFlow
Company
Managed Services
Markets
  • News
  • LOG IN
  • GET STARTED

OZ brings Visual Intelligence to physical venues, a managed edge layer that lets real-world environments see, understand, and act in real time.

Talk to us

ArcFlow

  • World Models
  • Sensors

Managed Services

  • OZ VI Venue 1
  • Case Studies

Markets

  • Sports
  • Broadcasting
  • Robotics

Company

  • About
  • Technology
  • Careers
  • Contact

Ready to see it live?

Talk to the OZ team about deploying at your venues, from a single pilot match to a full regional rollout.

Schedule a deployment review

© 2026 OZ. All rights reserved.

LinkedIn
ArcFlow Docs
Start
  • Quickstart
  • Installation
  • Bindings
  • Platforms
  • Get Started
  • Cookbook
Concepts
  • World Model
  • Graph Model
  • Evidence Model
  • Observations
  • Confidence & Provenance
  • Proof Artifacts & Gates
  • SQL vs GQL
  • Graph Patterns
  • Parameters
  • Query Results
  • Persistence & WAL
  • Snapshot-Pinned Reads
  • Error Handling
  • Execution Models
  • Causal Edges
  • Adapter Discipline
  • Time Decay
  • Layers
  • 1. World Store
  • 1a. World Store · Smart Reader
  • 2. Perception Lake
  • 3. World Graph
  • 4. Query Engine
  • 5. Live Surface
  • 6. Event Bus
  • 7. Behavior Engine
  • 8. Algorithm Library
  • Virtual Computed Columns
  • Threading Model
  • Typed ID Contract
WorldCypher
  • Overview
  • Execution Options
  • Statements
  • MATCH
  • WHERE
  • RETURN
  • OPTIONAL MATCH
  • CREATE
  • SET
  • MERGE
  • DELETE
  • REMOVE
  • Composition
  • WITH
  • UNION
  • UNWIND
  • CASE
  • Schema
  • Schema Overview
  • Indexes
  • Constraints
  • Functions
  • Built-in Functions
  • Aggregations
  • Procedures
  • Shortest Path
  • EXPLAIN
  • PROFILE
  • Temporal Queriesfacet
  • Spatial Queriesfacet
  • Algorithmsfacet
  • Triggers
Capabilities
  • Live Queries
  • Vector Search
  • Trusted RAG
  • Spatial Knowledge
  • Temporal
  • Behavior Graphs
  • Graph Algorithms
  • Skills
  • CREATE SKILL
  • PROCESS NODE
  • REPROCESS EDGES
  • Sync
  • Programs
  • GPU Acceleration
  • Agent-Native
  • MCP Server
  • Event Sourcing
  • Intent Relay
  • Event Bus
Use Cases
  • Agent Tooling
  • Trusted RAG
  • Knowledge Management
  • Behavior Graphs
  • Autonomous Systems
  • Physical AI
  • Digital Twins
  • Robotics & Perception
  • Sports Analytics
  • Grounded Neural Objects
  • Fraud Detection
Walkthroughs
    Guides
  • Agent Integration
  • Building a World Model
  • Modeling a Social Graph
  • Build a RAG Pipeline
  • Using Skills
  • Behavior Graphs
  • Swarm & Multi-Agent
  • Fleet Coordination
  • Migrate from Cypher / Neo4j
  • From SQL to GQL
  • Filesystem Workspace
  • Data Quality
  • Code Intelligence
  • Scale Patterns
  • v0.7 → v0.8 Lakehouse Fast-Path
  • Tutorials
  • Knowledge Graph
  • Entity Linking
  • Vector Search
  • Graph Algorithms
  • Recipes
  • CRUD
  • Multi-MATCH
  • MERGE (Upsert)
  • Full-Text Search
  • Batch Projection
  • Multi-Source Observation
  • Sports Analytics
Operations
  • CLI
  • REPL Commands
  • Snapshot & Restore
  • Filesystem Projection
  • Plugin Management
  • Agent Governance
  • Server Modes & PG Wire
  • Persistence (ops)
  • Import & Export
  • Deployment
  • Deployment Modes
  • Daemon (UDS)
  • Why not Docker
  • Architecture
  • Engine Architecture
  • Cloud Architecture
  • Sync Protocol (Deep Dive)
  • World Graph Substrate (Preview)
Reference
  • TypeScript API
  • Glossary
  • Naming & Domain Map
  • Data Types
  • Operators
  • Error Codes
  • GQL Reference
  • Known Issues
  • Versioning
  • Licensing
  • Conformance
  • GQL Conformance
  • openCypher TCK
  • Extension Regressions
GQL Reference
    Conformance
  • Conformance Dashboard
  • openCypher TCK Results
  • Extension Regressions
  • Features
  • MATCH Basic
  • CREATE Nodes Edges
  • SET REMOVE Properties
  • DELETE Detach DELETE
  • RETURN WITH WHERE
  • Order BY Limit Skip
  • Order BY Nulls First Last
  • UNWIND
  • Aggregate Functions
  • OPTIONAL MATCH
  • Variable Length Paths
  • Label OR AND NOT Expressions
  • Label Wildcard
  • Quantified Path Sugar
  • Path Modes Walk Trail Simple Acyclic
  • Shortest Path Variants
  • IS Labeled Predicate
  • Element ID Function
  • IS Type Predicate
  • Binary Literals
  • Line Comments Solidus
  • Line Comments Minus
  • GQLSTATUS Result Codes
  • GQL Error Code Mapping
  • Transaction Control Syntax
  • SET Session
  • Conditional Execution WHEN THEN ELSE
  • RETURN NEXT Pipeline
  • Primary Key Constraint
  • Unique Constraint
  • Deterministic MERGE Via PK
  • Undirected Edge MATCH
  • Cast Type Conversion
  • GQL Directories
  • Multiple Labels Per Node
  • GQL Flagger
  • NEXT Linear Composition
  • Cardinality Function
  • INT64 BIGINT Type Names
  • FLOAT64 Double Type Names
  • Log10 Log2 Functions
  • Trim Leading Trailing Both
  • FILTER Clause
  • LET Statement
  • Group BY Explicit
  • EXCEPT SET Operations
  • INTERSECT SET Operations
  • ALL Different Predicate
  • Same Predicate
  • Property Exists Function
  • Path Variable Binding
  • USE Graph Clause
  • FOR IN List
  • Typed Temporal Literals
  • Session SET Value Params
  • Typed List Annotations
  • arcflow.cosine() function
  • arcflow.embed() function
  • arcflow.similar() procedure
  • arcflow.graphrag() procedure
  • ArcFlow Extensions
  • LIVE Queries
  • Triggered Write-Back Views
  • Evidence Algebra
  • Relationship Skills
  • AI Function Namespace
  • Graph Embedding Algorithms
  • ASOF JOIN
  • Durable Workflows
  • Incremental Z-Set Engine
  • GPU GraphBLAS
  • Triggers
  • HNSW Vector Index
  • Extensions Moat

CLI

arcflow adds world model intelligence to the command line. The way grep searches text and find searches files, arcflow searches, transforms, and reasons over operational world models — at filesystem speed, with structured JSON output that pipes into any workflow.

# Create a graph, query it, get JSON — one line
echo 'MATCH (n) RETURN count(*)' | arcflow --data-dir ./graph --json
 
# Pipe results to jq
arcflow --data-dir ./graph --exec schema.cypher --json | jq '.rows[].name'
 
# Watch a directory — auto-execute queries as agents write them
arcflow --data-dir ./graph --watch queries/ --output-dir results/

For AI coding agents, arcflow is a tool in the same category as grep, find, ls, and jq — a command-line primitive that processes data and returns structured results. The agent doesn't need MCP, WebSocket, or any protocol. It calls a CLI command and reads the output. Zero overhead.


Agent Tooling#

As Fast as grep#

An agent calling arcflow has the same performance characteristics as calling grep or find:

# grep searches text
grep -r "class AuthService" src/
 
# arcflow searches a world model
arcflow --data-dir ./graph --exec "MATCH (c:Crate)-[:DEPENDS_ON]->(d) RETURN c.name, d.name" --json

Both are single-process CLI calls. Both return structured output. Both complete in milliseconds. No server startup. No connection handshake. No token overhead.

Structured Output for Agents#

Every command supports --json for machine-readable output:

arcflow --data-dir ./graph --exec "MATCH (n) RETURN count(*)" --json
{"columns":["count(*)"],"rows":[{"count(*)":"10234"}],"count":1}

Deterministic exit codes:

  • 0 — success
  • 1 — query error (syntax, missing label)
  • 2 — system error (file not found, permission denied)
  • 3 — validation error (constraint violation)

Structured errors with recovery hints:

{"ok":false,"code":"PARSE_FAILED","message":"Unknown keyword 'METCH'","recovery_suggestion":"Did you mean MATCH?"}

Snapshot-Pinned Reads#

Every CLI result envelope carries a __snapshot field — the URI of the snapshot the query observed:

arcflow query "MATCH (n) RETURN count(*)" --json
# {"__snapshot":"arcflow://snapshot/9c3b…","columns":[...],"rows":[...]}

Pin a query to a historical snapshot:

arcflow query "MATCH (e:Entity {id: $id}) RETURN e._confidence" \
  --param id=unit-01 \
  --at-snapshot arcflow://snapshot/9c3b…

arcflow rerun is a thin wrapper that always pins:

arcflow rerun --snapshot arcflow://snapshot/9c3b… --query "MATCH (n) RETURN count(*)"

See Snapshot-Pinned Reads for the full provenance story.

Project the World Model to Files#

Write the current snapshot to a directory tree any Unix tool can read:

arcflow project ./world-model --json
# {"snapshot_uri":"arcflow://snapshot/9c3b…","node_count":1248,"edge_count":5821,"layout_version":1}

Two projections of the same snapshot are byte-identical. See Filesystem Projection for the agent-grep workflow.

Batch Execution#

Execute an entire directory of queries in one call:

arcflow --data-dir ./graph --exec-dir queries/ --output-dir results/ --json

One process. N queries. N result files. The agent writes .cypher files, calls the CLI once, reads .json results.

Watch Mode#

For interactive agent sessions, the CLI watches a directory and auto-executes queries as they appear:

arcflow --data-dir ./graph --watch queries/ --output-dir results/

The agent writes a file → the result appears within milliseconds. No polling. No protocol.


Interactive REPL#

For human developers, arcflow starts an interactive REPL:

arcflow --data-dir ./my-graph

Commands:

  • :help — command reference
  • :status — node/relationship counts
  • :schema — labels, types, indexes
  • :demo — load sample graph
  • :bench — run performance benchmark
  • :dump — export graph as JSON
  • :quit — exit

See REPL Commands for the full command reference.


Server Modes#

Add a flag to serve the same engine over the network:

arcflow --data-dir ./graph --pg 5432       # PostgreSQL wire protocol
arcflow --data-dir ./graph --serve 7687    # TCP
arcflow --data-dir ./graph --http 8080     # REST API
arcflow --data-dir ./graph --ws 7688       # WebSocket subscriptions
arcflow-mcp --data-dir ./graph             # MCP (cloud chat UIs)

Run all servers concurrently on the same graph store:

arcflow --pg 5432 --serve 7687 --http 8080 --data-dir ./graph

Same engine. Same queries. Same data. The CLI is the primary interface; server modes are for when you need network access. The --pg flag lets any PostgreSQL client (psql, pgAdmin, Grafana, psycopg2, node-postgres) connect and run WorldCypher queries transparently.

Authentication#

The HTTP and WebSocket servers support JWT authentication:

arcflow --http 8080 --auth jwt --jwt-secret my-secret --jwt-issuer https://auth.example.com

API key auth for simple cases:

arcflow --http 8080 --api-key my-api-key

Multi-Workspace Tenancy#

Serve isolated graph stores for multiple tenants in one process:

arcflow --http 8080 --multi-workspace 50

Each tenant gets their own graph store, WAL, and standing queries at /workspaces/{id}/. Zero data leakage between tenants. Create workspaces via the HTTP API or the --multi-workspace flag to pre-allocate slots.


Validation#

Dry-run query validation without executing mutations:

arcflow --validate "MATCH (n:Person) RETURN n.name"
# → {"ok": true, "plan": "NodeScan > Filter > Return"}
 
arcflow --validate "METCH (n) RETURN n"
# → {"ok": false, "code": "PARSE_FAILED", "suggestion": "Did you mean MATCH?"}

Useful in CI to validate query files before deployment.


Flywheel Suite#

Evidence-based scoring and gating for agent workflows:

# Execute queries and collect timing + evidence artifacts
arcflow run queries/pagerank.cypher queries/community.cypher
 
# Score results with percentile analysis
arcflow score queries/pagerank.cypher
 
# Gate with pass/fail verdict (use in CI)
arcflow gate queries/critical.cypher
# Exit code 0 = pass, 1 = fail
 
# Compare against a baseline
arcflow compare queries/pagerank.cypher --baseline results/baseline.json

The flywheel suite is designed for AI agents that need to verify their own outputs — run a query, score it against historical evidence, gate on quality thresholds.


GPU Commands#

arcflow gpu status     # Show available GPU backends (CUDA, Metal)
arcflow gpu install    # Download GPU acceleration libraries

Sync Commands#

arcflow sync status    # Pending mutations and high-water mark
arcflow sync push      # Export pending mutations as JSON to stdout
arcflow sync pull      # Import mutations from stdin JSON
arcflow sync snapshot  # Export full graph snapshot to stdout
arcflow sync restore   # Import snapshot from stdin
arcflow sync health    # Mesh node status
arcflow sync cloud     # Push + pull via ArcFlow Cloud (requires login)

Agent Context Introspection#

Full engine state dump for AI agents:

arcflow agent-context synth --json

Returns all labels, relationship types, algorithm capabilities, observation classes, clock domains, and available procedures in a single structured JSON. Agents use this to understand the schema and available operations without running individual CALL db.* queries.


Authentication#

arcflow login                    # Authenticate with oz.com/world
arcflow login --token TOKEN      # Headless / CI login
arcflow logout                   # Clear stored credentials
arcflow whoami                   # Show current identity
arcflow status                   # Account + engine status

Self-Update#

ArcFlow can update itself:

arcflow upgrade            # Check for updates and install
arcflow upgrade --check    # Check only, don't install

The REPL also checks for updates in the background on startup (cached for 24h). Opt out with ARCFLOW_NO_UPDATE_CHECK=1.

Updates use atomic binary replacement with automatic rollback on failure.


Sections#

  • REPL Commands — interactive query session and meta-commands
  • Snapshot & Restore — graph persistence and migration
  • Filesystem Projection — arcflow project writes a snapshot as a directory tree
  • Plugin Management — arcflow plugin install/uninstall/list/verify
  • Agent Governance — receipts, hooks, and the agent verification state machine

See Also#

  • Agent-Native Database — why CLI-first beats MCP for shell agents; filesystem workspace patterns
  • ArcFlow for Coding Agents — structured errors, batch execution, checkpointing
  • Installation — binary, npm, pip, cargo, and WASM install paths
  • Snapshot-Pinned Reads — --at-snapshot, arcflow rerun, and __snapshot provenance
Try it
Open ↗⌘↵ to run
Loading engine…