Rust + Axum · Materialize · WebSocket

The messenger
for streaming data

Streaming SQL API gateway built on Materialize and Rust. Real-time data pipelines, WebSocket streaming, and event-driven architecture for the entire Colossal Capital platform.

View on GitHub

    // Subscribe to a streaming query

    let stream = hermes.subscribe({

      query: "SELECT * FROM crypto_trades WHERE volume > 1000",

      format: "json",

      transport: "websocket"

    });

    // → Real-time results as they happen

Features

Real-time data, delivered

Built in Rust with Axum for maximum performance. Sub-millisecond routing, zero-copy serialization, and backpressure-aware streaming.

Streaming SQL

Powered by Materialize for incremental view maintenance. Subscribe to SQL queries and get real-time updates as underlying data changes.

MaterializeIncremental

Rust + Axum

Built in Rust with the Axum web framework for maximum performance. Zero-cost abstractions, memory safety, and fearless concurrency.

RustAxumTokio

WebSocket Streaming

Native WebSocket support for real-time data delivery. Automatic reconnection, heartbeat monitoring, and backpressure-aware flow control.

WebSocketBackpressure

API Gateway

Unified API gateway for all Colossal Capital services. Authentication, rate limiting, request routing, and response transformation.

AuthRate Limiting

Event-Driven

Event sourcing and CQRS patterns. Kafka/RedPanda integration for durable event streams. Exactly-once processing guarantees.

KafkaCQRS

Multi-Protocol

REST, WebSocket, gRPC, and Server-Sent Events. Choose the right protocol for your use case. Automatic protocol negotiation.

RESTgRPCSSE

Architecture

Data flows through Hermes

Hermes sits between data sources and consumers, providing a unified streaming API for the entire platform.

Ingest

AckwardRoots streams market data, blockchain events, and user activity into RedPanda topics.

Process

Materialize maintains incremental views over streaming data. SQL queries produce real-time results.

Route

Hermes routes query results to consumers via WebSocket, REST, gRPC, or SSE with authentication and rate limiting.

Consume

Versal, Delt, Jacynth, and external clients consume real-time data through Hermes APIs.

Integrations

The backbone of the platform

Versal

Streams real-time market data to the trading terminal. Price feeds, order books, and trade execution.

Jacynth

Executes AI-generated streaming queries. Natural language → SQL → real-time results.

AckwardRoots

Ingests data from exchange APIs, blockchain nodes, and external sources into the streaming pipeline.

Delt

Powers real-time portfolio updates, price alerts, and trading notifications in the mobile app.

Pricing

Hermes is part of the Colossal Capital platform

Hermes pricing is managed through your Colossal Capital tier — Free, Pro, Ultra, Business, or Enterprise. Your tier controls streaming capacity, API limits, and feature gates.

Hermes is a $10/mo product add-on. Your CC tier (starting at $0/mo) sets your feature gates and capacity.

Coming Soon

The messengerfor streaming data

The messenger
for streaming data