استدعاءات الخدمات

الاستدعاء الداخلي الأحادي في go-like تركيب صغير وواضح. يمرر @go-like/client لقطة Discovery إلى Selector، ثم ينفذ تبادلاً واحداً من fetch عبر Transport. وتستخدم عملية الإنشاء خيارات وظيفية:

import type { Context } from "@go-like/context"
import {
  newClient,
  withDiscovery,
  withEndpoint,
  withFilter,
  withSelector,
  withTransport,
  type CallRequest
} from "@go-like/client"
import {
  filterLabel,
  filterVersion,
  newRoundRobinSelector,
  type Discovery,
  type Filter
} from "@go-like/registry"
import type { Transport } from "@go-like/transport"

declare const ctx: Context
declare const discovery: Discovery
declare const serviceTransport: Transport
declare const requestBytes: Uint8Array

const client = newClient(
  withDiscovery(discovery),
  withEndpoint("discovery:///orders"),
  withSelector(newRoundRobinSelector()),
  withTransport(serviceTransport)
)
const filters: readonly Filter[] = [filterVersion("v1"), filterLabel("zone", "a")]
const request: CallRequest = {
  service: "orders",
  endpoint: "get",
  headers: { "content-type": "application/json" },
  body: requestBytes
}
const reply = await client.call(ctx, request, withFilter(...filters))
void reply

يصدر API الجذري لـ Registry النوع Filter والدالتين filterVersion(...) وfilterLabel(...)، بينما يرفق withFilter(...) المرشحات بالاستدعاء. تعمل المرشحات بترتيب التصريح قبل Selector.select. للوجهة المباشرة، أنشئ العميل عبر newClient(withTransport(serviceTransport), withEndpoint(serviceAddress))؛ لا يستخدم withEndpoint(...) Discovery، لكنه يمر عبر Selector نفسه الذي تستخدمه اللقطات المكتشفة. أما العميل المستند إلى Discovery فيستخدم withEndpoint("discovery:///<name>") وwithDiscovery(discovery) معاً، ويفتح مراقباً واحداً لكل خدمة عند الحاجة ويختار من أحدث لقطة مكتملة. ينفذ كل استدعاء محاولة واحدة افتراضياً؛ وبعد إثبات أن الإعادة آمنة، يضبط withRetry(...) عدداً محدوداً من المحاولات وتصنيف حالات الفشل وتأخيراً اختيارياً، وتعيد كل محاولة مسموحة الاختيار من أحدث لقطة. عند الانتهاء يجب استدعاء client.close(ctx)؛ ويحد closeTimeout(...) تنظيف عميل Transport المنطقي فقط، بينما يملك Transport وبيئة التشغيل إعادة استخدام الاتصال الفعلي.

يربط @go-like/server المعالجات بطبقة النقل ويعرض العنوان الفعلي المرتبط. أنشئ الخادم بخيارات transport(...) وaddress(...) وmiddleware(...) وlistenOption(...)، ثم سجّل المسار قبل التشغيل عبر server.registerHandler(...)؛ ويمرر الخيار الأخير قيم ListenOption الخاصة بالمزوّد إلى Transport.listen. يعيد endpoint(ctx) نقطة النهاية الفعلية نفسها التي يستخدمها start(ctx). وينشر Core App المكوّن عبر newApp(registrar(registry), server(serviceServer)) نقطة النهاية هذه ضمن ServiceInstance ثم يسحبها عند الإيقاف. هذا هو مسار دورة الحياة الموصى به؛ ولا يحتاج المستخدم إلى رمز تسجيل أو readiness DSL أو أداة تسجيل خاصة بالخادم.

تضيف كل محاولة أحادية قيمة TransportInfo في جهة العميل، وتتضمن الهدف الفعلي وعملية service/endpoint الثابتة وترويسات النقل الحقيقية، إلى Context الممرر إلى Transport. ويضيف الخادم قيمة TransportInfo المناظرة قبل استدعاء معالج العمل. يرمّز العميل والخادم البيانات الوصفية متعددة القيم في Context داخل الغلاف المحدود والقياسي Go-Like-Metadata، وتحمله مزوّدات Transport كترويسة Fetch معتمة. ولا تنسخ propagateToClientContext(...) البيانات الوصفية الخاصة بالخادم إلى سياق العميل إلا عبر قائمة سماح صريحة من نوع exact أو prefix.

لا يكتمل الاستدعاء إلا بعد feedback وإعادة عميل Transport المنطقي إلى pool أو إغلاقه عند الحاجة. يُعاد استخدام العميل الناجح افتراضياً؛ اضبط poolSize(0) لتعطيل الاحتفاظ به. تحفظ مشكلة التنظيف بعد وصول الاستجابة هذه الاستجابة في AggregateError.cause وترتّب الأخطاء في errors، ولا تبرر إعادة الاستدعاء. أغلق المالك عبر client.close(ctx) عند الانتهاء.