KeyValueStoreReplica クラス

定義

トランザクション、レプリケート、連想データ ストレージ コンポーネントをサービス ライターに提供します。任意の Service Fabric サービスに統合できます。

これは、従来の Service Fabric サービスで使用されます。 新しいサービスはすべて Reliable Collections を使用する必要があります。
public class KeyValueStoreReplica : System.Fabric.IStatefulServiceReplica
type KeyValueStoreReplica = class
    interface IStatefulServiceReplica
Public Class KeyValueStoreReplica
Implements IStatefulServiceReplica
継承
KeyValueStoreReplica
実装

コンストラクター

KeyValueStoreReplica(String)

指定したキー/値ストア名を KeyValueStoreReplica 使用して、 クラスの新しいインスタンスを初期化します。

KeyValueStoreReplica(String, LocalStoreSettings)

指定したキー/値ストア名とローカル ストア設定を使用して、 クラスの新しいインスタンス KeyValueStoreReplica を初期化します。

KeyValueStoreReplica(String, LocalStoreSettings, ReplicatorSettings)

指定したキー/値ストア名、ローカル ストア設定、およびレプリケーター設定を使用して、 クラスの新しいインスタンス KeyValueStoreReplica を初期化します。

KeyValueStoreReplica(String, LocalStoreSettings, ReplicatorSettings, KeyValueStoreReplica+SecondaryNotificationMode)

指定したキー/値ストア名、ローカル ストア設定、およびレプリケーター設定を使用して、 クラスの新しいインスタンス KeyValueStoreReplica を初期化します。 セカンダリ レプリカ通知は、通知モードを使用して有効になります。

KeyValueStoreReplica(String, LocalStoreSettings, ReplicatorSettings, KeyValueStoreReplicaSettings)

KeyValueStoreReplica クラスの新しいインスタンスを、指定したキー/値ストア名、ローカル ストア設定、レプリケーター設定、およびレプリカ設定で初期化します。

KeyValueStoreReplica(String, ReplicatorSettings)

指定したキー/値ストア名とストア レプリケータ設定を使用して、 クラスの新しいインスタンス KeyValueStoreReplica を初期化します。

フィールド

IgnoreSequenceNumberCheck

シーケンス番号チェックを実行しないことを示します。

プロパティ

KeyValueStoreReplicaSettings

のオプション設定 KeyValueStoreReplicaを取得または設定します。

LocalStoreSettings

ローカル キー/値ストアのオプション設定を取得または設定します。

NotificationMode

このレプリカの構築中に指定されたセカンダリ通知モードを取得します。

ReplicatorSettings

キー/値ストア レプリケータのオプション設定を取得または設定します。

StoreName

キー/値ストアの名前を取得または設定します。

メソッド

Abort()

クラスのこのインスタンスを KeyValueStoreReplica 中止します。

Add(TransactionBase, String, Byte[])

指定したキーによってインデックス付けされた値をキー/値ストアに追加します。

Backup(String)
古い.

非推奨。 指定した宛先ディレクトリへのレプリカのローカル ストアの完全バックアップを実行します。

BackupAsync(String, StoreBackupOption, Func<StoreBackupInfo,Task<Boolean>>)

キー/値ストアのバックアップを非同期的に作成します。

BackupAsync(String, StoreBackupOption, Func<StoreBackupInfo,Task<Boolean>>, CancellationToken)

キー/値ストアのバックアップを非同期的に作成します。

ChangeRoleAsync(ReplicaRole, CancellationToken)

レプリカとそのレプリケータのレプリカ ロールを変更します。

CloseAsync(CancellationToken)

レプリカ セットからオフラインになる準備として、レプリカとそのレプリケータを閉じます。

Contains(TransactionBase, String)

値がキー/値ストアに含まれているかどうかを判断します。

CreateTransaction()

キー/値ストア操作のグループをコミットまたはロールバックするために使用される一意 Transaction のインスタンスを作成します。

CreateTransaction(KeyValueStoreTransactionSettings)

キー/値ストア操作のグループをコミットまたはロールバックするために使用される一意 Transaction のインスタンスを作成します。

Enumerate(TransactionBase)

キー/値ストア内の値を反復処理する KeyValueStoreItem 列挙子を返します。

Enumerate(TransactionBase, String)

キー/値ストア内の値を KeyValueStoreItem 反復処理する列挙子を返します。ここで、値キーは指定したキー プレフィックスと一致します。

Enumerate(TransactionBase, String, Boolean)

キー/値ストア内の値を反復処理する KeyValueStoreItem 列挙子を返します。

EnumerateBySequenceNumber(TransactionBase, Int64)

キー/値ストア内の値を KeyValueStoreItem シーケンス番号の順序で反復処理する列挙子を返します。

EnumerateKeysAndTombstonesBySequenceNumber(TransactionBase, Int64)

キー/値ストア内の値と廃棄ストーンを KeyValueStoreItem シーケンス番号の順序で反復処理する列挙子を返します。

EnumerateMetadata(TransactionBase)

キー/値ストア内の値を反復処理する KeyValueStoreItemMetadata 列挙子を返します。

EnumerateMetadata(TransactionBase, String)

キー/値ストア内の値を KeyValueStoreItemMetadata 反復処理する列挙子を返します。ここで、値キーは指定したキー プレフィックスと一致します。

EnumerateMetadata(TransactionBase, String, Boolean)

キー/値ストア内の値を反復処理する KeyValueStoreItemMetadata 列挙子を返します。

Get(TransactionBase, String)

指定したキーに関連付けられた、格納されている値を KeyValueStoreItem オブジェクトとして取得します。

GetCurrentEpoch()

キー/値ストアの現在のエポックを取得します。

GetLastCommittedSequenceNumber()

最後にコミットされたシーケンス番号を取得します

GetLSNSplitPercentile(Int32)

KVS ストアを通る方法の約百分位% の LSN を取得します。

GetMetadata(TransactionBase, String)

指定したキーに関連付けられている値の KeyValueStoreItemMetadata メタデータをオブジェクトとして取得します。

GetValue(TransactionBase, String)

格納されている値を、指定したキーに関連付けられたバイト配列として取得します。

Initialize(StatefulServiceInitializationParameters)

開く準備としてレプリカを初期化します。

OnAbort()

このインスタンスをシャットダウンするために呼び出されます。

OnChangeRoleAsync(ReplicaRole, CancellationToken)

このレプリカがロールを変更していることを示します。

OnCloseAsync(CancellationToken)

このサービス レプリカがシャットダウンされ、閉じる必要がある場合に呼び出されます。

OnCopyComplete(KeyValueStoreEnumerator)

プライマリからのビルドが完了し、レプリケーション操作の適用を開始する準備ができたときに、セカンダリ レプリカ上のシステムによって呼び出されます。

このメソッドは、オブジェクトが有効なKeyValueStoreReplica.SecondaryNotificationModeパラメーターを使用してKeyValueStoreReplica構築された場合にのみ、セカンダリ レプリカで呼び出されます。

OnDataLossAsync(CancellationToken)

レプリカ セットでデータ損失が発生した可能性があることを通知します。 アプリケーションは、このメソッドをオーバーライドしてイベントを非同期的に処理するか、 イベントを DataLossReported 使用して同期的に処理できます。 どちらも同じイベントを表します。

OnDatalossReported(EventArgs)

レプリカ セットでデータ損失が発生した可能性があることを通知します。 アプリケーションは、このメソッドをオーバーライドするか、Event を DataLossReported リッスンできます。 どちらも同じイベントを表します

OnInitialize(StatefulServiceInitializationParameters)

新しく作成されたサービス レプリカを初期化します。

OnOpenAsync(ReplicaOpenMode, IStatefulServicePartition, CancellationToken)

追加のアクションを実行できるように、初期化されたサービス レプリカで呼び出して開きます。

OnReplicationOperation(IEnumerator<KeyValueStoreNotification>)

受信レプリケーション操作のために、セカンダリ レプリカ上のシステムによって呼び出されます。 各 KeyValueStoreNotification オブジェクトには、1 つのアトミック レプリケーション操作のすべてのデータが含まれます。

OnRestoreCompletedAsync(CancellationToken)

レプリカの状態がシステムによって正常に復元されたことを通知します。 これは、システムがバックアップ復元サービスを介して復元を内部的にトリガーする場合にのみ呼び出されます。

OpenAsync(ReplicaOpenMode, IStatefulServicePartition, CancellationToken)

レプリカ セットでオンラインになる準備として、レプリカとそのレプリケータを開きます。

Remove(TransactionBase, String)

指定したキーによってインデックスが作成された値を削除します。

Remove(TransactionBase, String, Int64)

指定したキーによってインデックスが作成された値を削除します。

Restore(String)
古い.

を呼び出 BackupAsync(String, StoreBackupOption, Func<StoreBackupInfo,Task<Boolean>>)して以前に作成したバックアップから、このレプリカのローカル ストア データベースを復元します。

RestoreAsync(String)

を呼び出 BackupAsync(String, StoreBackupOption, Func<StoreBackupInfo,Task<Boolean>>)して以前に作成したバックアップから、このレプリカのローカル ストア データベースを復元します。

RestoreAsync(String, CancellationToken)

を呼び出 BackupAsync(String, StoreBackupOption, Func<StoreBackupInfo,Task<Boolean>>)して以前に作成したバックアップから、このレプリカのローカル ストア データベースを復元します。

RestoreAsync(String, RestoreSettings, CancellationToken)

キー/値ストア レプリカを非同期的に復元します。

TryAbortExistingTransactionsAndRejectWrites()

KVS から別のデータ ストアにデータを移行するために使用することを目的としています。 を呼び出した後、書き込みはレプリカの再起動までブロックされたままになります。 KVS が別のストアへの最終的な移行の準備ができているかどうかを確認します。 これが呼び出され、KVS が移行準備を開始していない場合 (KVS フェールオーバーの場合に発生します)、これは再び準備を開始します。

TryAdd(TransactionBase, String, Byte[])

指定したキーによってインデックス付けされた値をキー/値ストアに追加しようとします。

TryGet(TransactionBase, String)

指定したキーに関連付けられた、格納されている値を KeyValueStoreItem オブジェクトとして取得しようとします。

TryGetMetadata(TransactionBase, String)

指定したキーに関連付けられている値の KeyValueStoreItemMetadata メタデータをオブジェクトとして取得しようとします。

TryGetValue(TransactionBase, String)

指定したキーに関連付けられたバイト配列として格納された値を取得しようとします。

TryRemove(TransactionBase, String)

指定したキーによってインデックス付けされた値の削除を試みます。

TryRemove(TransactionBase, String, Int64)

指定したキーによってインデックス付けされた値の削除を試みます。

TryUpdate(TransactionBase, String, Byte[])

指定したキーによってインデックス付けされた値の更新を試みます。

TryUpdate(TransactionBase, String, Byte[], Int64)

指定したキーによってインデックス付けされた値の更新を試みます。

Update(TransactionBase, String, Byte[])

指定したキーに関連付けられている格納された値を更新します。

Update(TransactionBase, String, Byte[], Int64)

指定したキーによってインデックスが作成された値を更新します。

UpdateReplicatorSettings(ReplicatorSettings)

指定したReplicatorSettingsオブジェクトの設定を使用して、キー/値ストア レプリケータを更新します。

イベント

DataLossReported

データ損失イベントのハンドラー。

適用対象