ZooKeeperBasedMembershipTable Classe
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Implémentation d’une table d’appartenances à l’aide d’Apache Zookeeper 3.4.6 https://zookeeper.apache.org/doc/r3.4.6/
public class ZooKeeperBasedMembershipTable : Orleans.IMembershipTabletype ZooKeeperBasedMembershipTable = class
interface IMembershipTablePublic Class ZooKeeperBasedMembershipTable
Implements IMembershipTable- Héritage
-
ZooKeeperBasedMembershipTable
- Implémente
Remarques
Vue d’ensemble des fonctionnalités ZK utilisées : les données sont représentées par une arborescence de nœuds (similaire à un système de fichiers). Chaque nœud est traité par un chemin d’accès et peut contenir des données sous forme de tableau d’octets et a une version. Lorsqu’un nœud est créé, sa version est 0. Lors des mises à jour, la version est incrémentée atomiquement. Une mise à jour peut également être conditionnelle à une version actuelle attendue. Une transaction peut contenir plusieurs opérations, qui réussissent ou échouent atomiquement. Lors de la création d’un client zookeeper, vous pouvez définir un chemin de base où toutes les opérations sont relatives.
Dans cette implémentation : Chaque déploiement Orleans a un nœud /UniqueDeploymentId L’état de chaque silo est enregistré dans /UniqueDeploymentId/IP:Port@Gen IAmAlive de chaque silo est enregistré dans /UniqueDeploymentId/IP:Port@Gen/IAmAlive IAmAlive est enregistré dans un nœud distinct, car ses mises à jour sont inconditionnelles.
La version ZK d’un nœud est son ETag : la version de table est la version de /UniqueDeploymentId, la version d’entrée de silo est la version de /UniqueDeploymentId/IP:Port@Gen
Constructeurs
| ZooKeeperBasedMembershipTable(ILogger<ZooKeeperBasedMembershipTable>, IOptions<ZooKeeperClusteringSiloOptions>, IOptions<ClusterOptions>) |
Implémentation d’une table d’appartenances à l’aide d’Apache Zookeeper 3.4.6 https://zookeeper.apache.org/doc/r3.4.6/ |
Méthodes
| CleanupDefunctSiloEntries(DateTimeOffset) |
Implémentation d’une table d’appartenances à l’aide d’Apache Zookeeper 3.4.6 https://zookeeper.apache.org/doc/r3.4.6/ |
| DeleteMembershipTableEntries(String) |
Supprime toutes les entrées de table du clusterId donné |
| InitializeMembershipTable(Boolean) |
Initialise la table d’appartenance basée sur ZooKeeper. |
| InsertRow(MembershipEntry, TableVersion) |
Tente atomiquement d’insérer (ajouter) un nouvel MembershipEntry pour un silo et de mettre également à jour tableVersion. Si l’opération réussit, les modifications suivantes sont apportées à la table :
|
| ReadAll() |
Lit atomiquement le contenu complet de la table d’appartenances. L’élément MembershipTableData retourné inclut toute l’entrée MembershipEntry pour tous les silos de la table et la TableVersion pour cette table. MembershipEntries et TableVersion doivent être lus atomiquement. |
| ReadRow(SiloAddress) |
Lit atomiquement les informations de la table d’appartenance sur un silo donné. Le MembershipTableData retourné inclut une entrée MembershipEntry pour un silo donné et la TableVersion pour cette table. MembershipEntry et TableVersion doivent être lus atomiquement. |
| UpdateIAmAlive(MembershipEntry) |
Mises à jour la partie IAmAlive (colonne) de MembershipEntry pour ce silo. Cette opération doit uniquement mettre à jour la colonne IAmAlive et ne pas modifier les autres colonnes. Cette opération est une « écriture incorrecte » ou une « mise à jour sur place » et est effectuée sans validation etag. En ce qui concerne la mise à jour des eTags : cette opération peut mettre à jour automatiquement l’eTag associé à la ligne de silo donnée, mais elle n’est pas nécessaire. Il peut également laisser l’etag non modifié (« écriture incorrecte »). En ce qui concerne TableVersion : cette opération ne doit pas modifier la TableVersion de la table. Il devrait le laisser intact. Il n’existe aucun scénario dans lequel cette opération pourrait échouer pour des raisons sémantiques de table. Il ne peut échouer qu’en raison de problèmes réseau ou d’indisponibilité de table. |
| UpdateRow(MembershipEntry, String, TableVersion) |
Tente atomiquement de mettre à jour MembershipEntry pour un silo et de mettre également à jour TableVersion. Si l’opération réussit, les modifications suivantes sont apportées à la table :
|