Pipelines + Realtime

Pipelines

Athena supports config-driven and inline pipelines:

• POST /pipelines
• POST /pipelines/simulate
• GET /pipelines/templates

Each run can define source, transform, and sink steps.

Simulate Example

curl -X POST "http://localhost:4052/pipelines/simulate" \
  -H "content-type: application/json" \
  -H "x-athena-client: analytics" \
  -d '{
    "source": { "table_name": "events", "limit": 500 },
    "transform": {
      "group_by": "organization_id",
      "aggregation_column": "amount_cents",
      "aggregation_strategy": "sum"
    }
  }'

Deferred Gateway Requests

Use deferred queue routes to inspect and requeue async jobs:

• GET /gateway/deferred/{request_id}
• POST /gateway/deferred/{request_id}/requeue

WebSocket Gateway

Athena exposes WebSocket gateway contract metadata and spec:

• GET /wss/info
• GET /openapi-wss.yaml

WebSocket actions mirror gateway operations:

• gateway.fetch
• gateway.insert
• gateway.update
• gateway.delete
• gateway.query

Operation Links

• POST /pipelines
• POST /pipelines/simulate
• GET /pipelines/templates
• GET /gateway/deferred/:request_id
• POST /gateway/deferred/:request_id/requeue
• GET /wss/info
• GET /wss/gateway