Run YAML decisions directly on incoming event streams.

BlazeRules evaluates your rules at the first layer of data flow, so applications can approve, block, review, route, or suppress events before teams build full filtering pipelines around them.

5.8M Peak direct Arrow rec/s
2.89M Peak HTTP Arrow rec/s
6.1 GiB/s Peak HTTP Arrow input rate
Live BlazeRules dashboard showing evaluation rate, input throughput, skipped rows, an event timeline, and decision distribution
Live HTTP ingestion with evaluation rate, input throughput, skipped rows, and custom decision labels.

Start with the interface you need.

Use the Python SDK inside your app, or download a native CLI build for local files, agents, and shell workflows.

terminal

Python SDK

Evaluate JSON, NDJSON, or Arrow batches in-process.

pip install blazerules
deployed_code

Native CLI

Download a local binary for shell and agent workflows.

Stop paying per record.

Instead of pushing every raw event into a warehouse, stream processor, or custom filter service, BlazeRules compiles the rule set once and evaluates batches as projected columns.

Standard Row Engine

MEMORY Scattered object states
EXECUTION Nested pointer chasing
PARALLELISM Thread-locking callbacks
CACHE MISS RISK

BlazeRules Vector

MEMORY Contiguous Columnar Buffers
EXECUTION SIMD Masked Evaluation
PARALLELISM Lock-free Batch Partitioning
CACHELINE OPTIMIZED

The Data Plane Pipeline

Rules, windows, lookups, model scores, and routing outputs stay in one batch-first decision path.

STEP 01
input
Source Polling

Reusable batch buffers

STEP 02
dataset
Batching

Transposing Rows to Columns

STEP 03
settings_suggest
Normalization

Schema enforcement

STEP 04
memory
SIMD Kernel

Vector rule execution

STEP 05
list_alt
Aggregation

Window state persistence

STEP 06
send
Egress Dispatch

Grouped decisions

Features

Time-series operations, lookup files from S3, nested fields, ML model scoring, and hot reloads are all built into the engine.

history

Velocity Windows

Calculate rolling counters and sums over sliding windows without an external database.

search

Lookup Sets

CSV-backed string, integer, and IPv4 CIDR lookup sets compiled into fast membership checks.

account_tree

Nested Payloads

Nested dotted fields and array_any rules project only referenced payload paths into columns.

neurology

ONNX Integration

Optional ONNX model_score rules can add model outputs as decision signals when enabled.

refresh

Hot Reload

Compile and validate a candidate ruleset, then swap it between batches without interrupting the active engine.

fork_right

Grouped Routing

Expose decisions and grouped row indices so callers can bulk-route APPROVE, REVIEW, BLOCK, or custom outcomes.

Local Mac Stress Matrix

Benchmarked locally against a large nested rules corpus. Throughput is reported as evaluated events/sec and input GiB/s. Engine-side metrics for comparison

Configuration

Rules: 1,047
Payloads: nested JSON/Arrow/Avro/Protobuf
Host: local Mac 36GB/12-core

Engine Input Throughput (GiB/s)

JSON 15KB+ ~3.0 GiB/s · ~211K rec/s
Arrow IPC peak ~3.1 GiB/s · ~654K rec/s
Avro median ~0.65 GiB/s · ~417K rec/s
Protobuf median ~0.48 GiB/s · ~427K rec/s

JSON Payload Width Sensitivity (GiB/s)

2KB
5KB
10KB
15KB+

Lower cost starts with fewer raw payloads.

Run decisions before SIEMs, warehouses, queues, and model calls. Routine events become compact decision rows. Records that need review can still keep the full payload.

Index
Fewer raw events
Store
Smaller payload trail
Review
Less queue noise
Before
Raw events everywhere

Full payloads enter every downstream system, whether or not the final decision is simple.

After
Decisions first

Emit approve, review, block, and DLQ records. Keep raw evidence only for events that need it.

The financial lever is simple: systems that bill by indexed GB, scanned data, or review volume see less input.

A rule engine data plane, not another stream processor or database.

BlazeRules is built for low-latency decision density. Unlike analytical engines or general-purpose stream processors, it optimizes for stateful rule evaluation over batches.

settings_input_component Transport Streams / CDC / Webhooks
bolt BlazeRules Real-time Decisions
database Storage Warehouse / SIEM
account_tree Workflows Case Management

BlazeRules sits between ingestion and persistence, where latency-sensitive decisions are made before storage and workflow systems receive the event.

BlazeRules Engine
Peripheral Systems

Capability Landscape

BlazeRules

Designed for fast, columnar rule evaluation over batches with persistent state and rule hot reload. It sits between the high-speed data plane and decision logic.

BRMS / decision suites

Strongest for authoring, governance, business policy modeling, and workflow integration. They are not optimized for raw high-throughput batch evaluation.

Stream processors

Best for distributed streaming, partitioned state, and event-time processing. They excel at large-scale stateful pipelines, not just single-node rule evaluation.

OLAP / SQL engines

Best for analytical queries, ad hoc reporting, joins, and broad SQL workloads where planner-powered query execution is the priority.

Rule throughput Decision latency Deploy footprint Ingest breadth Stream state Batch replay Rule governance Data locality Analytics depth Team workflow
BlazeRules BRMS Streams OLAP SaaS

Ready for a benchmark?

Run the benchmark harness against your current stack and compare throughput, latency, and payload sensitivity in your own environment.