What is Expanso and how does it work?

Expanso is a managed platform for deploying intelligent data pipelines at the edge. It processes data where it's generated - reducing bandwidth, latency, and costs. You deploy lightweight agents on your infrastructure, build pipelines using our visual builder or YAML, and control everything from a central SaaS platform.

Can I run AI/ML models directly in my data pipelines?

Yes! Expanso supports running ONNX, TensorFlow Lite, and other models as native pipeline steps. Execute low-latency inference on streaming data, enrich events with model outputs (like risk scores), and make decisions at the edge without cloud round-trips.

How many pre-built components are available?

Expanso provides 200+ pre-built components including inputs (Kafka, HTTP, files), processors (transformations, filtering, PII masking, aggregations), and outputs (S3, Snowflake, Datadog, Splunk). Browse the complete catalog in our Component Reference.

Do I need to write code to build pipelines?

No - use our drag-and-drop visual pipeline builder to create sophisticated pipelines without code. For advanced use cases, you can also write pipelines in YAML or use the Bloblang transformation language for complex data mappings.

How does Expanso help with data governance and compliance?

Expanso includes built-in governance features: automatic PII detection and masking, policy enforcement at the edge, RBAC, SSO integration, and comprehensive audit trails. Mask sensitive data before it ever leaves your network.

types.StatusResponse

collected_atstring

Metadata

connection object

Edge-specific

health object

connected_sincestring

consecutive_failuresinteger

handshake_requiredboolean

last_errorstring

last_heartbeatstring

last_updatestring

start_timestring

statetypes.ConnectionState (string)

Possible values: [disconnected, connecting, connected]

urlstring

evaluations object

Orchestrator only

inflightinteger

pendinginteger

readyinteger

waitinginteger

executions object

Both

by_state object

property name*integer

totalinteger

identity object

Grouped Identity

namestring

network_idstring

node_idstring

organization_idstring

jobs object

Both

by_state object

property name*integer

latest_created_atstring

totalinteger

nodes object

Aggregate Counts

by_connection object

property name*integer

latest_join_timestring

totalinteger

resources object

Self Resource Usage

cpu_percentnumber

disk_percentnumber

goroutinesinteger

memory_percentnumber

runtime object

Runtime state (version, build, health status, uptime)

build object

commitstring

datestring

go_versionstring

platformstring

start_timestring

statustypes.HealthStatusType (string)

Possible values: [healthy, degraded, unhealthy]

uptime_secondsnumber

versionstring

store object

Store Metadata

db_size_bytesinteger

entities object

property name*integer

types.StatusResponse
{
  "collected_at": "string",
  "connection": {
    "health": {
      "connected_since": "string",
      "consecutive_failures": 0,
      "handshake_required": true,
      "last_error": "string",
      "last_heartbeat": "string",
      "last_update": "string",
      "start_time": "string",
      "state": "disconnected"
    },
    "url": "string"
  },
  "evaluations": {
    "inflight": 0,
    "pending": 0,
    "ready": 0,
    "waiting": 0
  },
  "executions": {
    "by_state": {},
    "total": 0
  },
  "identity": {
    "name": "string",
    "network_id": "string",
    "node_id": "string",
    "organization_id": "string"
  },
  "jobs": {
    "by_state": {},
    "latest_created_at": "string",
    "total": 0
  },
  "nodes": {
    "by_connection": {},
    "latest_join_time": "string",
    "total": 0
  },
  "resources": {
    "cpu_percent": 0,
    "disk_percent": 0,
    "goroutines": 0,
    "memory_percent": 0
  },
  "runtime": {
    "build": {
      "commit": "string",
      "date": "string",
      "go_version": "string",
      "platform": "string"
    },
    "start_time": "string",
    "status": "healthy",
    "uptime_seconds": 0,
    "version": "string"
  },
  "store": {
    "db_size_bytes": 0,
    "entities": {}
  }
}