ZooKeeperBasedMembershipTable クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
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- 継承
-
ZooKeeperBasedMembershipTable
- 実装
注釈
使用される ZK 機能の簡単な概要: データはノードのツリー (ファイル システムと同様) で表されます。 すべてのノードはパスによってアドレス指定され、データをバイト配列として保持でき、バージョンがあります。 ノードが作成されると、そのバージョンは 0 になります。 更新時に、バージョンはアトミックにインクリメントされます。 更新プログラムは、予想される現在のバージョンで条件付きにすることもできます。 トランザクションには、成功または失敗する複数の操作をアトミックに保持できます。 zookeeper クライアントを作成するときに、すべての操作が相対的なベース パスを設定できます。
この実装では、すべての Orleans デプロイにノード /UniqueDeploymentId があります。すべてのサイロの状態は /UniqueDeploymentId/IP:Port@Gen すべてのサイロの IAmAlive が /UniqueDeploymentId/IP:Port@Gen/IAmAlive IAmAlive に保存されます。更新は無条件であるため、別のノードに保存されます。
ノードの ZK バージョンは ETag です。テーブル のバージョンは /UniqueDeploymentId のバージョンであり、サイロ エントリ のバージョンは /UniqueDeploymentId/IP:Port@Gen
コンストラクター
| ZooKeeperBasedMembershipTable(ILogger<ZooKeeperBasedMembershipTable>, IOptions<ZooKeeperClusteringSiloOptions>, IOptions<ClusterOptions>) |
Apache Zookeeper 3.4.6 を使用したメンバーシップ テーブルの実装 https://zookeeper.apache.org/doc/r3.4.6/ |
メソッド
| CleanupDefunctSiloEntries(DateTimeOffset) |
Apache Zookeeper 3.4.6 を使用したメンバーシップ テーブルの実装 https://zookeeper.apache.org/doc/r3.4.6/ |
| DeleteMembershipTableEntries(String) |
指定された clusterId のすべてのテーブル エントリを削除します |
| InitializeMembershipTable(Boolean) |
ZooKeeper ベースのメンバーシップ テーブルを初期化します。 |
| InsertRow(MembershipEntry, TableVersion) |
1 つのサイロに対して新しい MembershipEntry をアトミックに挿入 (追加) し、TableVersion も更新しようとします。 操作が成功すると、テーブルに対して次の変更が行われます。
|
| ReadAll() |
メンバーシップ テーブルの完全な内容をアトミックに読み取ります。 返される MembershipTableData には、テーブル内のすべてのサイロのすべての MembershipEntry エントリと、このテーブルの TableVersion が含まれます。 MembershipEntries と TableVersion はアトミックに読み取る必要があります。 |
| ReadRow(SiloAddress) |
特定のサイロに関するメンバーシップ テーブル情報をアトミックに読み取ります。 返される MembershipTableData には、特定のサイロに対して 1 つの MembershipEntry エントリと、このテーブルの TableVersion が含まれます。 MembershipEntry と TableVersion はアトミックに読み取る必要があります。 |
| UpdateIAmAlive(MembershipEntry) |
このサイロの MembershipEntry の IAmAlive パーツ (列) を更新します。 この操作では、IAmAlive 列のみを更新し、他の列を変更しないでください。 この操作は"ダーティ書き込み" または "インプレース更新" であり、etag 検証なしで実行されます。 eTag の更新に関して: この操作では、指定されたサイロ行に関連付けられている eTag が自動的に更新される可能性がありますが、更新する必要はありません。 また、etag を変更しないようにすることもできます ("ダーティライト")。 TableVersion に関して: この操作では、テーブルの TableVersion を変更しないでください。 それは手つかずのままにする必要があります。 テーブルの意味上の理由により、この操作が失敗する可能性があるシナリオはありません。 ネットワークの問題またはテーブルが使用できないことが原因でのみ失敗する可能性があります。 |
| UpdateRow(MembershipEntry, String, TableVersion) |
1 つのサイロの MembershipEntry をアトミックに更新し、TableVersion も更新しようとします。 操作が成功すると、テーブルに対して次の変更が行われます。
|