La bibliothèque se documente elle-même · Concurrence et distribution

stzClusterSupervisor

13 méthodes propres · 0 formes avec extensions, rangées sous leur méthode

la source: base/cluster/stzClusterSupervisor.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

Name_

(sans commentaire dans la source : le nom se lit comme une phrase) name_aucune extension

SetName

(sans commentaire dans la source : le nom se lit comme une phrase) set nameaucune extension

ClusterQ

(sans commentaire dans la source : le nom se lit comme une phrase) cluster qaucune extension

Policy

policy ------------------------------------------------------------- Bound a profile's fleet size: never below nMin, never above nMax.aucune extension

SetWaterMarks

(sans commentaire dans la source : le nom se lit comme une phrase) set water marksaucune extension

ReportLoad

The app's observed demand for a profile (0..1: e.g. latency/SLA or in-flight/capacity). This is the honest load signal -- the app measures it; the supervisor enforces the policy.aucune extension

LoadOf

(sans commentaire dans la source : le nom se lit comme une phrase) load ofaucune extension

FeedLoadFrom

The perf-P6 closing of the loop: the load signal MEASURED instead of hand-fed. A stzPerfProfile's LoadRatio() is X/Xmax -- how close the observed workload is to its CPU ceiling -- read from the same engine instruments everything else trusts. Call it before each Supervise()/Cycle() pass (or from the same host tick).aucune extension

Decide

the decision (PURE policy) ----------------------------------------- Given the current fleet metrics + reported load, return the actions to take: [ [ :restart, tag ], [ :scaleup, tag ], [ :scaledown, tag ] ]. Dead-worker restart takes precedence; then load-driven scaling within the [min, max] bounds. No side effects -- Supervise() applies these.aucune extension

Supervise

applying the decision to the live cluster -------------------------- One supervision pass: refresh health, decide, apply. Returns the actions taken.aucune extension

LastActions

(sans commentaire dans la source : le nom se lit comme une phrase) last actionsaucune extension

Cycle

R5 composition: a supervised job on stzAgentHost ------------------- stzAgentHost ticks Cycle() on any supervised object. So the cluster supervisor runs on the SAME reactor loop the fleet runs on. Returns the number of actions taken this tick (0 -> quiescent).aucune extension