Contact Sales Request Demo
Enterprise Engineering & Use Cases

Solutions & Platform Architecture

Discover how Uniflow's decoupled core engine and event-driven visual rule graphs solve complex protocol integration challenges across Industrial OT, Physical Security, IT Management, and Fleet Telemetry.

Deep Dive Engineering

Core Platform Architecture

Built for resilience, sub-millisecond execution, and total hardware decoupling based on Uniflow's technical specification.

Core Engine Spec

1. Decoupled Client-Service Architecture & IPC Pipeline

Uniflow isolates the visual control plane from background telemetry processing. The Windows WPF Client handles layout design and D3.js real-time dashboards, while the headless .NET Service (UniflowService) performs device polling, stream ingestion, and rule graph evaluation.

  • Dual NamedPipe IPC: NamedPipeIpcServer for synchronous topology control and PushPipeServer for asynchronous telemetry streaming
  • Sub-millisecond latency push pipeline streaming live SourceValuesChanged events and rule execution traces
  • Headless server capability: service runs continuously as an OS background worker without requiring active UI logins
Protocol Abstraction

2. Unified Protocol Ingestion & Dynamic ALC Plugins

The SourceManager core provides a protocol-agnostic abstraction layer. External communications adapters operate inside isolated AssemblyLoadContext (ALC) sandboxes, preventing driver panics from affecting system integrity.

  • Industrial OT: Modbus TCP Client/Server, OPC UA Client/Server, CAN Bus (Vector DBC parsing)
  • IT & Networking: SNMP v2c/v3 USM, HTTP REST Client, TCP Sockets
  • IoT & Telemetry: MQTT Pub/Sub with TLS and QoS levels
  • VMS & Physical Security: Deep native bindings for Avigilon ACC, Milestone XProtect, Hexagon 3D Lidar, SIA DC-09 Receiver/Agent, and ONVIF IP Cameras
Logic Processing

3. Event-Driven Visual Rule Engine (DAG Architecture)

Built on a Directed Acyclic Graph (DAG) model, Uniflow's logic engine evaluates strictly upon state mutations, completely eliminating high-overhead CPU polling loops.

  • Topological execution ordering ensuring upstream data inputs resolve prior to downstream node evaluation
  • Built-in Node Catalog: Math, Logic, Bitwise PLC packing, Cryptography (AES, RSA, SHA-2), and Array manipulation
  • Deterministic flow control: Multi-Condition If, Switch, Coalesce, and Guard nodes
State Management

4. In-Memory Registry & Disk State Persistence

Internal Storage Points act as intermediate memory registers (Boolean, Integer, Double, String) to chain multi-stage logic pipelines seamlessly across independent rule graphs.

  • Continuous background disk persistence for memory tags flagged as Persistent
  • Automatic state recovery upon server reboots or emergency power restoration
  • Thread-safe memory lock manager guaranteeing data consistency during concurrent updates
Performance & Safety

5. Multi-Threaded Concurrency & Resource Safeguards

Rules execute asynchronously across .NET ThreadPool workers with user-configurable priority scheduling (Level 10-100), ensuring critical safety rules take precedence during event storms.

  • Recursion Safety Breaker: Max Rule Trigger Depth clamp to prevent CPU loops
  • Hardware Flooding Protection: Configurable Debounce (ms) and Cooldown (ms) timers on physical write sinks
  • Priority Scheduler: Emergency alarm rules execute ahead of background telemetry logging
Data Serialization

6. Dynamic Schema & JSON Data Pipeline

Bridges legacy industrial hardware with modern cloud REST APIs via a built-in JSON Object Management engine.

  • Automatic parsing and schema flattening of deeply nested JSON API payloads
  • Visual JSONPath extraction and serialization nodes directly on the canvas
  • Seamless conversion between raw byte streams, JSON objects, and typed storage tags
High-Throughput Telemetry

IPC & Thread-Pool Dispatch Pipeline

Uniflow's headless service isolates hardware stream ingestion from presentation rendering. Asynchronous telemetry changes flow over a high-speed push pipe, while rules evaluate in parallel across optimized .NET ThreadPool workers.

NamedPipe IPC Sub-ms Latency Priority Scheduler Recursion Safety Clamp
// Uniflow Core Execution Loop
var pipeServer = new PushPipeServer("UniflowTelemetryPipe");
var engine = new RuleGraphEngine(priority: 100);

// Event-driven state mutation trigger
sourceManager.OnSourceValueChanged += (src, tag) => {
await engine.DispatchEventAsync(tag.PointId, tag.Value);
pipeServer.PushTelemetryAsync(src.Id, tag);
};

// ThreadPool: Evaluated parallel logic in 0.42ms
Real-World Deployments

Industry Solutions & Use Cases

Explore 9 concrete, field-tested deployment scenarios demonstrating Uniflow's versatility across industrial automation, security, IT infrastructure, and smart cities.

Industrial OT & SCADA #01

Industrial Automation & Legacy PLC Gateway

Connect shop floor Modbus TCP/RS-485 PLCs and variable frequency drives (VFDs) directly into enterprise OPC UA servers and cloud MES without replacing legacy machinery.

Protocol Stack:
Modbus TCP OPC UA Server Internal Storage
Impact: Unlocks Industry 4.0 telemetry streaming while preserving 100% of existing legacy hardware investments.
Physical Security & VMS #02

Perimeter Intrusion Defense & Automated Camera Tracking

Ingest real-time 3D spatial point-cloud alerts from Hexagon Lidar sensors along perimeter fences, immediately steering PTZ camera presets in Avigilon ACC and Milestone XProtect while locking facility gates via Modbus discrete relays.

Protocol Stack:
Hexagon 3D Lidar Avigilon ACC / Milestone Modbus Discrete IO
Impact: Delivers sub-second automated threat response with zero human intervention delay.
Smart Cities & Infrastructure #03

Smart City IoT Sensor Stream Consolidation

Consolidate thousands of distributed environmental sensors, air quality meters, and intelligent street lighting streams published over cellular MQTT brokers into a unified WebHook REST API for municipal GIS mapping.

Protocol Stack:
MQTT Pub/Sub WebHook Server JSON Utilities
Impact: Processes massive concurrent MQTT topics with dynamic JSONPath schema extraction.
IT & Enterprise Infrastructure #04

Data Center Environmental Monitoring & IT Alerting

Poll server rack thermal sensors, UPS power loads, and network switch bandwidth via SNMP v3 USM. Calculate rolling averages and trigger high-priority REST webhooks to PagerDuty/Slack when thermal thresholds breach safe limits.

Protocol Stack:
SNMP v3 USM HTTP REST Client System Timer
Impact: Secures enterprise server infrastructure with encrypted SNMP v3 monitoring and instant escalation.
Fleet Management & Heavy Machinery #05

Automotive Fleet Diagnostics & Machinery Telemetry

Intercept raw CAN Bus engine diagnostic frames on heavy mining equipment, parse custom Vector DBC files (.dbc) to compute engine temperatures and oil pressure KPIs, and relay diagnostic codes over TCP sockets.

Protocol Stack:
CAN Bus (Vector DBC) TCP Client Bitwise Nodes
Impact: Enables native vehicle telemetry parsing without requiring custom C# hardware drivers.
Central Station Monitoring #06

Central Alarm Station (SIA DC-09) Receiver & Escalation

Receive AES-256 encrypted SIA DC-09 alarm packets from physical intrusion panels (Bosch, DSC, Honeywell). Evaluate account codes and event types in real time, auto-acknowledging routine signals and escalating verified burglary alerts to police dispatch.

Protocol Stack:
SIA Receiver SIA Agent AES-256 Cryptography
Impact: Streamlines central monitoring station throughput with automated packet decryption and rule-based dispatch.
Building Automation & Energy #07

Building Management (BACnet/IP) & Energy Optimization

Interface commercial HVAC chillers and air handling units (AHUs) via BACnet/IP. Monitor occupancy sensors and air quality, automatically tuning temperature setpoints and activating energy-saving setback schedules.

Protocol Stack:
BACnet/IP Walker BACnet Agent Time Logic Nodes
Impact: Reduces commercial building energy expenditure through automated, occupancy-aware climate tuning.
Banking & Cash Logistics #08

Financial Vault & Cash Counting Machine Automation

Interface Kisan currency sorting machinery in bank vaults and armored transit depots. Ingest real-time bill counts, denomination distributions, and recognized bill serial numbers into SQL database records.

Protocol Stack:
KisanCM Hardware DB Link (SQL Server) File Access
Impact: Provides automated audit trails and real-time ledger synchronization for high-volume cash operations.
Security & Access Control #09

IP Camera AI Analytics & Access Control Integration

Ingest ONVIF camera motion triggers and License Plate Recognition (LPR) analytics. Cross-reference vehicle plates against PostgreSQL databases, automatically pulsing gate barrier relays and logging access timestamps.

Protocol Stack:
ONVIF Camera DB Link (PostgreSQL) Modbus Server
Impact: Fuses video analytics, relational databases, and physical barrier relays into a single visual rule graph.
Get Started Today

Ready to Architect Your Solution?

Explore our pre-built plugins or generate your own custom protocol adapters using the Uniflow SDK.

Explore Plugins Directory Read User Manual