Composable pipelines for backpressure economics

Browse recipes. Fork them. Simulate backpressure routing in your browser. Deploy to Base with one CLI command.

Recipes

View all →

Decentralized Log Router

infrastructure

Log ingestion where collector nodes declare capacity. Overwhelmed nodes reroute streams to nodes with spare capacity. Streaming payments compensate operators.

log-ingest×2
→
route-and-store×2
→
delivery-confirm×1
CapacityRegistryBackpressurePoolPricingCurveEscrowBuffer+3
advanced

LLM Ensemble (capacity-weighted)

ai

Route completions across multiple model runners; weights follow spare capacity and price.

prompt-to-tokens×3
CapacityRegistryBackpressurePoolPricingCurveEscrowBuffer+2
intermediate

Nostr Relay Fanout with Congestion Pricing

nostr

Publish/subscribe event distribution across Nostr relays. Overloaded relays shed subscriptions to relays with spare capacity.

event-ingest×2
→
relay-fanout×2
CapacityRegistryBackpressurePoolPricingCurveCompletionTracker
intermediate

Open Source Revenue Splitter

general

Stream incoming payments to contributors based on declared availability. Away maintainers auto-reroute their share to active contributors.

payment-ingest×3
CapacityRegistryBackpressurePoolEscrowBuffer
beginner

Sport Sponsorship Streamer

general

Fan and brand micropayments stream to athletes. Overfunded recipients auto-reroute new sponsorships to underfunded participants.

sponsorship-ingest×2
→
engagement-verify×1
CapacityRegistryBackpressurePoolPricingCurveEscrowBuffer
beginner

Atomic patterns

View all →

CapacityRegistry attestation

CapacityRegistry

EIP-712 signing flow for declaring spare capacity. Covers the typed data structure, signing code, and on-chain registration call.

beginner

CompletionTracker SLO verification

CompletionTracker

Define SLOs (latency, completion rate), track completions, and trigger penalties on violation. Verification flow end-to-end.

advanced

OffchainAggregator telemetry loop

OffchainAggregator

Collect runtime metrics off-chain, aggregate them, and push updated capacity attestations on-chain. Aggregation logic and attestation refresh cycle.

advanced

PricingCurve tuning

PricingCurve

Interactive visualization of pricing curve parameters. Adjust base price, k, and alpha to see the resulting price curve as utilization goes from 0 to 100%.

intermediate

StakeManager bond/slash lifecycle

StakeManager

Full lifecycle: bonding tokens, operating, getting slashed (3x penalty), and withdrawing. Contract calls and state transitions.

intermediate

Superfluid GDA streaming

EscrowBuffer

Initialize a streaming payment via Superfluid General Distribution Agreement. Setup, flow rate calculation, and pool connection.

intermediate