Slung

Write real-time functions that compute over temporal data streams with full historical context.
Homepage · Documentation · Roadmap

Warning

This project is currently WIP and is no where near ready for production use.

Roadmap

#	Objective	Status
1	Stream ingestion [#1]	📅
2	TSM tree [#2]	⚠️
3	Parallel data query engine [#3]	📅
4	Wasm execution	📅
5	Write-ahead log (WAL)	🚫
6	WebTransport	🚫

• ✅ Done: Feature is implemented and verified.
• ⚠️ In-progress: Active development or stabilization phase.
• 📅 Planned: Queued for development; architecture defined.
• 🚫 Deferred: Not currently in scope for the current milestone.

Stream ingestion

• Non-blocking websocket channel [#4]
• Stream rx/tx pool manager [#5]

TSM tree

• Skip list
• Columnar table
• Bloom filter

Parallel query engine

• Query DSL [#6]
• Async iterator [#7]

Wasm execution

• Host functions template
• Life cycle manager