Industrial infrastructure

ULTRAMEGA S1

Always-on. Fault-tolerant. Free forever.
An industrial execution substrate with process isolation, real-time messaging, managed hosting, a full REST API with event streaming, and an MCP endpoint for AI integration.

Control C# / .NET Analytics Python Integration C++ / gRPC AI Agent MCP ... S1 Gateway REST API • WebSocket Events • SignalR Hub • Auth • RBAC S1 Platform (Hosting) Process Lifecycle • Port Allocation • Self-Healing • Health Monitoring Fault Isolation Failures never cascade Real-time IPC Sub-ms messaging Any Language gRPC / TCP / REST Self-Healing Three-layer resilience Install via NuGet: S1.Client • S1.Hosting • S1.Runtime
Overview

What is ULTRAMEGA S1?

ULTRAMEGA S1 is the execution substrate for industrial systems that demand continuous operation. It orchestrates independently developed modules (any language, any runtime) inside a type-safe, message-driven architecture with a full REST API, real-time event streaming, and managed process hosting.

Real-time control loops, high-rate test pipelines, cross-platform integrations: ULTRAMEGA S1 composes dependable systems instead of rebuilding infrastructure. Multi-step workflows with saga orchestration, multi-instance federation, scheduled execution, and persistent journaling are built into the substrate. A built-in MCP endpoint exposes 57 system tools to AI agents. Ship it as three NuGet packages. No configuration files, no installers.

Core capabilities

Production-grade from the ground up

Process Isolation

Each module runs in its own process with protected memory space. A fault in one component cannot cascade to the rest of the system. The hosting layer manages process lifecycle, port allocation, and automatic restart on failure.

Deep dive →

Real-time Messaging

Low-latency IPC bus with guaranteed message ordering. Sub-millisecond delivery for critical control signals. Typed messages with compile-time schema validation prevent integration errors before they reach production.

Deep dive →

REST API & Event Streaming

Full HTTP API across 17 controllers: modules, messages, discovery, config, health, metrics, pipelines, and more. WebSocket streams for real-time events. SignalR hub for module-specific message delivery.

Deep dive →

Self-Healing Architecture

Three-layer resilience: circuit breakers isolate failures at the communication boundary, resilient connections maintain gRPC links through transient faults, and process supervision restarts crashed modules with state recovery. Each layer operates independently so a single fault never escalates into a system-wide outage.

Deep dive →

Health & Observability

Five health endpoints (liveness, readiness, startup, detailed, aggregate) for integration with orchestrators and load balancers. Metrics snapshots, audit trails, and per-module health tracking across the entire substrate.

Deep dive →

Pipeline Orchestration

Define multi-stage processing pipelines through the API. Route data through sequences of modules with typed contracts at every stage boundary. Pipelines are defined, inspected, and executed through the API.

Deep dive →

Saga Orchestration

Multi-step workflows with automatic compensation on failure. Each saga tracks step progress, enforces concurrency limits, and guarantees correlation ID uniqueness. If a step fails, previously completed steps are rolled back through registered compensation handlers.

Deep dive →

Federation

Connect multiple S1 instances into a federated mesh. Messages route transparently across instance boundaries with endpoint validation and SSRF protection. Federation health monitoring tracks peer availability and enforces forwarding timeouts.

Deep dive →

Scheduled Execution

Cron-based task scheduling with persistent storage. Define recurring jobs that survive restarts. The scheduler integrates with the feature flag system for runtime kill-switches and supports bounded query pagination across all schedule stores.

Deep dive →

Content Routing

Route messages based on content fields, not just destination addresses. Define routing rules through the API that match message payloads and direct them to the appropriate modules. Add, remove, and update rules at runtime through the API without module restarts.

Deep dive →

Journal & Checkpoint

Persistent message journal with query and replay capabilities. Save and restore module state through the checkpoint API. Journal compaction runs automatically to manage storage growth, with structured metrics for monitoring retention and drop rates.

Deep dive →
Resilience

Self-Healing Architecture

Three independent layers that keep production running through hardware faults, network interruptions, and process crashes

Circuit Breakers

When a downstream module stops responding, the circuit opens to prevent request pileup and cascading timeouts. Calls fail fast with a clear status while the breaker periodically probes for recovery.

  • Protects inter-module communication
  • Configurable thresholds per module pair
  • State visible through health API
Deep dive →

Resilient Connections

Exponential backoff with jitter maintains gRPC channels through transient network faults. Connections re-establish automatically without operator intervention or message loss.

  • Protects gRPC and TCP transport links
  • Prevents reconnect storms
  • Connection state reported in real time
Deep dive →

Process Supervision

The hosting layer detects crashed processes, cleans up stale state, and restarts modules with their last known configuration. PID tracking and orphan detection prevent zombie processes from consuming resources.

  • Protects module process lifecycle
  • Rate-limited restarts
  • Checkpoint recovery on restart
Deep dive →
AI integration

Model Context Protocol (MCP)

Expose the substrate to AI agents through the Model Context Protocol

MCP Endpoint

The built-in MCP server exposes 57 system tools to AI agents. Manage modules, send messages, execute pipelines, query health, and control the substrate through the same standardized interface used by human operators.

Deep dive →

Capability-based Access Control

Modules declare capabilities using a resource:action model. RBAC gates which tools each session can invoke. Agents and operators see only the tools they are authorized to use.

Deep dive →

Session Management & Audit

Every MCP session is tracked with identity resolution. Every tool call is audit-logged for compliance. Session broadcasting enables coordination across multiple agents on the same substrate.

Deep dive →

Tool Schema Registry

Register custom tools with JSON Schema definitions. The schema registry enables agents to discover available operations, understand parameter types, and invoke them correctly without hardcoded knowledge.

Deep dive →
MCP tools

57 System Tools

Every tool is available to both AI agents and human operators through a single interface

Module Management

Register, start, stop, restart, and remove modules. Query state and health.

Deep dive →

Messaging

Send, batch, broadcast, and query-with-response. Typed messages with routing.

Deep dive →

Configuration

Read and update substrate config. Toggle feature flags at runtime.

Deep dive →

System Control

Shutdown, restart, system info, performance stats, and platform metadata.

Deep dive →

Cluster

Node management, leader election, service discovery, and distributed state.

Deep dive →

Pipelines

Create multi-stage processing pipelines and execute them with payloads.

Deep dive →

Service Discovery

Register service endpoints and resolve them by name.

Deep dive →

Type System

Register message types with schemas and query the type registry.

Deep dive →

Content Routing

Add, remove, and list content-based routing rules with predicate matching.

Deep dive →

Journal

Query message history, replay sequences, and inspect journal statistics.

Deep dive →

Checkpoint

Save, restore, and list module state checkpoints for crash recovery.

Deep dive →

Scheduling

Schedule messages for future or recurring delivery. Cancel and list jobs.

Deep dive →

Sagas

Start durable multi-step workflows with compensation. Track and cancel.

Deep dive →

Federation

Register remote substrate peers, manage federation links, and check peer health.

Deep dive →
Distribution

Ship as NuGet Packages

Three packages. No installers, no configuration files.

Ultramega.S1.Client

Typed .NET client for the Gateway REST API. Covers authentication, module management, messaging, discovery, config, health, metrics, and feature flags. Includes WebSocket event streaming and SignalR hub integration with auto-reconnect.

  • AddS1GatewayClient() for DI
  • AddS1EventStream() for WebSocket
  • AddS1HubClient() for SignalR

Ultramega.S1.Hosting

Managed process hosting for the S1 platform. Spawns and monitors Gateway and ModuleHost processes, handles port allocation, readiness detection, graceful shutdown, and crash recovery. Two modes: managed (owns processes) or external (connects to existing).

  • AddS1Platform() as IHostedService
  • Module registration API
  • Self-healing process supervision with circuit breakers

Ultramega.S1.Runtime.{rid}

Pre-built, self-contained executables for Gateway, ModuleHost, and McpServer. Content packages that land binaries directly in your output directory. No separate install step. No build-time compilation of S1 internals.

  • win-x64, linux-x64, linux-arm64
  • osx-arm64
  • Single-file executables, no dependencies
Integration

Module Integration

Two paths to integration

Native Modules (C# / .NET)

Maximum performance with direct SDK integration. Zero-copy message passing and native memory management. Modules declare capabilities and register through the hosting API with full lifecycle management.

  • Direct SDK integration via IModule
  • Zero-copy IPC
  • Capability declaration (resource:action model)
  • Managed by S1 Hosting process lifecycle

External Modules (Any Language)

Integrate existing systems via gRPC, TCP, or WebSocket. The ModuleHost bridges external processes to native IPC. Register through the REST API and receive real-time events over WebSocket.

  • C++, Python, MATLAB, LabVIEW
  • gRPC / TCP / WebSocket protocols
  • REST API for registration and discovery
  • Legacy system and protocol bridging
Applications

Use Cases

Where ULTRAMEGA S1 excels

Industrial Control Systems

Orchestrate control logic from multiple vendors. MATLAB models, LabVIEW drivers, Python robotics, and C++ algorithms working together in one system with process isolation and self-healing resilience.

Test & Measurement

High-rate test pipelines with real-time data acquisition. Coordinate test fixtures, vision systems, and quality databases in unified workflows. Pipeline orchestration routes data through measurement, analysis, and reporting stages.

Legacy Modernization

Wrap existing PLCs and SCADA systems with digital interfaces. Add modern analytics, remote monitoring, and AI capabilities to brownfield installations without disrupting operations.

HIL & Digital Twins

Hardware-in-the-loop simulation with real-time fidelity. Mix physical hardware with simulated components for testing and validation. Event streaming provides live visibility into every state transition.

Robotics & Automation

Multi-robot coordination with real-time sensor fusion. Path planning, autonomous navigation, and collaborative manipulation with sub-millisecond message delivery between control modules.

AI-Assisted Operations

Connect AI agents to the substrate through the built-in MCP endpoint. Agents use the same 57-tool interface as human operators to configure instruments, run test sequences, monitor results, and adapt.

REST surface

Gateway API

17 controllers, full REST coverage

Authentication

JWT login, token refresh, logout, password change, and token verification.

Deep dive →

Modules

Full lifecycle: register, start, stop, restart, delete. Plus health, logs, and external module support.

Deep dive →

Messages

Send single, typed, or batch messages. Query delivery status by message ID.

Deep dive →

Discovery

Register and resolve services. Load-balanced selection with round-robin strategy.

Deep dive →

Health

Liveness, readiness, and detailed health endpoints for load balancers and orchestrators.

Deep dive →

Configuration

Read full config or by section. Admin-only write access for runtime changes.

Deep dive →

Features

List all feature flags, check individual flags, enable and disable at runtime.

Deep dive →

Metrics

JSON and Prometheus formats. Drain diagnostics, CI build metrics, and security findings.

Deep dive →

Pipelines

Create, execute, inspect, and delete multi-stage processing pipelines.

Deep dive →

WebSocket

Real-time event and message streams. Connection info endpoint for clients.

Deep dive →

Types

Register and query message types, module states, and delivery guarantee enums.

Deep dive →

Diagnostics

System info and drain progress for debugging message processing bottlenecks.

Deep dive →
Resources

Documentation

Everything you need to get started

Technical Whitepaper

Architecture overview, performance characteristics, and the design decisions behind the message-driven microkernel.

Go to Downloads

SDK Reference

APIs, data contracts, lifecycle hooks, threading model, resilient connections, and code samples for native module development.

Go to Downloads

Hosting Packages Guide

Step-by-step adoption guide for S1.Client, S1.Hosting, and S1.Runtime NuGet packages. Includes migration checklist and DI patterns.

Go to Downloads

MCP Integration Guide

Connecting AI agents to S1. Tool registration, capability scanning, RBAC configuration, and session management.

Go to Downloads

Integration Examples

Practical walkthroughs for PLCs, SCADA, enterprise systems, and external module integration via gRPC and WebSocket.

Go to Downloads

Gateway API Reference

Complete REST API documentation for all 17 controllers. Request/response schemas, authentication, and WebSocket protocols.

Go to Downloads

Download ULTRAMEGA S1

Free forever, for any use, including commercial. Available as standalone runtime or as NuGet packages for .NET applications.