Oracle SDK

One-line health check before each agent-to-agent transaction. Maintain a local in-memory cache updated by a persistent WebSocket stream — sub-millisecond gate decisions, no extra network hop per call.

Install

npmnpm install @inferenceflow/oracle-sdk
pippip install inferenceflow-oracle

Quick start (TypeScript)

import { OracleClient } from "@inferenceflow/oracle-sdk";

// Maintains a background WebSocket connection.
// Health states update in < 1ms from local cache.
const oracle = new OracleClient({ apiKey: process.env.ORACLE_API_KEY });

await oracle.connect();

// Before calling a model:
const health = oracle.check("openai-gpt4o");

if (health.state === "green") {
  const result = await callGPT4o(prompt);
} else if (health.state === "yellow") {
  // Route to fallback
  const result = await callClaude(prompt);
} else {
  // RED — skip spend, use cached response
  throw new Error("Primary provider down, skipping transaction");
}

Quick start (Python)

from inferenceflow import OracleClient

oracle = OracleClient(api_key=os.environ["ORACLE_API_KEY"])
oracle.connect()  # starts background WebSocket listener

# Inside your agent loop:
health = oracle.check("anthropic-claude35")

if health.state == "green":
    response = call_claude(prompt)
elif health.state == "yellow":
    response = call_fallback(prompt)
else:
    raise RuntimeError(f"Provider down: {health.provider_id}")

REST API

GET/api/oracle/health

Full health snapshot for all monitored providers.

GET/api/oracle/health/:provider_id

Single provider health object with latency percentiles and failure modes.

GET/api/oracle/stream

SSE stream. Emits a health_update event whenever a provider state changes.

Health object

{
  "provider_id": "openai-gpt4o",
  "name": "GPT-4o",
  "state": "green",           // "green" | "yellow" | "red"
  "uptime_24h": 99.87,        // percent
  "latency": {
    "p50": 312,               // milliseconds
    "p95": 720,
    "p99": 1240
  },
  "ttft": 187,                // time to first token, ms
  "error_rate": 0.12,         // percent
  "cost_per_1k": 0.005,       // USD per 1 000 input tokens
  "cost_drift": 1.2,          // percent change vs 7-day average
  "checked_at": "2025-01-01T12:00:00Z"
}

Architecture

The Oracle Engine is built on a fork of Hummingbot(Apache 2.0) — its event-driven WebSocket loop replaces exchange connectors with inference provider connectors. Trading strategy logic is replaced by health-scoring and anomaly detection. The engine runs on Render and emits a real-time SSE feed consumed by this dashboard and by the SDK's local cache layer.

Hummingbot concept
Exchange connector
Order book events
Trading strategy
Circuit breaker
Event bus / reactor
Rate limiter