Lewati ke konten utama

KV Cache

KV Cache pada worker-common menyalin data konfigurasi dari PostgreSQL ke Redis agar konsumen tidak perlu membaca tabel sumber setiap kali membutuhkan konfigurasi. Worker melakukan pemuatan penuh saat startup dan pembaruan inkremental saat menerima event CDC dari NATS JetStream.

Tujuan​

  • Memuat tabel yang didaftarkan pada kv_cache_table ke Redis.
  • Menjaga cache tetap selaras ketika konfigurasi tabel atau row sumber berubah.
  • Menyediakan bentuk cache per-row dan snapshot gabungan global:config untuk Node-RED.
  • Menerbitkan snapshot dan perubahan melalui stream NATS CONFIG_EVENTS.

Gambaran singkat​

Worker ini adalah application context NestJS tanpa HTTP server. StartupBarrierService memastikan listener realtime baru aktif setelah sinkronisasi bootstrap selesai.

Batas cakupan​

Fitur ini mengelola sinkronisasi cache, bukan menghasilkan event CDC. Stream PG_CDC_EVENTS diasumsikan sudah menerima subject pgcdc.public.> dari pipeline Debezium di luar source worker-common.