Python memory helpers
connection.memory wraps memory writes, searches, and context assembly. connection.cache wraps exact and semantic prompt cache store/lookup.
Python memory helpers
connection.memory wraps memory writes, searches, and context assembly. connection.cache wraps exact and semantic prompt cache store/lookup.
LangGraph-style flows
Example retrieve/call/remember flows show how to assemble context, check cache, call a provider on miss, and write memory back.
Provider adapters
Optional example adapters cover OpenAI Responses and Anthropic Messages. They lazy-import SDKs and keep model names in application config.
AgentOps telemetry
Example schemas model agent_runs, retrieval_events, cache_events, llm_calls, and tool_calls as ordinary time-series tables.
ZeptoDB does not call LLM or embedding providers from the server. Applications own providers and credentials; ZeptoDB stores memory, filters candidates, assembles context, and checks cache.
Kafka
Built-in Kafka consumer with batch ingestion. Up to 3.2M events/sec from Kafka topics. Useful for operational event streams and AgentOps pipelines.
Kafka connector requires Enterprise license.
FIX 4.4
Native FIX parser for market-data and order feeds. Trading agents can pair tick data with strategy memory and decision replay.
ITCH
NASDAQ ITCH handler for L3 order-book data. Lossless, nanosecond-timestamped, and ready for temporal market-memory workflows.
Binance WebSocket
Real-time crypto market data ingestion for agents watching multi-exchange state.
| Language | Type | Typical use | Link |
|---|---|---|---|
| Python | Zero-copy + memory/cache helpers | Agent loops, ML pipelines, notebooks | Python Reference → |
| C++ | Native Pipeline API | Embedded, low-latency, edge deployments | C++ Reference → |
| HTTP | REST API | SQL plus /api/ai/* memory/cache endpoints | HTTP Reference → |
| Arrow Flight | gRPC streaming | Batch data transfer and distributed training | Flight Reference → |
Prometheus
Built-in /metrics endpoint. Scrape ingestion rates, query latency, memory usage, cluster health, Agent Memory counts, cache counts, evictions, and capacity limits.
Grafana
Query ZeptoDB directly from Grafana via HTTP API. Build dashboards over operational telemetry, AgentOps events, and memory/cache metrics.
| Integration | Status | Description |
|---|---|---|
| Agent Memory sidecar | ✓ | records.bin + vectors.bin snapshots for memory/cache persistence |
| Amazon S3 | ✓ | Parquet HDB for historical time-series data |
| Google Cloud Storage | ✓ | Parquet HDB |
| Local NFS | ✓ | On-premise Parquet HDB for air-gapped and edge |
| Docker | ✓ | Single-command deployment and Agent Memory pilots |
| Kubernetes | ✓ | Helm chart with StatefulSet for time-series clusters |
| ARM Graviton | ✓ | aarch64 native for cost-efficient edge and cloud |
| Provider | Protocol | Status |
|---|---|---|
| Okta | OIDC | ✓ |
| Auth0 | OIDC | ✓ |
| Azure AD / Entra ID | OIDC | ✓ |
| Google Workspace | OIDC | ✓ |
| API Keys | Native | ✓ |
| JWT | Bearer token | ✓ |
| Integration | Status | Description |
|---|---|---|
| OPC-UA | Available / expanding | Industrial PLC / SCADA connector for manufacturing and process telemetry |
| MQTT | Available / expanding | Lightweight IoT sensor and robot telemetry ingestion |
| ROS2 | Planned | Direct topic subscription for robotics and autonomy stacks |
| AutomationML / PackML | Under evaluation | Standardized plant and machine data models |
| CAN / Vehicle Bus | Under evaluation | Automotive telemetry ingestion at the edge |
| Integration | Status | Description |
|---|---|---|
| Apache Pulsar | Planned | Streaming alternative to Kafka |
| AWS Kinesis | Planned | Cloud streaming ingestion |
| Kafka Connect Sink | Planned | Standard Kafka connector plugin |
| CDC (Debezium) | Planned | PostgreSQL / MySQL change capture |
| JDBC / ODBC | Planned | Tableau, Excel, BI tools |
| DuckDB | Planned | Arrow zero-copy JOIN delegation |
Interested in an integration, or want to prioritize one? Open an issue on GitHub or Talk to Sales →.