Files
agents/control-plane/migrations/017_create_observability_dead_letter_queue.sql
zeekayandGitHub 5b5cf9e9db feat: merge AgentField control plane + SDKs as Hanzo Agents (#1)
Transforms hanzoai/agents from a marketplace config repo into a full
agent orchestration platform by merging the AgentField infrastructure:

- Go control plane (K8s-like agent orchestration, service mesh, DAG workflows)
- Python SDK (FastAPI-based agent framework, LiteLLM, memory, DID/VC)
- TypeScript SDK (@hanzo/agents - Vercel AI SDK, MCP, workflows)
- Go SDK (idiomatic agent builder + client)
- React 19 embedded dashboard (XyFlow DAGs, Recharts, Radix UI)
- Docker/K8s/Helm deployment configs
- Examples: hello world, deep research, RAG, simulation, benchmarks
- Functional test suite across Python/Go/TypeScript

All references rebranded: AgentField → Hanzo Agents
- Module: github.com/hanzoai/agents/control-plane
- Python: hanzo_agents
- TypeScript: @hanzo/agents
- Go: github.com/hanzoai/agents/sdk/go
- Env vars: HANZO_AGENTS_*
- Config: hanzo-agents.yaml

Previous marketplace configs moved to config/ directory.
2026-02-09 18:53:09 -08:00

27 lines
989 B
SQL

-- +goose Up
-- +goose StatementBegin
CREATE TABLE IF NOT EXISTS observability_dead_letter_queue (
id INTEGER PRIMARY KEY,
event_type TEXT NOT NULL,
event_source TEXT NOT NULL,
event_timestamp TEXT NOT NULL,
payload TEXT NOT NULL,
error_message TEXT NOT NULL,
retry_count INTEGER NOT NULL DEFAULT 0,
created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP
);
-- Index for efficient querying by creation time (oldest first for redrive)
CREATE INDEX IF NOT EXISTS idx_observability_dlq_created_at ON observability_dead_letter_queue(created_at);
-- Index for filtering by event type/source
CREATE INDEX IF NOT EXISTS idx_observability_dlq_event_type ON observability_dead_letter_queue(event_type, event_source);
-- +goose StatementEnd
-- +goose Down
-- +goose StatementBegin
DROP INDEX IF EXISTS idx_observability_dlq_event_type;
DROP INDEX IF EXISTS idx_observability_dlq_created_at;
DROP TABLE IF EXISTS observability_dead_letter_queue;
-- +goose StatementEnd