تخطَّ إلى المحتوى

المسرد

المُصطلحات المُستخدمة في كاظمة، بمعانٍ دقيقة مُستندة إلى قاعدة الشيفرة.


Adapter (platform) صنف يترجم الأحداث الأصلية للمنصّة (تحديثات Telegram، أحداث بوابة Discord، أحداث مقبس Slack) إلى IncomingMessage الخاص بكاظمة، ويُصيِّر OutboundMessage للخلف. جميعها توسِّع BaseAdapter (kazma-gateway/.../gateway.py:239). تختلف عن مُحوّل الناقل (bus adapter).

Adapter (bus) مُحوّل منفصل لموافقات HITL الخاصة بالسرب (TelegramBusAdapter، DiscordBusAdapter، SlackBusAdapter)، وجميعها فئات فرعية من BusAdapter (kazma_core/swarm/bus.py:66). يُنشَط واحدٌ منها فقط في كل مرّة؛ الأولوية Telegram > Discord > Slack.

Agent handler الجسر بين مُحوّلات المنصّة ورسم المُشرف. أصبح الآن حزمة agent_handler/ (مُفكَّكة من ملف agent_handler.py القديم). يملك عزل المنصّة.

Aggregation طريقة دمج نتائج التوزيع المتعدّد (fan-out): collect، first_valid، merge_all، vote، synthesize (swarm/aggregator.py).

Authority (Context) ContextAuthority (authority.py) — يُقرِّر متى يتم تكثيف (compact) المحادثة (عند 80% من نافذة السياق) ويستدعي CompactionEngine.

AutoScaler يُنشئ عمّال {name}-pool-{n} من قوالب عندما لا يجد التوجيه auto عاملًا قادرًا؛ ويُلغي تخصيص (reaps) النسخ الخاملة.


Blackboard (pipeline) السياق المشترك الذي يُمرَّر بين مراحل خط المعالجة؛ ترى كل مرحلة مُخرجات المراحل السابقة.

BlackboardStore الكائن المشترك للوحح المبدئي (scratchpad) الذي يُمرَّر بين عمّال خط المعالجة/التوزيع المتعدّد/الاستشارة؛ تقرأ كل مرحلة المُخرجات السابقة وتكتب مُخرجاتها الخاصة.

Bounded concurrency BoundedConcurrency (reliability.py:872) — غلاف لـ asyncio.Semaphore يحدّ من عمليات الإرسال المتوازية (الافتراضي 5).

Breaker (circuit) CircuitBreaker (reliability.py:238) — عازِل إخفاقات ثلاثي الحالات (CLOSED/OPEN/HALF_OPEN). تسمح حالة نصف المفتوحة بتجربة واحدة بالضبط (probe) (_probe_in_flight).

Bus (message) المفرد (singleton) (get_message_bus()، bus.py:282) الذي يوجّه طلبات موافقة HITL الخاصة بالسرب إلى مُحوّل ناقل المنصّة النشط.


Checkpointer طبقة استمرار LangGraph (AsyncSqliteSaver على kazma-data/checkpoints.db) التي تخزّن حالة المحادثة وإيقافات HITL.

CheckpointManager swarm/checkpoint_manager.py — يملك حالة خط المعالجة المُوقَفة، ويُسلّح مهلات الرفض التلقائي، ويستمرّ في SQLite، ويُستعيد عند إعادة التشغيل.

Classify (MCP tool) classify_mcp_tool() (mcp/manager.py:71) — يُصنّف أداة MCP مُكتشفة وقت التشغيل على أنّها danger/safe/unknown حسب نمط الاسم. القيمة غير المعروفة تُفترَض خطرًا (danger) افتراضيًا.

Code-switch token مقطع إنجليزي/لاتيني مُضمَّن داخل نص عربي، مُوسوم CODE_SWITCH بواسطة المُجزِّئ (tokenizer) المزدوج ليُحافَظ عليه بدلًا من نَقْحَرَتِه أو تجذيره.

CommandConsole شريط أوامر الواجهة الطرفية (TUI) بنمط vim المُفعَّل بـ : (يُدخَل أوامر بنمط ex مثل :theme، :lang).

Compaction CompactionEngine (compaction.py) — يُلخّص المحادثة حين تقترب من نافذة السياق. في التوصيل الافتراضي، تُشغَّل خطوة التلخيص عبر LLM فقط (استرجاع الذاكرة + نقاط الحفظ لا تُؤدّيان فعلًا / no-ops).

ConfigStore مخزن إعدادات وقت التشغيل المدعوم بـ SQLite (config_store.py) الذي يتجاوز kazma.yaml. مفرد (singleton) عبر get_config_store(). وضع WAL مع busy_timeout=5000.

CONSULT نمط سرب: جمع آراء متوازية من عدة عمّال، ثم توليف عبر LLM.

ContextAuthority انظر Authority.

CostCircuitBreaker cost_breaker.py — يُفعَّل (trips) عند تجاوز الإنفاق حدًّا أعلى (الافتراضي $0.50) بعد نافذة صمت (الافتراضي 5 دقائق). غير موصول تلقائيًا في chat().


Danger tool أداة تتطلّب موافقة HITL قبل التنفيذ. توجد ثلاث قوائم (graph/swarm/MCP) — انظر الأمان والسلامة.

Delegation تسليم مهام بين الوكلاء مع سلامة تشفيرية كاملة (توقيع Ed25519، تشفير X25519+AES-256-GCM) — delegation/security.py. تختلف عن MCP والمهارات.

DISPATCH نمط سرب: عامل واحد يتولّى مهمّة.

Dormant gate بوّابة HITL غير نشطة لأنّ hitl_config لم يُمرَّر وقت بناء الرسم (كل الأدوات تذهب إلى safe_tools).


FAN_OUT نمط سرب: تنفيذ متوازٍ عبر العمّال مع تزامن محدود، ثم تجميع (aggregation).

Fallback chain عمّال احتياطيون تسلسليّون بعد فشل العامل الأساسي (reliability.py:734).


Handoff قيام عاملٍ بنقل مهمّة إلى عامل آخر أثناء التنفيذ. محصور بعمق 5 وزيارتين لكل عامل (handoff_guards.py).

HITL الإنسان في الحلقة (Human-in-the-Loop). لكاظمة ثلاث بوابات HITL مستقلّة: مقاطعة الرسم (الدردشة)، ناقل السرب (الإرسال)، نقاط حفظ خط المعالجة.

Hub سجلّ المهارات/السوق (kazma_core/hub/) مع التوقيع والشهادة والبحث (kazma hub …).


i18n نظام الترجمة المُضمَّن EN/AR في kazma-ui/kazma_ui/i18n.py (دون ملفّات منفصلة). يضبط dir/lang لكل طلب.

interrupt() أداة LangGraph الأوّلية للتعليق، تُستدعى في tool_worker_node للأدوات الخطيرة. تُستأنَف عبر Command(resume=...).

InProcessWorker تنفيذ العامل لكلا نوعَي العامل in_process وtelegram_bot (worker_factory.py:17).


Majlis بروتوكول المحادثة الثقافي الخليجي (majlis.py) — أربع مراحل: GREETING → SOCIAL → TRANSACTION → FAREWELL. وحدة أساسية، وليست مفتاح تبديل في الواجهة.

MCP بروتوكول سياق النموذج (Model Context Protocol). خوادم أدوات خارجية (stdio أو SSE) تُوكَّل إلى الوكيل. يدعم SSE مصادقة الحامل (bearer auth)؛ أمّا stdio فلا.

ModelRegistry المفرد على مستوى العملية (model_registry.py:81) الذي يُدير المُزوّدين والنماذج والاكتشاف والاختيار النشط. الاسم المستعار: UnifiedModelRegistry.


OutputValidator reliability.py:488 — يتحقّق من مُخرَج العامل مقابل نموذج Pydantic، أو مخطّط JSON (JSON Schema)، أو قاموس أنواع بسيط.


Phonebook swarm/phonebook.py — استدعاء وإرسال مباشر يتجاوز طبقة الموثوقية؛ يُستخدَم بواسطة منفّذي التوبولوجيا/DAG. يُحقِن الذاكرة الحلقيّة (episodic) من المُكيّف رباعي الطبقات.

PermissionLevel مستوى الوصول إلى الأدوات في السرب: READ_ONLY، SYSTEM_EXEC، FULL_ACCESS. يُسنَد لكل دور عامل.

Pipeline نمط سرب: مراحل مرتّبة تتشارك لوحًا أسود (blackboard)، مع نقاط حفظ HITL اختيارية.

Platform isolation الثابت (invariant) بأنّ chat_id/user_id/message_id وغيرها لا تدخل حالة الرسم إطلاقًا — فهي تعيش في SessionStore وتُعاد إرفاقها عند الردّ عبر _build_target_id().


RRF دمج الرتبة المتبادلة (Reciprocal Rank Fusion) — خوارزمية المزج التي يستخدمها UnifiedMemoryAdapter (_RRF_K = 60).

ReliabilityRegistry swarm/reliability_registry.py — حامل إعدادات لقواطع/إعادات/مهلات/مُتحقّقات/تزامن خاصّة بكل عامل. تعيش آلات الحالة في reliability.py.

RetryPolicy reliability.py:66 — تراجع أُسّي (exponential backoff) (الافتراضي 3 إعادات، 1–60 ثانية). لا يُعيد محاولة 4xx.


SafetyMiddleware swarm/safety.py:47 — بوّابة HITL لناقل السرب. check_sync() مغلق عند الفشل (fail-closed). (لا يوجد صنف باسم SafetyGate/SafetyChecker.)

SessionStore تعيين مُعرّف المنصّة ↔ thread_id (gateway.py:185). إمّا SQLite أو في الذاكرة. لا يحتفظ أبدًا بحالة الرسم.

Skill نقطة دخول Python مُغلَّفة ومُوقَّعة اختياريًّا + بيان وصف (manifest) يُسجِّل أداةً أو أكثر. تُحمَّل من kazma-skills/manifests/ أو من Hub.

sqlite-vec امتداد SQLite للبحث المُتجهي (vector search)، يُستخدَم في الطبقة الرابعة من مُكيّف الذاكرة. ليست تبعية مُعلَنة — موجودة عرضيًّا (transitively) عبر langgraph-checkpoint-sqlite.

SwarmEngine swarm/engine.py:103 — المنسِّق التزامني (async) المركزي لعمّال السرب.


TaskType الـ enum لأنماط السرب: DISPATCH، BROADCAST، PIPELINE، FAN_OUT، CONSULT، CONDITIONAL.

TimeoutGuard reliability.py:397 — مهلة لكل مهمّة (الافتراضي 300 ثانية) مع سلوك fail/retry/skip.

ToolRegistry agent/tool_registry.py — السجلّ الذي يستشيره المُشرف في كل دورة. execute() هو مسار التنفيذ الوحيد وبوّابة HITL لناقل السرب.

TUI لوحة الطرفية المبنيّة على Textual (kazma-tui)، وهي مستهلك غالبه للقراءة للمفردات الأساسية (singletons).


UnifiedMemoryAdapter مُزج الذاكرة رباعي الطبقات (swarm/memory/adapter.py): ChromaDB + NetworkX + FTS5 + sqlite-vec، مدمَجة عبر RRF. يُستخدَم فقط بواسطة التحسين الذاتي ودفتر العناوين (phonebook).

UnifiedRouter محرّك التوجيه التلقائي لإرسال السرب عبر workers=["auto"].


VectorMemory الذاكرة المدعومة بـ ChromaDB والمُستخدَمة بواسطة أداتَي memory_search/memory_store (memory/vector_store.py). أبعاد 384-d مع all-MiniLM-L6-v2.


Worker وحدة تنفيذ في السرب (SwarmWorker). تُسجَّل في _workers؛ وتُحلَّ عبر السجلّ أو دفتر العناوين (phonebook).

WorkerCapabilities كائن {role, expertise, tools, model_specialty} يصف ما يستطيع العامل فعله؛ يُستخدَم بواسطة UnifiedRouter وAutoScaler لمطابقة المهام مع العمّال.

WorkerRegistry سجلّ عمّال مدعوم بـ JSON (swarm/registry.py)، يُحمَّل من swarm_registry.json.