From argos
Data contract — REST/GraphQL/gRPC/AsyncAPI + Avro/Protobuf + Schema Registry + versioning + idempotent consumer + DLQ + CI gate + Backstage API entity
npx claudepluginhub resultakak/argos --plugin argos<event | api | topic># /data-contract ## Amaç Producer-consumer **sözleşmesi** — schema + semantics + SLA + ownership. "Event yayınladık, downstream çalışmıyor" → contract eksik. ## Ne Zaman Kullanılır - Yeni event publish (producer çıkıyor) - Yeni consumer onboard - Breaking change kararı (major bump) - Schema drift bulgu (CI fail veya production poison) - Catalog API entity ekleme (Backstage) - Privacy review PII field annotation - DB warehouse contract (dbt) - Kafka topic onboarding - Retry storm / DLQ olmadığı tespit ## Input - `<event>` — örn. `events.order.created` - veya `<api>` — örn. `payments-sv...
Share bugs, ideas, or general feedback.
Producer-consumer sözleşmesi — schema + semantics + SLA + ownership. "Event yayınladık, downstream çalışmıyor" → contract eksik.
<event> — örn. events.order.created<api> — örn. payments-svc REST<topic> — Kafka topicapi-contract-guardian lider — REST/GraphQL/AsyncAPI sahibi.
Alt-delege:
system-design-architect — contract-first designbackend-implementer — producer + consumer impldatabase-implementer — dbt warehouse contractsdatabase-optimizer — warehouse query patternsobservability-engineer — consumer lag + DLQ alarmprivacy-engineer — PII annotation + retention bağırelease-manager — schema version + sunset planmigration-planner — major bump consumer migrationdata-contracts skill'i prosedürü taşır.
Rule: rules/data-contracts.md.
rules/data-contracts.md + rules/observability.md +
rules/privacy-engineering.md yükle.x-pii: pseudo/direct + retention.contract: enforced./data-contract events.order.created
/data-contract payments-svc-rest-v2
/data-contract --topic events.notification.sent
/data-contract --audit # tüm event/api drift taraması
/data-contract --dbt orders # warehouse contract
# Data Contract: events.order.created
## Discovery
- Producer: checkout-svc
- Consumers: 7 (notifications-svc, marketing-svc, analytics-svc,
fulfillment-svc, fraud-svc, accounting-svc, billing-svc)
- Schema location: YOK (wiki + copy-paste)
## Contract Spec (AsyncAPI 3.0)
- events/order-created.yaml v1.0.0 (yeni)
- SLA: latency p99 500ms, at_least_once, lag alarm 60s
## Findings
- Critical: 3 consumer dedup yok (duplicate process)
- Critical: notifications-svc DLQ yok, retry storm 2h sustained
- High: PII user_email plaintext payload
- High: schema_version header yok
- High: 7 consumer copy-paste, Pact yok
- Medium: CI contract test yok
- Medium: Backstage API entity yok
- Low: SLA dokümante değil
## Action Items
| P0 | AsyncAPI spec events/order-created.yaml + Schema Registry register | @payments | 2026-05-23 |
| P0 | PII pseudonymize user_email → user_id_hash | @payments | 2026-05-23 |
| P0 | DLQ topic + alert 3 consumer | @platform | 2026-05-30 |
| P0 | Idempotency event_id producer + processed_events 7 consumer | @payments | 2026-06-06 |
| P1 | schema_version header + Pact 7 consumer | @api | 2026-06-13 |
| P1 | CI contract test (AsyncAPI validate + Pact + compat) | @platform | 2026-06-13 |
| P1 | Backstage API entity | @platform | 2026-06-20 |
| P2 | SLA dokümante (Backstage TechDocs) | @payments | 2026-06-30 |