HTTP Admin API

handler := api.NewHandler(r.Store(), r.Catalog(), r.Endpoints(), r.DLQ(), logger)
mux.Handle("/webhooks/", http.StripPrefix("/webhooks", handler))

POST /event-types
Content-Type: application/json

{
  "name": "invoice.created",
  "description": "Fired when a new invoice is generated",
  "group": "billing",
  "version": "2025-01-01",
  "schema": {"type": "object"},
  "example": {"invoice_id": "INV-001"}
}

GET /event-types?group=billing&limit=20&offset=0

GET /event-types/{name}

DELETE /event-types/{name}

POST /endpoints
Content-Type: application/json

{
  "tenant_id": "tenant-acme",
  "url": "https://acme.example.com/webhook",
  "description": "Production webhook",
  "event_types": ["order.*", "invoice.created"],
  "headers": {"X-Custom": "value"},
  "rate_limit": 100,
  "metadata": {"env": "production"}
}

GET /endpoints?tenant_id=tenant-acme&limit=20&offset=0

GET /endpoints/{id}

PUT /endpoints/{id}
Content-Type: application/json

{
  "url": "https://new-url.example.com/webhook",
  "event_types": ["order.*"],
  "rate_limit": 200
}

DELETE /endpoints/{id}

PATCH /endpoints/{id}/enable
PATCH /endpoints/{id}/disable

POST /endpoints/{id}/rotate-secret

POST /events
Content-Type: application/json

{
  "type": "order.created",
  "tenant_id": "tenant-acme",
  "data": {"order_id": "ORD-001", "amount": 99.99},
  "idempotency_key": "order-ORD-001"
}

GET /events?type=order.created&limit=20&offset=0

GET /events/{id}

GET /endpoints/{id}/deliveries?state=pending&limit=20&offset=0

GET /dlq?tenant_id=tenant-acme&limit=20&offset=0

POST /dlq/{id}/replay

POST /dlq/replay
Content-Type: application/json

{
  "ids": ["dlq_01h455vb...", "dlq_01h456ab..."]
}

GET /stats

{
  "error": "endpoint not found"
}