Flo

The Universal Distributed Runtime — Streams, KV, Queues, Time-Series, Actions, Workflows, and Stream Processing in a single binary. Thread-per-shard. Zero dependencies.

Quickstart

Get up and running in under a minute. Every primitive ships in one binary — no Kafka, no Redis, no separate workflow engine.

# Install via Homebrew
brew install floruntime/tap/flo
 
# Start the runtime
flo server start
 
# Store and read a value
flo kv set hello "world"
flo kv get hello

Primitives

Four data primitives — all backed by the same Raft-replicated log, shaped to fit different access patterns.

Hash-indexed key-value store with MVCC, TTL, CAS, and prefix scans.

Streams

Partitioned append-only logs with consumer groups and exactly-once delivery.

Queues

Priority queues with lease-based delivery, dead-letter support, and visibility timeouts.

Time-Series

Columnar storage with InfluxDB line protocol ingest and the FloQL query language.

Orchestration

Durable execution, multi-step workflows, and real-time stream processing — no separate cluster needed.

Actions

Durable execution of external logic with automatic retries, timeouts, and dead-letter handling.

Workers

Long-running consumers that poll for action invocations and report results.

Workflows

Multi-step orchestration with YAML definitions, signals, timers, and circuit breakers.

Stream Processing

Real-time stateful pipelines with windowing, checkpointing, watermarks, and built-in operators.

SDKs

Native clients with the full TCP wire protocol, plus drop-in Redis compatibility for KV.

Native Go client with full TCP protocol support.

Python

Async Python client with asyncio transport.

JavaScript

Node.js and browser clients with TCP and WebSocket transports.

Zig

Native Zig client for maximum performance.

Architecture

Understand how Flo works under the hood.

Architecture Overview

Thread-per-shard design, Raft consensus, and the Unified Append Log.

Storage Engine

Hot ring buffer → warm disk segments → cold remote storage.

Deployment

Docker, clustering, and production configuration.

Wire Protocol

Binary protocol spec with TLV encoding.

Edit this page on GitHub