API Events
N/A across the board.
@nx/assetis a synchronous library: REST controllers + direct S3/Minio calls. It produces and consumes no Kafka topics, BullMQ jobs, or WebSocket events. Its REST surface is documented in the host's live OpenAPI and in Storage / MetaLinks.
1. Inbound — Kafka
| Topic | Producer | Handler | Idempotency Key | Failure Mode |
|---|---|---|---|---|
| — | — | — | — | — |
N/A — no Kafka consumer.
2. Outbound — Kafka
| Topic | Trigger | Consumers | Payload Schema |
|---|---|---|---|
| — | — | — | — |
N/A — no Kafka producer.
3. Inbound — BullMQ
| Queue | Job Type | Producer | Handler | Concurrency |
|---|---|---|---|---|
| — | — | — | — | — |
N/A — no queue workers.
4. Outbound — BullMQ
| Queue | Job Type | Trigger | Consumer Service |
|---|---|---|---|
| — | — | — | — |
N/A — no job producers.
5. WebSocket Emissions
| Topic | Room | Trigger | Action Enum |
|---|---|---|---|
| — | — | — | — |
N/A — no WebSocket component.
6. Payload Schemas
N/A — no async payloads. The synchronous REST request/response schemas live in:
packages/asset/src/controllers/asset/definition.ts(StaticAssetRoutes)packages/asset/src/controllers/banks-vn/definition.ts(BanksVNRoutes)MetaLinkInsertSchema/MetaLinkUpdateSchemafrom@nx/core
7. Idempotency & Ordering
| Topic | At-most/at-least-once | Ordering | Recovery |
|---|---|---|---|
| — | — | — | — |
N/A — synchronous request/response. Upload is not idempotent (each call mints a new UUID object name).