StepLock
agent
Uyari
Health Uyari
- License — License: Apache-2.0
- Description — Repository has a description
- Active repo — Last push 0 days ago
- Low visibility — Only 6 GitHub stars
Code Gecti
- Code scan — Scanned 11 files during light audit, no dangerous patterns found
Permissions Gecti
- Permissions — No dangerous permissions requested
Bu listing icin henuz AI raporu yok.
A sub-millisecond, zero-allocation deterministic state proxy and Merkle DAG execution engine for multi-step AI agents. Features time-travel branching and dynamic TLS MITM packet virtualization via .NET 11 Pipelines.
README.md
StepLock
"Git for Live Agent Execution RAM & Network Traffic"
A sub-millisecond deterministic state proxy and Merkle DAG execution engine built for multi-step AI agent runtimes (LangGraph, Temporal, AutoGen, CrewAI, and Playwright).
Quickstart •
Why StepLock? •
Architecture •
Benchmarks •
Python SDK •
Enterprise Edition
The Problem StepLock Solves
When an AI agent runs an 8-step workflow (e.g. triaging a user, calling tools, executing database queries, and modifying state):
- Expensive & Non-Deterministic Retries: Step 7 fails. Re-running the agent from scratch burns tokens, hits API rate limits, and LLM jitter prevents you from reproducing the exact bug.
- Dangerous Mutation Side-Effects: Replaying a trace in staging might accidentally fire live Stripe charges, DB writes, or email dispatches.
- Zero Lineage Visibility: Traditional APMs give logs, but cannot time-travel, fork branches, or virtually replay network packets with exact token timing.
StepLock solves this by recording every execution step into a cryptographic Merkle DAG and virtualizing replays in sub-microseconds.
30-Second Quickstart
1. Launch the StepLock Proxy Gateway
# Using Docker
docker run -d -p 5000:5000 -v steplock_data:/data steplock/steplock:latest
# Or natively via .NET SDK
dotnet run --project src/DeterministicProxy.Gateway
StepLock is now active at http://localhost:5000 with the visual dashboard at http://localhost:5000/dashboard.
2. Install the Python SDK
pip install steplock
3. Wrap Your Agent Calls
from steplock import StepLockSession
import httpx
with StepLockSession(session_id="order-support-agent-01", branch_id="main") as session:
# Step 0: Call LLM
headers = session.get_headers(target_url="https://api.openai.com/v1/chat/completions")
session.advance_step()
res = httpx.post(
"http://localhost:5000",
headers=headers,
json={"model": "gpt-4o", "messages": [{"role": "user", "content": "Refund order #452"}]}
)
print("Step 0 Result:", res.json())
print("Served from Cache?", res.headers.get("X-Deterministic-Replay") == "true")
⚖️ Why StepLock?
| Feature | StepLock | LangSmith / Langfuse | VCR.py / Mocking | Charles / MITMProxy |
|---|---|---|---|---|
| Cryptographic Merkle DAG Chaining | ✅ Yes | ❌ No | ❌ No | ❌ No |
| Sub-Millisecond Zero-Copy Streaming Tap | ✅ Yes (337k chunks/s) | ❌ No (HTTP Hook) | ❌ No | ⚠️ High Overhead |
Time-Travel Execution Branching (fork) |
✅ Yes | ❌ No | ❌ No | ❌ No |
| Dynamic TLS MITM & WebSocket CDP Tap | ✅ Yes | ❌ No | ❌ No | ⚠️ Partial |
| On-Premise / 100% Free & Open Source Core | ✅ Yes (Apache 2.0) | ❌ Cloud / Heavy | ✅ Yes | ✅ Yes |
System Architecture
┌──────────────────────────────────────────────┐
│ Agent Orchestrator (Python / Node) │
│ LangGraph / Temporal / AutoGen / CrewAI │
└──────────────────────┬───────────────────────┘
│
HTTP/HTTPS & CDP │ Headers: X-Agent-Session-ID, X-Step-Index,
(Reverse / Forward) │ X-Execution-Mode, X-Branch-Id
▼
┌────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐
│ STEPLOCK CORE (.NET 11) │
│ │
│ ┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐ │
│ │ High-Performance Gateway & Dispatcher │ │
│ │ • Kestrel Edge Pipeline • Dynamic TLS MITM Tunnel (CONNECT) • WebSocket / CDP Frame Multiplexer │ │
│ └──────────────────────────────────────────────────────────┬───────────────────────────────────────────────────────┘ │
│ │ │
│ ▼ │
│ ┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐ │
│ │ Semantic Request Canonicalizer │ │
│ │ • Strips dynamic jitter (Timestamps, UUIDs) • Normalizes JSON payloads • Computes Merkle Hash │ │
│ └──────────────────────────────────────────────────────────┬───────────────────────────────────────────────────────┘ │
│ │ │
│ ┌────────────────────────────┴────────────────────────────┐ │
│ │ │ │
│ [Cache Hit / Replay Mode] [Cache Miss / Live Execution] │
│ ▼ ▼ │
│ ┌──────────────────────────────────────────────────────────┐ ┌────────────────────────────────────────────────────┐ │
│ │ Virtual Replay Engine │ │ Duplex Streaming Tap (Pipelines) │ │
│ │ • Instant 0x deterministic cache replay │ │ • Zero-copy forward to Agent Client │ │
│ │ • Cryptographic Merkle parent integrity check │ │ • Enqueues frame to Background WAL Channel │ │
│ └──────────────────────────────────────────────────────────┘ └─────────────────────────┬──────────────────────────┘ │
│ │ │
│ ▼ │
│ ┌──────────────────────────────────────────────────────────────────────────────────────────────────────────────────┐ │
│ │ High-Throughput State Persistence (CAS) │ │
│ │ • L1: In-Memory Ring Buffer & Hot CAS (2.5M ops/s) │ │
│ │ • L2: SQLite (WAL Mode) for Merkle DAG & Chunk BLOBs (19k frames/s) │ │
│ └──────────────────────────────────────────────────────────────────────────────────────────────────────────────────┘ │
└─────────────────────────────────────────────────────────────┬──────────────────────────────────────────────────────────┘
│
┌───────────────────────┴───────────────────────┐
▼ ▼
[ External LLM APIs ] [ Third-Party Tools & APIs ]
(OpenAI, Anthropic, Gemini) (Stripe, Postgres, GitHub)
Performance Benchmarks
Run benchmarks locally: dotnet run --project tests/DeterministicProxy.Benchmarks/DeterministicProxy.Benchmarks.csproj -c Release
| Benchmark Target | Throughput | p50 Latency | p95 Latency | p99 Latency | Alloc / Op |
|---|---|---|---|---|---|
| In-Memory Store (Write + Hash Lookup) | 2,544,115 op/s | 0.20 µs | 0.50 µs | 1.10 µs | 72 B |
Zero-Copy Streaming Tap (Pipelines) |
337,929 op/s | 2.30 µs | 4.20 µs | 9.30 µs | 1.6 KB |
| Merkle DAG Hashing (SHA-256 Chaining) | 143,251 op/s | 4.90 µs | 14.30 µs | 29.50 µs | 1.4 KB |
| PII & Secret Redaction Engine | 60,304 op/s | 14.00 µs | 30.70 µs | 55.40 µs | 2.0 KB |
| Semantic Request Canonicalizer (JSON) | 17,788 op/s | 44.30 µs | 127.90 µs | 218.90 µs | 12.1 KB |
| Dynamic TLS Leaf Cert Gen (ECDsa P-256) | 1,361 op/s | 446.40 µs | 2.23 ms | 2.74 ms | 17.5 KB |
| SQLite WAL Batch Persistence (50 Frames/Tx) | 381 op/s (19k frames/s) | 2.48 ms | 4.24 ms | 5.53 ms | 223.1 KB |
Python SDK (steplock)
Time-Travel Branching
from steplock import StepLockClient
client = StepLockClient("http://localhost:5000")
session_id = "customer-support-agent-01"
# 1. Fork a failed session from Step 2 into an experiment branch
client.fork_branch(
session_id=session_id,
source_branch="main",
new_branch="experiment-tweaked-prompt",
fork_at_step=2
)
# 2. Re-run agent on the new branch (Steps 0, 1, 2 served instantly from cache!)
# 3. Verify cryptographic Merkle chain integrity:
is_valid = client.verify_dag(session_id, "main")
print("Merkle DAG Integrity Valid:", is_valid)
StepLock Enterprise
StepLock is open-core. While the Community Edition provides the complete standalone proxy and Merkle DAG engine, StepLock Enterprise offers proprietary commercial modules for large-scale production agent fleets:
┌───────────────────────────────────────────────┐
│ STEPLOCK CORE │
│ (100% Open Source) │
└───────────────────────┬───────────────────────┘
│
┌───────────────────────┴───────────────────────┐
▼ ▼
[ OPEN SOURCE COMMUNITY CORE ] [ PROPRIETARY ENTERPRISE MODULES ]
Distributed under Apache 2.0 on GitHub Commercial License / Self-Hosted
• System.IO.Pipelines SSE Zero-Copy Tap • Branch Regression Diffing Engine
• Basic SQLite WAL Persistence Engine • L3 Cloud Archive Sync (S3/Blob format)
• Python Integration SDK (`steplock`) • Virtual Timing Replay (1x / 10x / Instant)
• Reverse / Forward Proxy MITM Gateway • Side-Effect Mutation Safety Barrier
• WebSocket CDP Duplex Interceptor • Multi-Tenancy & Usage Quota Management
• Merkle DAG Cryptographic Integrity • 24/7 SLA & Dedicated Architecture Support
👉 Read the full Enterprise Overview & Feature Breakdown or reach out to [email protected] for dedicated deployment assistance and licensing.
Contributing
Community contributions are welcome! Please see CONTRIBUTING.md for local setup, architecture overview, and PR guidelines.
License
StepLock Community Core is open-source software licensed under the Apache License 2.0.
Yorumlar (0)
Yorum birakmak icin giris yap.
Yorum birakSonuc bulunamadi