Eventual Consistency amalda

Eventual consistency (EC) - ma’lumotlarning nusxalari vaqtincha farqlanishi mumkin bo’lgan, ammo vaqt o’tishi bilan global muvofiqlashtirishsiz bir-biriga mos keladigan model. Agar invariantlar, merj qoidalari va mijozlar kafolatlari to’g’ri aniqlansa, bu yuqori ochiqlik (CAP) va past latentlik (PACELC) kalitidir.

1) EC ni qachon tanlash (va qachon tanlamaslik)

• Fayllar, profillar, layklar/hisoblagichlar, kataloglar/qidiruv, keshlangan koʻrinishlar.
• Lokal yozuvlar va yumshoq invariantlarga ega global tizimlar.
• Proyeksiyalar (CQRS), bu yerda haqiqat manbai - qattiq yadro, o’qish esa - asinxron.

• Qattiq invariantlar: pul, yolg’izlik, limitlar, inventar «minusga ketmaslik». U yerda - SR/EC, sage/TSS dan kuchliroq.

2) EC uchun ma’lumotlar dizayni: nizolar va ularni hal qilish

Printsip: har bir yozuv versiya meta-ma’lumotlari va birlashtirishning aniqlangan funksiyasini o’z ichiga oladi.

Vaqt belgilari/version:’version’,’ts’,’actor’.
Vektor soatlari: sabablarni qayd etadi, «ziddiyatli parallellarni» tushunish imkonini beradi.

• LWW (Last-Write-Wins): oddiy va tez, lekin «ma’nosini» yo’qotishi mumkin.
• CRDT: kommutativ/idempotent tuzilmalar, yaqinlashishni kafolatlaydi.
• Domen merge: biznes funksiyasi (masalan, roʻyxatlarni dublsiz birlashtirish, hisoblagichlarni jamlash, «eng yangi email + teglarni birlashtirish»).

• Hisoblagichlar → G-Counter/PN-Counter.
• Ko’p → OR-Set («yopishmasdan» olib tashlash).
• Registrlar → LWW-Register («yo’qotishlar» uchun ehtiyotkorlik bilan).
• Kartalar/hujjatlar → Map of CRDTs.
• Birgalikda tahrirlash → matnli CRDT/OT.

3) Replikatsiya va antientropiya

Gossip/anti-entropy: tugunlar orasidagi holatlar/xeshlar almashinuvi.
Hinted handoff: mavjud boʻlmagan tugun uchun vaqtinchalik «deponentlash».
Read repair: o’qishda kelishmovchilikni aniqladik - yangi versiyalarni aniqladik.
O’zgarishlar paketlari (deltas): to’liq rasmlarni emas, balki deltalarni haydayapmiz.
R/W kvorumlari:’R’,’W’,’N’ni tezlik va yangilik murosasiga moslashtiramiz (masalan,’R + W> N’ni «oxirgi yozuvdagi» strong ga yaqinroq).

4) EC ustidagi mijoz kafolatlari

Read-Your-Writes (RYW): muallif o’z yozuvidan keyin uni ko’radi (sticky-session/markirovka versiyasi).
Monotonic Reads: mijozni eski qiymatga «qaytarmaymiz» (oxirgi versiyadagi watermark saqlanmoqda).
Causal Consistency: Harakat/harakat oqimi (sarlavha/tokenlardagi vektor belgilari) doirasida sabablarni saqlaymiz.
Bounded Staleness: UX-tanqidiy ekranlar uchun «Δ t/N versiyasidan katta emas» kafolati.

5) EC uchun UX-patternlar

Optimistik yangiliklar: Biz «sinxronizatsiya» ni belgilab, harakatni darhol aks ettiramiz.
Tazelik belgisi: «yangilangan X sek oldin» nishonchasi, «Yangilash» tugmasi.
Mojaro-UI: kamdan-kam uchraydigan mojarolar uchun - «ikkala versiyani ham ko’rsatish va tanlash/birlashtirish».
Skeleton/placeholder + soft refresh: global kvorumlarni kutish orqali UIni bloklamang.

6) Arxitektura shablonlari

6. 1 CQRS + proyeksiyalari

Write-yadro (CP): qatʼiy invariantlar.
Read-tekislik (EC): asinxron proyeksiyalar, indekslar, keshlar; lag.

6. 2 AP ko’p mintaqasi

Yozuvlar lokal tezda, replikatsiya asinxron.
Geo-partitioning: maʼlumotlar foydalanuvchiga yaqinroq «yashaydi»; kross-mintaqa - agregatlar.
CRDT/merge funksiyalari mojarolar ogʻrigʻini bartaraf etadi.

6. 3 Kvorumli sozlash

yaml consistency:
replicas: 3 # N write_quorum: 2 # W read_quorum: 2 # R => R + W> N, closer to freshness on "last record"
read_repair: true hinted_handoff: true

7) Versiyalash siyosati va merge (misol)

yaml entity: "profile"
versioning:
clock: "vector"    # или "hybrid_time"
fields:
name:   { merge: "lww" }
emails:  { merge: "set_union" }   # OR-Set tags:   { merge: "or_set" }
likes:   { merge: "pn_counter" }
conflict_ui:
enabled: true show_diff_for: ["name"]
auto_merge_for: ["emails","tags","likes"]

8) EC kuzatilishi: nimani o’lchash kerak

Staleness Age (p50/p95/p99):’now − data_version_ts' yoki «orqada qolish versiyalari soni».
Replication Lag: Mintaqalar/uzellar oʻrtasida yetkazib berishning kechikishi.
Conflict Rate: parallel yangilanishlar ulushi, turlari boʻyicha taqsimlash.
Read-Repair Rate/Latency: o’qishda qanchalik tez-tez va qanchalik tez «davolash».
Convergence Time: Yozuv/uzel muvaffaqiyatsiz tugundan keyingi yaqinlashuv vaqti.
Semantik SLO: «95% profillar 2s dan katta emas», «99% fida <10s».

9) Runbook’i va hodisalar

1. lag’ning mintaqalararo o’sishi:’write fan-out’ni kamaytirish, tajovuzkor read-repair’ni o’z ichiga olish, og’ir yozuvchilarni trotlatlash.

2. Mojarolar avj olishi: vaqtincha «qattiqroq» qoidani (masalan, causal/RYW) yoqish, issiq kalitlarda raqobatdosh yangilanishlarni cheklash.

3. Proyeksiyalarning orqada qolishi: replikatsiya navbatlarini ustuvor belgilash, tanqidiy bo’lmagan yangilanishlar chastotasini vaqtincha qisqartirish.

4. Ma’lumotlar ba’zi uzellarda «yopishgan»: fors-anti-entropiya, partiyalar rebalansi, hinted handoff auditi.

5. Qo’lda tahlil: ziddiyatli kalitlarni tushirish, «merge-preview» asbobi, batch fiks.

10) EC testlari

Jepsen kabi testlar: tarmoqni ajratish, clock-skew, takroriy yozuvlar.
Property-based: merge-funksiyalarning invariantlari (kommutativlik, idempotentlik, assotsiativlik).
Fuzz-konfliktlari: bir kalit uchun parallel apdeytlar.
Yuk «arra» lari: convergence time baholash uchun burst/sukunatlarni almashtirish.
UX-simulyatsiyalar: tipik stsenariylarda RYW/monotonic koʻrinishi.

11) Multi-tenant va rejalar

Hodisa/yozuvlardagi’tenant _ id/plan/region’teglari.
Fairness: «shovqinli» mijoz umumiy stalenessni oshirmasligi uchun replikatsiya/repair per tenant limitlari.
Residency: yurisdiksiya doirasidagi ma’lumotlar va ularning replikalari; kross-mintaqaviy ko’rinishlar faqat agregatlar.

12) Tipik xatolar

LWW «hamma narsa uchun». Semantik parallel o’zgarishlarni yo’qotadi; CRDT/domen merge’dan foydalaning.
Mijoz kafolatlari yoʻq. Foydalanuvchi o’z yozuvini ko’rmaydi → ishonchni yo’qotadi.
Eskirish kuzatilmaganligi. Hech qanday staleness/lag → «yashirin degradatsiya» metrikasi mavjud emas.
Dual-write merge’siz turli tizimlarga. Fantomlar va tafovutlar cheksiz.
Global tartib har qanday holatda ham. Ortiqcha kvorumlar p95 ni o’ldiradi, biznes uchun esa mahalliy tartib etarli.

13) Tezkor retseptlar

Fid/lenta: muallif uchun EC + causal/RYW, reaksiyalar uchun CRDT, staleness p95 ≤ 2-5s.
Profillar/moslamalar: bounded staleness (1-2s ≤), RYW, domen merge (union toʻplamlar).
Global katalog: geo-partition, asinxron replikatsiya, so’rov bo’yicha read-repair, OR-Set orqali mojarolar.
Metriklar/hisoblagichlar: PN-Counter, fondagi konsolidatsiya; «taxminiy» qiymatlarni belgi bilan koʻrsatish.

14) Mini-etalon (so’z sxemasi)

Write-edge: versiya bilan lokal yozuv (’vector/hybrid’), voqealar jurnali.
Replication: очереди + gossip/anti-entropy, hinted handoff.
Storage: kalit, CRDT/merj funksiyalarini yozuv darajasida joylashtirish.
O’qish-reja: o’qish-repair, RYW/monotonik tokenlar, tanqidiy ekranlar uchun bounded staleness bilan keshlar.
Observability: laglar/eskirish/mojarolar, SLO steylnessdan oshib ketish alertlari.

15) Sotishdan oldingi chek-varaq

• Invariantlar va ECga yo’l qo’yiladigan joylar aniq tasvirlangan.
• Version (vector/hybrid) va determinizatsiya qilingan merge/CRDT funksiyalari tanlangan.
• Tanqidiy UX uchun mijozlar kafolatlari (RYW/monotonic/causal) amalga oshirildi.
• Replikatsiya, read-repair, hinted handoff sozlangan; R/W kvorumlari hujjatlashtirilgan.
• Staleness/lag/convergence metriklari va p95/p99 ostonalari bo’yicha alertlar.
• Runbook’va mojarolar/lag’larning o’sishiga; xavfsiz qo’l merge asboblari.
• Tarmoq bo’linishlari, parallel yangilanishlar va o’xshashlik uchun testlar.
• Ko’p tenant limitlar va residency siyosati hisobga olingan.
• UX-yangi va fallback-xulq-atvor ko’rsatkichlari mahsulot bilan kelishilgan.

Xulosa

Eventual consistency - «murosaga kelish uchun murosaga kelish» emas, balki masshtabga erishish va foydalanish vositasidir. Agar siz invarantlarni rasmiylashtirsangiz, to’g’ri merge-funksiyalarni tanlasangiz (afzalroq CRDT), mijozlar kafolatlarini bersangiz va steylness va yaqinlashish vaqtini o’lchasangiz, tizim tez, barqaror va halol bo’ladi - foydalanuvchilar uchun ham, biznes uchun ham.