La bibliothèque se documente elle-même · Concurrence et distribution
stzAppCluster
48 méthodes propres · 1 formes avec extensions, rangées sous leur méthode
la source: base/cluster/stzAppCluster.ring(s'ouvre dans un nouvel onglet) · Toutes les classes · La référence du domaine : Concurrence et distribution
Sous chaque méthode, ses extensions (Q CS XT Z ZZ IB W U) : en gras et cochée, elle existe ; barrée, elle n'existe pas. Les extensions et leur sens
Aucune méthode de cette classe n'est exécutée sur cette page : la classe touche aux fichiers, au réseau, aux processus, à l'horloge, au hasard ou au son, et un exemple exécuté ici ne serait que l'exemple de ses effets. Chaque méthode porte l'explication que la bibliothèque donne d'elle-même.
Méthode
Explication, telle que la source la porte
init
(sans commentaire dans la source : le nom se lit comme une phrase) initaucune extension
AddProfile
declaring the fleet composition ------------------------------------ Declare nWorkers processes of a profile (capability tag + caps). One @aFleet row per worker is created NOW (port assigned at Start), so FleetSize/WorkersOf are correct before and after launch.QCSXTZZZIBWU
SetMaxTries
(sans commentaire dans la source : le nom se lit comme une phrase) set max triesaucune extension
SetCircuitBreaker
Circuit breaker: after nThreshold consecutive failures a worker's circuit OPENS (it is skipped for nCooldownMs, then half-open: one probe re-closes on success or re-opens on failure).aucune extension
SetRateLimit
Rate limit a facet at the front door: nRatePerSec sustained with a bucket of nBurst (the largest instantaneous burst absorbed). A facet with no SetRateLimit is UNLIMITED. Requests over the limit are shed with a -429 status before any worker is touched.aucune extension
RegisterExternalWorker
Register a PRE-EXISTING worker (e.g. a remote/static host) into a facet's pool -- it participates in routing, failover and health like a spawned worker. host:port endpoint.aucune extension
WithFacet
THE GENERAL FORM: specialize workers along ANY facet in THIS cluster's catalog (not just the doc's four). Capabilities, provenance and any external tool are taken from the pool's own catalog (instance-scoped, customizable via CatalogQ()/DefineFacet). oC.WithFacet(:graph, 2).WithFacet(:knowledge, 2).WithFacet(:neural, 1)aucune extension
CatalogQ
The cluster's facet catalog (instance-scoped -- customize per deployment: DefineFacet/DefinePolyglotFacet/Drop before WithFacet).aucune extension
WithNLP
Sugar for the doc's four (each just a WithFacet over the catalog).aucune extension
WithMath
Same as WithFacet: THE GENERAL FORM: specialize workers along ANY facet in THIS cluster's catalog (not just the doc's four). Capabilities, provenance and any external tool are taken from the pool's own catalog (instance-scoped, customizable via CatalogQ()/DefineFacet). oC.WithFacet(:graph, 2).WithFacet(:knowledge, 2).WithFacet(:neural, 1)aucune extension
WithSearch
Same as WithFacet: THE GENERAL FORM: specialize workers along ANY facet in THIS cluster's catalog (not just the doc's four). Capabilities, provenance and any external tool are taken from the pool's own catalog (instance-scoped, customizable via CatalogQ()/DefineFacet). oC.WithFacet(:graph, 2).WithFacet(:knowledge, 2).WithFacet(:neural, 1)aucune extension
WithVision
Same as WithFacet: THE GENERAL FORM: specialize workers along ANY facet in THIS cluster's catalog (not just the doc's four). Capabilities, provenance and any external tool are taken from the pool's own catalog (instance-scoped, customizable via CatalogQ()/DefineFacet). oC.WithFacet(:graph, 2).WithFacet(:knowledge, 2).WithFacet(:neural, 1)aucune extension
SetWorkerTTL
(sans commentaire dans la source : le nom se lit comme une phrase) set worker ttlaucune extension
SetBasePort
(sans commentaire dans la source : le nom se lit comme une phrase) set base portaucune extension
SetRingExe
(sans commentaire dans la source : le nom se lit comme une phrase) set ring exeaucune extension
Start
launching the fleetaucune extension
WaitReady
Poll every worker's /health until it answers 200 (workers need a moment to load stzBase + bind). Returns the number now ready.aucune extension
Route
routing: RETRY-WITH-FAILOVER + per-worker CIRCUIT BREAKER ----------- Proxy to a healthy worker of pcTag. On a failed attempt (transport error or non-2xx), FAIL OVER to the next healthy worker, up to SetMaxTries. A worker that fails SetCircuitBreaker consecutive times has its circuit OPENED (skipped for the cooldown, then half-open). A success resets/closes its circuit. Path is SSRF/CRLF-validated first.aucune extension
RouteLastStatus
(sans commentaire dans la source : le nom se lit comme une phrase) route last statusaucune extension
Why
(sans commentaire dans la source : le nom se lit comme une phrase) whyaucune extension
TelemetryQ
observability (latency percentiles + trace ids)aucune extension
LastTraceId
The trace id assigned to the most recent Route (correlates the front host's record with the worker's _trace on the wire).aucune extension
LatencyP50
Tail-aware latency for a facet (ms; the engine histogram bucket bound).aucune extension
LatencyP90
(sans commentaire dans la source : le nom se lit comme une phrase) latency p90aucune extension
LatencyP99
(sans commentaire dans la source : le nom se lit comme une phrase) latency p99aucune extension
LatencyStats
(sans commentaire dans la source : le nom se lit comme une phrase) latency statsaucune extension
RecentTraces
The last n request records: [ id, facet, endpoint, status, durMs, attempts ].aucune extension
LimiterQ
rate limiting (front-door admission)aucune extension
RateLimitedCount
How many requests this facet has shed for exceeding its rate limit.aucune extension
TokensAvailable
Tokens left in a facet's bucket (-1 = unlimited / no limit configured).aucune extension
CircuitOpenCount
(sans commentaire dans la source : le nom se lit comme une phrase) circuit open countaucune extension
FleetSize
introspectionaucune extension
ReadyCount
(sans commentaire dans la source : le nom se lit comme une phrase) ready countaucune extension
WorkersOf
(sans commentaire dans la source : le nom se lit comme une phrase) workers ofaucune extension
Ports
(sans commentaire dans la source : le nom se lit comme une phrase) portsaucune extension
PoolQ
(sans commentaire dans la source : le nom se lit comme une phrase) pool qaucune extension
ReactorQ
(sans commentaire dans la source : le nom se lit comme une phrase) reactor qaucune extension
ClassifierQ
R8.2 smart routing (classify -> route) ----------------------------- A request classifier bound to THIS cluster's facet catalog (created lazily, after facets are declared).aucune extension
RouteRequest
Classify a request to a facet (R8.2), then proxy it to a worker of that facet (R8.3). Returns the response body; "" (with negative RouteLastStatus) when the request is undecidable or has no worker.aucune extension
HealthCheck
R8.4 health + elastic scale (the supervision surface) -------------- Re-probe every worker's /health and refresh its ready flag. A worker that stops answering (crashed, exited its TTL) flips to NOT ready. Returns the number ready now.aucune extension
DeadCount
Workers that were launched but are not answering (crashed / expired).aucune extension
ScaleUp
Add ONE worker of a profile (elastic scale-up). Spawns a new process on a fresh port; call WaitReady()/HealthCheck() to see it come up. Returns the new port.aucune extension
ScaleDown
GRACEFUL drain-down: mark one ready worker of a profile DRAINING -- routing stops immediately (it finishes in-flight work), and the process self-exits on its TTL. Returns the drained port, or 0 if there is nothing to drain. (Forced kill of a hung worker is a small future engine add; drain is the graceful path.)aucune extension
RestartDead
Respawn every dead worker in place (health-driven self-healing). Returns the number restarted.aucune extension
ForceKill
forced kill + orphan cleanup (the forceful sibling of drain) -------- Force-kill EVERY spawned worker of a facet (SIGKILL). The forceful counterpart to ScaleDown's graceful drain: use it on a WEDGED worker that neither answers health nor self-exits on its TTL. Marks each not ready and returns how many were actually killed. External workers (RegisterExternalWorker, jobId 0) are NOT ours to kill and are skipped.aucune extension
KilledCount
Total workers force-killed over the cluster's life (a hung-worker / orphan-cleanup signal for the health console).aucune extension
FleetMetrics
A per-profile metrics snapshot the supervisor reads (REAL counts).aucune extension
Stop
teardown ----------------------------------------------------------- R8.3: workers self-terminate on their TTL. Graceful drain / kill / health-restart / autoscale is R8.4 (stzAgentHost supervision).aucune extension

