Expand description
Myko server runtime — WebSocket, durable event backends, peer federation.
This crate contains the tokio-dependent parts of the Myko server:
CellServer— server lifecycle (durable catch-up init, WS accept loop)postgres— PostgreSQL producer/consumer (event-table + LISTEN/NOTIFY)ws_handler— WebSocket connection handlingpeer_registry— federation with other serversmcp— Model Context Protocol server
Tokio-free server types (CellServerCtx, HandlerRegistry, etc.) live in myko::server.
Modules§
- client_
registry - Global client registry for sending messages to connected WebSocket clients.
- history_
replay - Trait for replaying persisted events into a temporary store.
- mcp
- MCP (Model Context Protocol) server module for Myko.
- peer_
registry - Peer registry for the cell-based server.
- persister
- Trait for persisting events to a durable store.
- postgres
- PostgreSQL producer and consumer for the cell-based server.
- ws_
handler - WebSocket handler for the cell-based server.
Structs§
- Blackhole
Persister - No-op persister that intentionally drops all events for selected entity types.
- Cell
Server - Cell-based Myko server.
- Cell
Server Builder - Builder for creating a CellServer.
- Cell
Server Config - Cell-based Myko server configuration.
- Cell
Server Ctx - Context providing capabilities to server modules.
- Client
Session - A WebSocket client session that manages subscriptions.
- Handler
Registry - Registry of all handlers for the cell-based server.
- Null
Persister - No-op persister for in-memory-only operation (dev mode).
- Pending
Query Response - Persist
Error - Error returned when event persistence fails.
- Persist
Health - Shared health state for a persister, readable from any thread.
- Persister
Router - Resolves persisters by entity type using:
- Relationship
Manager - Cell-based RelationshipManager for handling entity relationship cascades.
Traits§
- History
Replay Provider - Provider for replaying historical events into a temporary StoreRegistry.
- Persister
- Trait for persisting events to a durable store.
- WsWriter
- Trait for sending WebSocket messages.
Functions§
- client_
registry - Get the global client registry.
- init_
client_ registry - Initialize the global client registry.
- message_
to_ json - Serialize a MykoMessage to JSON.
- message_
to_ msgpack - Serialize a MykoMessage to MessagePack bytes.
- try_
client_ registry - Try to get the global client registry.