API Events
N/A toàn bộ.
@nx/assetlà một thư viện đồng bộ: REST controller + gọi trực tiếp S3/Minio. Nó không tạo và không tiêu thụ Kafka topic, BullMQ job, hay WebSocket event nào. Bề mặt REST của nó được tài liệu hóa trong OpenAPI trực tiếp của host và trong Storage / MetaLinks.
1. Inbound — Kafka
| Topic | Producer | Handler | Idempotency Key | Failure Mode |
|---|---|---|---|---|
| — | — | — | — | — |
N/A — không có Kafka consumer.
2. Outbound — Kafka
| Topic | Trigger | Consumers | Payload Schema |
|---|---|---|---|
| — | — | — | — |
N/A — không có Kafka producer.
3. Inbound — BullMQ
| Queue | Job Type | Producer | Handler | Concurrency |
|---|---|---|---|---|
| — | — | — | — | — |
N/A — không có queue worker.
4. Outbound — BullMQ
| Queue | Job Type | Trigger | Consumer Service |
|---|---|---|---|
| — | — | — | — |
N/A — không có job producer.
5. WebSocket Emissions
| Topic | Room | Trigger | Action Enum |
|---|---|---|---|
| — | — | — | — |
N/A — không có WebSocket component.
6. Payload Schemas
N/A — không có async payload. Các schema request/response REST đồng bộ nằm trong:
packages/asset/src/controllers/asset/definition.ts(StaticAssetRoutes)packages/asset/src/controllers/banks-vn/definition.ts(BanksVNRoutes)MetaLinkInsertSchema/MetaLinkUpdateSchematừ@nx/core
7. Idempotency & Ordering
| Topic | At-most/at-least-once | Ordering | Recovery |
|---|---|---|---|
| — | — | — | — |
N/A — request/response đồng bộ. Upload không idempotent (mỗi lần gọi tạo một tên object UUID mới).