| Crates.io | hyperstack-server |
| lib.rs | hyperstack-server |
| version | 0.3.5 |
| created_at | 2026-01-09 05:40:32.662392+00 |
| updated_at | 2026-01-24 05:43:34.005488+00 |
| description | WebSocket server and projection handlers for HyperStack streaming pipelines |
| homepage | |
| repository | https://github.com/HyperTekOrg/hyperstack.git |
| max_upload_size | |
| id | 2031626 |
| size | 330,347 |
WebSocket server and projection handlers for HyperStack streaming pipelines.
This crate provides a builder API for creating HyperStack servers that:
[dependencies]
hyperstack-server = "0.2"
use hyperstack_server::{Server, Spec};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
Server::builder()
.spec(my_spec())
.websocket()
.bind("[::]:8877".parse()?)
.health_monitoring()
.start()
.await
}
use hyperstack_server::{Server, WebSocketConfig, HealthConfig};
use std::time::Duration;
Server::builder()
.spec(my_spec())
.websocket_config(WebSocketConfig {
bind_addr: "[::]:8877".into(),
max_clients: 1000,
message_queue_size: 100,
})
.health_config(HealthConfig::new()
.with_heartbeat_interval(Duration::from_secs(30))
.with_health_check_timeout(Duration::from_secs(10)))
.start()
.await
┌─────────────────────┐
│ Yellowstone gRPC │
└──────────┬──────────┘
│
▼
┌─────────────────────┐
│ Vixen Runtime │ ← Generated from IDL
└──────────┬──────────┘
│
▼
┌──────────────────────┐
│ HyperStack VM │ ← Processes bytecode
└──────────┬───────────┘
│
▼
┌──────────────────────┐
│ Projector │ ← Mutations → Frames
└──────────┬───────────┘
│
▼
┌──────────────────────┐
│ BusManager │ ← Pub/Sub routing
└──────────┬───────────┘
│
▼
┌──────────────────────┐
│ WebSocket Server │ ← Streams to clients
└──────────────────────┘
| Feature | Default | Description |
|---|---|---|
otel |
No | OpenTelemetry integration for metrics and distributed tracing |
Built-in health monitoring tracks stream connectivity and detects issues:
hyperstack-server/
├── src/
│ ├── lib.rs # Server & ServerBuilder API
│ ├── bus.rs # Event bus manager
│ ├── config.rs # Configuration types
│ ├── runtime.rs # Runtime orchestrator
│ ├── projector.rs # Mutation → Frame transformation
│ ├── health.rs # Health monitoring
│ ├── view/ # View registry & specs
│ └── websocket/ # WebSocket infrastructure
├── Cargo.toml
└── README.md
tokio - Async runtimetokio-tungstenite - WebSocket supportyellowstone-vixen - Yellowstone gRPC integrationhyperstack-interpreter - HyperStack VM and bytecodeApache-2.0