hub
PIM Core Multichannel
domainMaster Core UA#101
search
NATS: ЗдоровийЧерга: live
Головна / NATS Pipeline

Моніторинг NATS & Pipeline

Stream PIM_EVENTS · FastStream + ARQ

NATS Pipeline: Healthy
Stream
PIM_EVENTS
JetStream
max_ack_pending
20
gemini backpressure
Subjects
4
raw→…→published
PIM feeds
9
hourly cron
Saleor
off
post-MVP

Topology JetStream & FastStream

КРОК 01
ARQ Scanner
hash-diff · 5 хв · offerable pool
КРОК 02
cat_mapping_workers
Ollama bge-m3 + pgvector
КРОК 03
gemini_workers
Gemini Flash · max_ack_pending=20
КРОК 04
quality_gate_workers
score ≥ 80 → auto_approved
КРОК 05
saleor_sync_workers
MVP no-op · post-MVP GraphQL
ConsumerQueue groupStatus
cat_mapper_consumercat_mapping_workersactive
gemini_enricher_consumergemini_workersthrottle ok
quality_gate_consumerquality_gate_workersactive
saleor_sync_consumersaleor_sync_workersdeferred