Get started.

import { Infino } from "@infino/sdk";

const infino = new Infino({ accessKey: process.env.INFINO_KEY });

// Write events as they arrive — schema is derived
await infino.write("checkout_events", {
  user_id: "u_123",
  amount: 49.0,
  status: "failed",
  ts: Date.now(),
});

// Query directly — governed, audited, executed
const result = await infino.queryDsl("checkout_events", {
  query: { term: { status: "failed" } },
  aggs: { by_reason: { terms: { field: "error_code", size: 5 } } },
});