Air — Communications Mesh
Air is a real-time messaging layer for your agents, services, and applications. It lets you publish and subscribe to topics, enabling your systems to communicate with each other through a simple HTTP API.
Why Air?
When building AI-powered applications, your agents need a way to communicate — with each other, with your backend services, and with external systems. Air provides:
- Topic-based messaging — Publish messages to topics and subscribe to receive them in real time
- Real-time delivery — Messages are delivered instantly to connected subscribers
- Topic overview — See all your active topics and their activity in the portal
- Multi-tenant isolation — Each organization's messaging is fully isolated
How It Works
Agent A ──publish──→ Air (topic) ──deliver──→ Agent B
──deliver──→ Agent C- Your agents publish messages to named topics via the Air API
- Messages are delivered in real time to all subscribers of that topic
- You can see an overview of your topics and their activity in the portal
TIP
Air is the messaging layer. If you're looking to collect and query logs, metrics, and traces, see Observability — which uses Air for ingestion but stores telemetry data durably for SQL querying.
Quick Start
Publish a message
bash
curl -X POST https://air.nextepoch.cloud/v1/ingest/messages \
-H "Authorization: Bearer <your-jwt-token>" \
-H "Content-Type: application/json" \
-d '{
"entries": [
{
"timestamp": "2025-01-15T10:30:00Z",
"message": "task_complete",
"attributes": {
"agent": "data-processor",
"task_id": "task_42",
"result": "success"
}
}
]
}'Publish an event
bash
curl -X POST https://air.nextepoch.cloud/v1/ingest/events \
-H "Authorization: Bearer <your-jwt-token>" \
-H "Content-Type: application/json" \
-d '{
"entries": [
{
"timestamp": "2025-01-15T10:30:00Z",
"name": "workflow_started",
"attributes": {
"workflow": "data-pipeline",
"triggered_by": "scheduler"
}
}
]
}'Viewing Topics in the Portal
The portal shows an overview of your active topics, including:
- Topic names and subscriber count
- Recent message activity
- Message throughput
Navigate to the Air section in the portal to view your topics.
Guides
- Sending Messages — Detailed guide on publishing messages and events
- API Reference — Full endpoint documentation
Next Steps
- Learn about Observability for durable telemetry storage and SQL querying