BussDCC Framework
bussdcc-framework is an opinionated runtime and tooling layer built on top of bussdcc.
It provides the components most real systems need:
- runtime orchestration
- event sinks and replay
- JSONL event logging
- a lightweight web interface
- system identity discovery
- deterministic replay of recorded event streams
The framework keeps the bussdcc kernel small while providing a practical foundation for building complete systems.
Architecture
Application
↓
bussdcc-framework
↓
bussdcc
bussdcc (kernel)
The core provides the minimal primitives:
- messages
- events
- processes
- services
- runtime
- state
- clocks
- event buses
bussdcc-framework
The framework adds system-level capabilities:
- structured event logging
- replay runtime
- web interface
- event sinks
- operational services
- application scaffolding
Features
Runtime
Extended runtime with event sinks and framework lifecycle messages.
from bussdcc_framework.runtime import Runtime
runtime = Runtime()
Features:
- event sink pipeline
- framework lifecycle messages
- graceful shutdown handling
- replay support
Event Logging (JSONL)
Built-in JSONL logging for deterministic replay and auditing.
from bussdcc_framework.io.jsonl import JsonlSink
runtime.add_sink(JsonlSink("./events"))
Logs are segmented by time:
events/
2026-03-09/
12-00-00.jsonl
12-10-00.jsonl
Each line contains a structured event:
{
"time":"2026-03-09T12:00:01.735301+00:00",
"type":"bussdcc_framework.message.system:SystemIdentityEvent",
"data":{ ... }
}
Event Replay
Replay previously recorded event streams.
from bussdcc_framework.runtime import ReplayRuntime
from bussdcc_framework.io.jsonl import JsonlSource
runtime = ReplayRuntime(speed=1.0)
runtime.add_source(JsonlSource("./events"))
This allows:
- deterministic testing
- system simulation
- historical debugging
Web Interface
A lightweight Flask + Socket.IO interface for system control and monitoring.
from bussdcc_framework.interface.web import WebInterface
runtime.add_process(
WebInterface(host="0.0.0.0", port=5000)
)
Custom routes can be registered:
class MyWeb(WebInterface):
def register_routes(self, app, ctx):
@app.route("/")
def index():
return "Hello World"
Inside Flask routes you can emit BussDCC messages:
from bussdcc_framework.interface.web import emit
emit(MyMessage())
Console Logging
Simple JSON event output for development.
from bussdcc_framework.io.console import ConsoleSink
runtime.add_sink(ConsoleSink())
Example output:
{"time":"2026-03-09T12:00:01.722504+00:00","type":"bussdcc_framework.message.framework:FrameworkBooted","data":{"version":"0.1.0"}}
System Identity Service
Discovers system metadata at runtime:
- hostname
- hardware model
- CPU serial
from bussdcc_framework.service import SystemIdentityService
runtime.add_service(SystemIdentityService())
This emits a SystemIdentityEvent and stores it in runtime state.
Example
Minimal application:
from bussdcc_framework.runtime import Runtime
from bussdcc_framework.io.console import ConsoleSink
from bussdcc_framework.service import SystemIdentityService
runtime = Runtime()
runtime.add_sink(ConsoleSink())
runtime.add_service(SystemIdentityService())
runtime.boot()
runtime.run()
Design Goals
Deterministic systems
All behavior flows through events that can be logged and replayed.
Strong typing
All messages are typed dataclasses.
Operational visibility
Event streams are easily captured and analyzed.
Replayable execution
Recorded systems can be replayed exactly for debugging and simulation.
Small core
The bussdcc kernel stays minimal while the framework provides practical tooling.
Installation
pip install bussdcc-framework
Related Projects
- bussdcc – event-driven systems kernel
- bussdcc-hardware – hardware device integrations
License
MIT License
1 maintainer
Metadata
1 maintainer
Release files for bussdcc-framework 0.46.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| bussdcc_framework-0.46.0.tar.gz | 188.4 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| bussdcc_framework-0.46.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 382.0 kB
Release files / bussdcc_framework-0.46.0.tar.gz
| Download URL | bussdcc_framework-0.46.0.tar.gz |
|---|---|
| Size | 188.4 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
4c41f3c8d08f30ffd106bb7b534ddfcbdeaf3789a5a9ee66fcc11e9e1c0a3017
|
|
BLAKE2b-256 checksum How to use checksums |
26105c7462d21b3bb0b002642cf4be7132e2453f345e148458174e5dc15db4cf
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/6.2.0 CPython/3.12.13
|
Release files / bussdcc_framework-0.46.0-py3-none-any.whl
| Download URL | bussdcc_framework-0.46.0-py3-none-any.whl |
|---|---|
| Size | 193.7 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
dc09224450b0f688911361082180b6abc049ad7ad6a576d63021c8b7380605b1
|
|
BLAKE2b-256 checksum How to use checksums |
fa6835ffb65b7a0295c7767ae67497b6439040985c193b8c0eec5056641ec78a
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
twine/6.2.0 CPython/3.12.13
|
