Industrial Intelligence,
Unified.

import { ScadaClient } from '@omniscada/sdk';

// Create Edge Node Ingestion Client
const client = new ScadaClient({
  brokerUrl: 'mqtt://192.168.1.100:1883',
  groupId: 'PlantA',
  edgeNodeId: 'Line02-Robotics'
});

await client.connect();

// Subscribe to live tag updates from TelemetryBus
client.on('metric', (name, value) => {
  console.log(`[Telemetry] ${name} = ${value}`);
});

// Batch publish metrics
await client.publishBatch([
  { name: 'Reactor/Pressure_PSI', value: 142.8 },
  { name: 'Reactor/Valve_Open_Pct', value: 85.0 }
]);

use omni_scada_sdk::{OmniScadaClient, MetricValue, Result};

#[tokio::main]
async fn main() -> Result<()> {
    // Connect with zero-copy high performance encoder
    let mut client = OmniScadaClient::connect(
        "mqtt://192.168.1.100:1883",
        "PlantA",
        "CNC-Spindle-01"
    ).await?;

    // Sub-millisecond metric encoding and transmission
    client.publish_metric("Spindle/RPM", MetricValue::Float(12000.0)).await?;
    client.publish_metric("Spindle/Load_Pct", MetricValue::Float(44.5)).await?;

    Ok(())
}

using System.Collections.Generic;
using System.Threading.Tasks;
using OmniSCADA.SDK;

var client = new OmniScadaClient("mqtt://192.168.1.100:1883", "PlantA", "PLC_Station_04");
await client.ConnectAsync();

// Task-based asynchronous telemetry publishing
await client.PublishTelemetryAsync(new Dictionary<string, object> {
    ["Tank/Level_Liters"] = 4850.0,
    ["Pump/FlowRate_GPM"] = 120.4,
    ["Alarms/HighLevel"] = false
});

# Query live telemetry from Modbus/S7/OPC-UA bridge via REST API
curl -X GET http://localhost:9600/api/v1/metrics \
  -H "Accept: application/json"

# Response:
{
  "timestamp": "2026-08-28T00:00:00Z",
  "devices": [{
    "name": "Siemens_S7_1500",
    "protocol": "s7",
    "tags": { "DB1.DBD0": 1750.0, "DB1.DBX4.0": true }
  }, {
    "name": "Modbus_PowerMeter",
    "protocol": "modbus_tcp",
    "tags": { "Holding_40001": 480.2, "Holding_40002": 59.98 }
  }]
}