ReplicatorSettings クラス

パッケージ:

system.fabric

• java.lang.Object
• • system.fabric.ReplicatorSettings

public class ReplicatorSettings

ステートフル レプリカで作成時に を FabricReplicator 構成できるようにします createReplicator(StateProvider stateProvider, ReplicatorSettings replicatorSettings)

コンストラクターの概要

コンストラクター	説明
ReplicatorSettings()

メソッドの概要

修飾子と型	メソッドと説明
Duration	getBatchAcknowledgementInterval() 受信確認を返す前に、操作を受信した後にレプリケーターが待機する時間を取得します。 発言：この期間中に受信および確認されたその他の操作では、受信確認が 1 つのメッセージで返送されます。 値を system.fabric.ReplicatorSettings#batchAcknowledgementInterval 大きくすると、個々のレプリケーション操作の待機時間は短縮されますが、レプリケータのスループットは向上します。 既定値は 0.05 秒 (50 ミリ秒) です
long	getInitialCopyQueueSize() 内のコピー操作キューの初期サイズを取得します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。 発言：既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
long	getInitialPrimaryReplicationQueueSize() 内 FabricReplicatorのプライマリ レプリケーション操作キューの初期サイズを定義します。この中にはレプリケーション Operations が含まれます。ここでのユニットは、キュー内の操作の数です。 発言：この設定は、サービスのロールが [プライマリ] の場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
long	getInitialReplicationQueueSize() レプリケーション キュー サイズの初期サイズを取得します。
long	getInitialSecondaryReplicationQueueSize() 内 FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズを Operation定義します。 発言：この設定は、サービスのロールがセカンダリ/アイドルの場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
long	getMaxCopyQueueSize() 内のコピー操作キューの最大サイズを取得します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。 発言：セカンダリでこのキュー サイズに達すると、操作はプライマリのコピー キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外の表示 system.fabric.FabricErrorCode#ReplicationQueueFull が開始されます。 既定値は 1024 です
long	getMaxPrimaryReplicationQueueMemorySize() 内FabricReplicatorOperationのプライマリ レプリケーション操作キューの最大サイズを定義します。 発言：この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します
long	getMaxPrimaryReplicationQueueSize() 内FabricReplicatorOperationのプライマリ レプリケーション操作キューの最大サイズを定義します。 発言：このキュー サイズに達すると、プライマリに例外の表示 system.fabric.FabricErrorCode#ReplicationQueueFull が開始されます。 既定値は 1024 です。このパラメーターの値は 2 の累乗である必要があります。 この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です
Long	getMaxReplicationMessageSize() レプリケータを介して送信できるメッセージの最大サイズを取得します。 これには、レプリケーション メッセージ、メッセージのコピー、コンテキスト メッセージのコピーが含まれます。 表現の単位はバイトです。 発言：既定値は 50 MB です
long	getMaxReplicationQueueMemorySize() レプリケーション キュー メモリの最大サイズを取得します。 発言：既定値は 0 です。 これは、メモリ制限がないことを意味します
long	getMaxReplicationQueueSize() レプリケーション キューの最大サイズを取得します。
long	getMaxSecondaryReplicationQueueMemorySize() 内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューにはレプリケーション Operationが含まれます。 発言：この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します
long	getMaxSecondaryReplicationQueueSize() 内FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation 発言：このキュー サイズに達すると、操作はプライマリのレプリケーション キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 2048 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です
Duration	getPrimaryWaitForPendingQuorumsTimeout() プライマリ レプリケーターが、再構成要求を処理する前に保留中のレプリケーション操作のクォーラム受信を待機する時間を定義します。この場合、保留中のレプリケーション操作が "取り消し" される可能性があります。 発言：既定値は 0 です。 これは、保留中のレプリケーション操作でクォーラムを受信するために再構成が待機されないことを意味します。 これは、より早く再構成を完了するのに役立ちます。 このパラメーターの値を大きくすると、再構成が遅くなる可能性があり、プライマリをフェールオーバーする期間が長くなる可能性があることに注意してください。
String	getReplicatorAddress() このレプリケーターが他のレプリケーターと通信するときに使用するアドレスを構成します。 発言：文字列は "hostname:port" として書式設定されます。ホスト名には FQDN または IP アドレスを指定できます。 既定値は localhost:0 です
Duration	getRetryInterval() セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する時間を定義します。 発言：メッセージを受信しても、必ずしもメッセージが処理されたとは限りません。 このタイマーを超えると、メッセージが再送信されます。 既定値は 5 秒です。
SecurityCredentials	getSecurityCredentials() サービスがレプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義できるようにします。
boolean	isRequireServiceAck() サービスが次の操作をポンプする前に を呼び出 acknowledge() すように要求することで、非永続的サービスでの操作のオプティミスティック受信確認を防止します。 発言：明示的な受信確認を必要とする非永続的サービスでは、レプリケーターによる操作のオプティミスティック受信確認を防ぐために、このプロパティを True に設定できます。 この設定は、永続的なサービスには影響しません。 既定値は false です。
boolean	isSecondaryClearAcknowledgedOperations() 通常、セカンダリ レプリケーターの操作は、プライマリに昇格された場合にレプリカをキャッチアップできるようにキューに保持されます。 このフラグを有効にすると、セカンダリ レプリケーターは、ユーザー サービスによって承認されるとすぐに操作を解放します。 発言：既定値は false です
boolean	isUseStreamFaultsAndEndOfStreamOperationAck() レプリケーターがストリーム 障害を使用するかどうかを指定します。 発言：既定値は false です
ReplicatorSettings	loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)
void	setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval) レプリケーターが操作を受信してから受信確認を返すまで待機する時間を設定します。 発言：この期間中に受信および確認されたその他の操作では、受信確認が 1 つのメッセージで返されます。 値を system.fabric.ReplicatorSettings#batchAcknowledgementInterval 大きくすると、個々のレプリケーション操作の待機時間は短縮されますが、レプリケーターのスループットは向上します。 既定値は 0.05 秒 (50 ミリ秒) です
void	setInitialCopyQueueSize(long initialCopyQueueSize) 内のコピー操作キューの初期サイズを取得または設定します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。 発言：既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
void	setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize) 内 FabricReplicatorのプライマリ レプリケーション操作キューの初期サイズを定義します。このサイズにはレプリケーション Operations が含まれます。ここでのユニットは、キュー内の操作の数です。 発言：この設定は、サービスのロールが [プライマリ] の場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
void	setInitialReplicationQueueSize(long initialReplicationQueueSize) レプリケーション キュー サイズの初期サイズを設定します。
void	setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize) 内FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズを定義します。このキューには、Operation 発言：この設定は、サービスの役割が [セカンダリ/アイドル] の場合にレプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。
void	setMaxCopyQueueSize(long maxCopyQueueSize) 内 FabricReplicatorのコピー操作キューの最大サイズを設定します。このキューには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。 発言：このキュー サイズにセカンダリで到達した場合、操作はプライマリのコピー キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 1024 です
void	setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize) 内FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation 発言：この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します
void	setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize) 内FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation 発言：このキュー サイズに達すると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 1024 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です
void	setMaxReplicationMessageSize(long maxReplicationMessageSize) レプリケーターを介して送信できるメッセージの最大サイズを設定します。 これには、レプリケーション メッセージ、メッセージのコピー、コンテキスト メッセージのコピーが含まれます。 表現の単位はバイトです。 発言：既定値は 50 MB です
void	setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize) レプリケーション キュー メモリの最大サイズを設定します。 発言：既定値は 0 です。 これは、メモリ制限がないことを意味します
void	setMaxReplicationQueueSize(long maxReplicationQueueSize) レプリケーション キューの最大サイズを設定します。
void	setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize) 内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューにはレプリケーション Operationが含まれます。 発言：この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します
void	setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize) 内FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation 発言：このキュー サイズに達すると、操作はプライマリのレプリケーション キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 2048 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です
void	setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout) プライマリ レプリケーターが、再構成要求を処理する前に保留中のレプリケーション操作のクォーラム受信を待機する時間を定義します。この場合、保留中のレプリケーション操作が "取り消し" される可能性があります。 発言：既定値は 0 です。 これは、保留中のレプリケーション操作でクォーラムを受信するために再構成が待機されないことを意味します。 これは、より早く再構成を完了するのに役立ちます。 このパラメーターの値を大きくすると、再構成が遅くなる可能性があり、プライマリをフェールオーバーする期間が長くなる可能性があることに注意してください。
void	setReplicatorAddress(String replicatorAddress) このレプリケーターが他のレプリケーターと通信するときに使用するアドレスを構成します。 発言：文字列は "hostname:port" として書式設定されます。ホスト名には FQDN または IP アドレスを指定できます。 既定値は localhost:0 です
void	setRequireServiceAck(boolean requireServiceAck) サービスが次の操作をポンプする前に を呼び出 acknowledge() すように要求することで、非永続的サービスでの操作のオプティミスティック受信確認を防止します。 発言：明示的な受信確認を必要とする非永続的サービスでは、レプリケーターによる操作のオプティミスティック受信確認を防ぐために、このプロパティを True に設定できます。 この設定は、永続的なサービスには影響しません。 既定値は false です。
void	setRetryInterval(Duration retryInterval) セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する時間を定義します。 発言：メッセージを受信しても、必ずしもメッセージが処理されたとは限りません。 このタイマーを超えると、メッセージが再送信されます。 既定値は 5 秒です。
void	setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations) 通常、セカンダリ レプリケーターの操作は、プライマリに昇格された場合にレプリカをキャッチアップできるようにキューに保持されます。 このフラグを有効にすると、セカンダリ レプリケーターは、ユーザー サービスによって承認されるとすぐに操作を解放します。 発言：既定値は false です
void	setSecurityCredentials(SecurityCredentials securityCredentials) サービスがレプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義できるようにします。
void	setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck) レプリケーターがストリーム 障害を使用するかどうかを指定します。 発言：既定値は false です
long	toNative(PinCollection pinCollection)
String	toString()

コンストラクターの詳細

ReplicatorSettings

public ReplicatorSettings()

メソッドの詳細

getBatchAcknowledgementInterval

public Duration getBatchAcknowledgementInterval()

受信確認を返す前に、操作を受信した後にレプリケーターが待機する時間を取得します。

発言：この期間中に受信および確認されたその他の操作では、受信確認が 1 つのメッセージで返送されます。 値を system.fabric.ReplicatorSettings#batchAcknowledgementInterval 大きくすると、個々のレプリケーション操作の待機時間は短縮されますが、レプリケータのスループットは向上します。 既定値は 0.05 秒 (50 ミリ秒) です

戻り値:

レプリケータが操作を受信してから受信確認を返すまで待機する時間。

getInitialCopyQueueSize

public long getInitialCopyQueueSize()

内のコピー操作キューの初期サイズを取得します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

発言：既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

戻り値:

内 FabricReplicatorのコピー操作キューの初期サイズ。サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

getInitialPrimaryReplicationQueueSize

public long getInitialPrimaryReplicationQueueSize()

内 FabricReplicatorのプライマリ レプリケーション操作キューの初期サイズを定義します。この中にはレプリケーション Operations が含まれます。ここでのユニットは、キュー内の操作の数です。

発言：この設定は、サービスのロールが [プライマリ] の場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

戻り値:

内部のプライマリ レプリケーション操作キューの初期サイズ FabricReplicator

getInitialReplicationQueueSize

public long getInitialReplicationQueueSize()

レプリケーション キュー サイズの初期サイズを取得します。

戻り値:

レプリケーション キュー サイズの初期サイズ。

getInitialSecondaryReplicationQueueSize

public long getInitialSecondaryReplicationQueueSize()

内 FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズを Operation定義します。

発言：この設定は、サービスのロールがセカンダリ/アイドルの場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

戻り値:

内 FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズ。サービスによってまだポンプおよび処理されていないレプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です

getMaxCopyQueueSize

public long getMaxCopyQueueSize()

内のコピー操作キューの最大サイズを取得します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

発言：セカンダリでこのキュー サイズに達すると、操作はプライマリのコピー キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外の表示 system.fabric.FabricErrorCode#ReplicationQueueFull が開始されます。 既定値は 1024 です

戻り値:

内 FabricReplicatorのコピー操作キューの最大サイズ。サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

getMaxPrimaryReplicationQueueMemorySize

public long getMaxPrimaryReplicationQueueMemorySize()

内FabricReplicatorOperationのプライマリ レプリケーション操作キューの最大サイズを定義します。

発言：この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します

戻り値:

. 内 FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズを返します。この中には、レプリケーション Operationが含まれています。ここでのユニットは、キューの仮想メモリ消費量です。long を返します。

getMaxPrimaryReplicationQueueSize

public long getMaxPrimaryReplicationQueueSize()

内FabricReplicatorOperationのプライマリ レプリケーション操作キューの最大サイズを定義します。

発言：このキュー サイズに達すると、プライマリに例外の表示 system.fabric.FabricErrorCode#ReplicationQueueFull が開始されます。 既定値は 1024 です。このパラメーターの値は 2 の累乗である必要があります。 この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です

戻り値:

内のプライマリ レプリケーション操作キューの最大サイズ。このキュー FabricReplicatorには レプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です。

getMaxReplicationMessageSize

public Long getMaxReplicationMessageSize()

レプリケータを介して送信できるメッセージの最大サイズを取得します。 これには、レプリケーション メッセージ、メッセージのコピー、コンテキスト メッセージのコピーが含まれます。 表現の単位はバイトです。

発言：既定値は 50 MB です

戻り値:

レプリケータを介して送信できるメッセージの最大サイズ。

getMaxReplicationQueueMemorySize

public long getMaxReplicationQueueMemorySize()

レプリケーション キュー メモリの最大サイズを取得します。

発言：既定値は 0 です。 これは、メモリ制限がないことを意味します

戻り値:

レプリケーション キュー メモリの最大サイズ。

getMaxReplicationQueueSize

public long getMaxReplicationQueueSize()

レプリケーション キューの最大サイズを取得します。

戻り値:

レプリケーション キューの最大サイズ。

getMaxSecondaryReplicationQueueMemorySize

public long getMaxSecondaryReplicationQueueMemorySize()

内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューにはレプリケーション Operationが含まれます。

発言：この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します

戻り値:

内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを返します。このキューにはレプリケーション Operationが含まれます。 ここでのユニットは、キューの仮想メモリ消費量です。

getMaxSecondaryReplicationQueueSize

public long getMaxSecondaryReplicationQueueSize()

内FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation

発言：このキュー サイズに達すると、操作はプライマリのレプリケーション キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 2048 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です

戻り値:

内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズ。サービスによってまだポンプおよび処理されていないレプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です

getPrimaryWaitForPendingQuorumsTimeout

public Duration getPrimaryWaitForPendingQuorumsTimeout()

プライマリ レプリケーターが、再構成要求を処理する前に保留中のレプリケーション操作のクォーラム受信を待機する時間を定義します。この場合、保留中のレプリケーション操作が "取り消し" される可能性があります。

発言：既定値は 0 です。 これは、保留中のレプリケーション操作でクォーラムを受信するために再構成が待機されないことを意味します。 これは、より早く再構成を完了するのに役立ちます。 このパラメーターの値を大きくすると、再構成が遅くなる可能性があり、プライマリをフェールオーバーする期間が長くなる可能性があることに注意してください。

戻り値:

プライマリ レプリケーターが再構成 java.time.Durationを処理する要求がある場合に、保留中のレプリケーション操作に対する受信確認のクォーラムの受信をプライマリ レプリケーターが待機する時間。

getReplicatorAddress

public String getReplicatorAddress()

このレプリケーターが他のレプリケーターと通信するときに使用するアドレスを構成します。

発言：文字列は "hostname:port" として書式設定されます。ホスト名には FQDN または IP アドレスを指定できます。 既定値は localhost:0 です

戻り値:

このレプリケーターが他のレプリケーターと通信するときに使用するアドレス。

getRetryInterval

public Duration getRetryInterval()

セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する時間を定義します。

発言：メッセージを受信しても、必ずしもメッセージが処理されたとは限りません。 このタイマーを超えると、メッセージが再送信されます。 既定値は 5 秒です。

戻り値:

セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する必要がある時間。

getSecurityCredentials

public SecurityCredentials getSecurityCredentials()

サービスがレプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義できるようにします。

戻り値:

レプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義するサービス。

isRequireServiceAck

public boolean isRequireServiceAck()

サービスが次の操作をポンプする前に を呼び出 acknowledge() すように要求することで、非永続的サービスでの操作のオプティミスティック受信確認を防止します。

発言：明示的な受信確認を必要とする非永続的サービスでは、レプリケーターによる操作のオプティミスティック受信確認を防ぐために、このプロパティを True に設定できます。 この設定は、永続的なサービスには影響しません。 既定値は false です。

戻り値:

非永続的サービスでの操作のオプティミスティック受信確認の場合は true、それ以外の場合は false。

isSecondaryClearAcknowledgedOperations

public boolean isSecondaryClearAcknowledgedOperations()

通常、セカンダリ レプリケーターの操作は、プライマリに昇格された場合にレプリカをキャッチアップできるようにキューに保持されます。 このフラグを有効にすると、セカンダリ レプリケーターは、ユーザー サービスによって承認されるとすぐに操作を解放します。

発言：既定値は false です

戻り値:

セカンダリ レプリケーターがユーザー サービスによって確認されるとすぐに操作を解放する場合は true。それ以外の場合は false。

isUseStreamFaultsAndEndOfStreamOperationAck

public boolean isUseStreamFaultsAndEndOfStreamOperationAck()

レプリケーターがストリーム 障害を使用するかどうかを指定します。

発言：既定値は false です

戻り値:

レプリケーターがストリーム 障害を使用する場合は true。それ以外の場合は false。

loadFrom

public static ReplicatorSettings loadFrom(FabricCodePackageActivationContext codePackageActivationContext, String configPackageName, String sectionName)

パラメーター:

codePackageActivationContext

configPackageName

sectionName

setBatchAcknowledgementInterval

public void setBatchAcknowledgementInterval(Duration batchAcknowledgementInterval)

レプリケーターが操作を受信してから受信確認を返すまで待機する時間を設定します。

発言：この期間中に受信および確認されたその他の操作では、受信確認が 1 つのメッセージで返されます。 値を system.fabric.ReplicatorSettings#batchAcknowledgementInterval 大きくすると、個々のレプリケーション操作の待機時間は短縮されますが、レプリケーターのスループットは向上します。 既定値は 0.05 秒 (50 ミリ秒) です

パラメーター:

batchAcknowledgementInterval - レプリケーターが操作を受信してから受信確認を送信するまで待機する時間。

setInitialCopyQueueSize

public void setInitialCopyQueueSize(long initialCopyQueueSize)

内のコピー操作キューの初期サイズを取得または設定します。このキュー FabricReplicatorには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

発言：既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

パラメーター:

initialCopyQueueSize - 内 FabricReplicatorのコピー操作キューの初期サイズ。サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

setInitialPrimaryReplicationQueueSize

public void setInitialPrimaryReplicationQueueSize(long initialPrimaryReplicationQueueSize)

内 FabricReplicatorのプライマリ レプリケーション操作キューの初期サイズを定義します。このサイズにはレプリケーション Operations が含まれます。ここでのユニットは、キュー内の操作の数です。

発言：この設定は、サービスのロールが [プライマリ] の場合、レプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

パラメーター:

initialPrimaryReplicationQueueSize - 内部のプライマリ レプリケーション操作キューの初期サイズ FabricReplicator

setInitialReplicationQueueSize

public void setInitialReplicationQueueSize(long initialReplicationQueueSize)

レプリケーション キュー サイズの初期サイズを設定します。

パラメーター:

initialReplicationQueueSize - レプリケーション キュー サイズの初期サイズ。

setInitialSecondaryReplicationQueueSize

public void setInitialSecondaryReplicationQueueSize(long initialSecondaryReplicationQueueSize)

内FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズを定義します。このキューには、Operation

発言：この設定は、サービスの役割が [セカンダリ/アイドル] の場合にレプリケーターに固有です。既定値は 64 です。 このパラメーターの値は 2 の累乗である必要があることに注意してください。

パラメーター:

initialSecondaryReplicationQueueSize - 内 FabricReplicatorのセカンダリ レプリケーション操作キューの初期サイズ。サービスによってまだポンプおよび処理されていないレプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です

setMaxCopyQueueSize

public void setMaxCopyQueueSize(long maxCopyQueueSize)

内 FabricReplicatorのコピー操作キューの最大サイズを設定します。このキューには、サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

発言：このキュー サイズにセカンダリで到達した場合、操作はプライマリのコピー キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 1024 です

パラメーター:

maxCopyQueueSize - 内 FabricReplicatorのコピー操作キューの最大サイズ。サービスによってまだポンプおよび処理されていないコピー Operationが含まれます。

setMaxPrimaryReplicationQueueMemorySize

public void setMaxPrimaryReplicationQueueMemorySize(long maxPrimaryReplicationQueueMemorySize)

内FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation

発言：この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します

パラメーター:

maxPrimaryReplicationQueueMemorySize - 内 FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズ。このキューにはレプリケーション Operationが含まれます。ここでのユニットは、キューの仮想メモリ消費量です。long を返します。

setMaxPrimaryReplicationQueueSize

public void setMaxPrimaryReplicationQueueSize(long maxPrimaryReplicationQueueSize)

内FabricReplicatorのプライマリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation

発言：このキュー サイズに達すると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 1024 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスのロールがプライマリの場合にレプリケーターに固有です

パラメーター:

maxPrimaryReplicationQueueSize - 内のプライマリ レプリケーション操作キューの最大サイズ。このキュー FabricReplicatorにはレプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です。

setMaxReplicationMessageSize

public void setMaxReplicationMessageSize(long maxReplicationMessageSize)

レプリケーターを介して送信できるメッセージの最大サイズを設定します。 これには、レプリケーション メッセージ、メッセージのコピー、コンテキスト メッセージのコピーが含まれます。 表現の単位はバイトです。

発言：既定値は 50 MB です

パラメーター:

maxReplicationMessageSize - レプリケーターを介して送信できるメッセージの最大サイズ。

setMaxReplicationQueueMemorySize

public void setMaxReplicationQueueMemorySize(long maxReplicationQueueMemorySize)

レプリケーション キュー メモリの最大サイズを設定します。

発言：既定値は 0 です。 これは、メモリ制限がないことを意味します

パラメーター:

maxReplicationQueueMemorySize - レプリケーション キュー メモリの最大サイズ。

setMaxReplicationQueueSize

public void setMaxReplicationQueueSize(long maxReplicationQueueSize)

レプリケーション キューの最大サイズを設定します。

パラメーター:

maxReplicationQueueSize - レプリケーション キューの最大サイズ。

setMaxSecondaryReplicationQueueMemorySize

public void setMaxSecondaryReplicationQueueMemorySize(long maxSecondaryReplicationQueueMemorySize)

内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューにはレプリケーション Operationが含まれます。

発言：この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です。 既定値は 0 です。 これは、メモリ制限がないことを意味します

パラメーター:

maxSecondaryReplicationQueueMemorySize - 内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを返します。このキューにはレプリケーション Operationが含まれます。 ここでのユニットは、キューの仮想メモリ消費量です。

setMaxSecondaryReplicationQueueSize

public void setMaxSecondaryReplicationQueueSize(long maxSecondaryReplicationQueueSize)

内FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズを定義します。このキューには、Operation

発言：このキュー サイズに達すると、操作はプライマリのレプリケーション キューにバッファーされます。 そのキューもいっぱいになると、プライマリに例外が表示 system.fabric.FabricErrorCode#ReplicationQueueFull されます。 既定値は 2048 です。このパラメーターの値は 2 の累乗である必要があることに注意してください。 この設定は、サービスの役割がセカンダリ/アイドルの場合にレプリケーターに固有です

パラメーター:

maxSecondaryReplicationQueueSize - 内 FabricReplicatorのセカンダリ レプリケーション操作キューの最大サイズ。サービスによってまだポンプおよび処理されていないレプリケーション Operationが含まれます。 ここでのユニットは、キュー内の操作の数です

setPrimaryWaitForPendingQuorumsTimeout

public void setPrimaryWaitForPendingQuorumsTimeout(Duration primaryWaitForPendingQuorumsTimeout)

プライマリ レプリケーターが、再構成要求を処理する前に保留中のレプリケーション操作のクォーラム受信を待機する時間を定義します。この場合、保留中のレプリケーション操作が "取り消し" される可能性があります。

発言：既定値は 0 です。 これは、保留中のレプリケーション操作でクォーラムを受信するために再構成が待機されないことを意味します。 これは、より早く再構成を完了するのに役立ちます。 このパラメーターの値を大きくすると、再構成が遅くなる可能性があり、プライマリをフェールオーバーする期間が長くなる可能性があることに注意してください。

パラメーター:

primaryWaitForPendingQuorumsTimeout - プライマリ レプリケーターが再構成 java.time.Durationを処理する要求がある場合に、保留中のレプリケーション操作に対する受信確認のクォーラムの受信をプライマリ レプリケーターが待機する時間。

setReplicatorAddress

public void setReplicatorAddress(String replicatorAddress)

このレプリケーターが他のレプリケーターと通信するときに使用するアドレスを構成します。

発言：文字列は "hostname:port" として書式設定されます。ホスト名には FQDN または IP アドレスを指定できます。 既定値は localhost:0 です

パラメーター:

replicatorAddress - このレプリケーターが他のレプリケーターと通信するときに使用するアドレス。

setRequireServiceAck

public void setRequireServiceAck(boolean requireServiceAck)

サービスが次の操作をポンプする前に を呼び出 acknowledge() すように要求することで、非永続的サービスでの操作のオプティミスティック受信確認を防止します。

発言：明示的な受信確認を必要とする非永続的サービスでは、レプリケーターによる操作のオプティミスティック受信確認を防ぐために、このプロパティを True に設定できます。 この設定は、永続的なサービスには影響しません。 既定値は false です。

パラメーター:

requireServiceAck - 非永続的サービスでの操作のオプティミスティック受信確認の場合は true、それ以外の場合は false。

setRetryInterval

public void setRetryInterval(Duration retryInterval)

セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する時間を定義します。

発言：メッセージを受信しても、必ずしもメッセージが処理されたとは限りません。 このタイマーを超えると、メッセージが再送信されます。 既定値は 5 秒です。

パラメーター:

retryInterval - セカンダリがメッセージを FabricReplicator 受信したことを確認するためにプライマリからセカンダリにメッセージを送信した後に待機する必要がある時間。

setSecondaryClearAcknowledgedOperations

public void setSecondaryClearAcknowledgedOperations(boolean secondaryClearAcknowledgedOperations)

通常、セカンダリ レプリケーターの操作は、プライマリに昇格された場合にレプリカをキャッチアップできるようにキューに保持されます。 このフラグを有効にすると、セカンダリ レプリケーターは、ユーザー サービスによって承認されるとすぐに操作を解放します。

発言：既定値は false です

パラメーター:

secondaryClearAcknowledgedOperations - セカンダリ レプリケーターがユーザー サービスによって確認されるとすぐに操作を解放する場合は true。それ以外の場合は false。

setSecurityCredentials

public void setSecurityCredentials(SecurityCredentials securityCredentials)

サービスがレプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義できるようにします。

パラメーター:

securityCredentials - レプリケーター間のトラフィックをセキュリティで保護するためのセキュリティ資格情報を定義するサービス。

setUseStreamFaultsAndEndOfStreamOperationAck

public void setUseStreamFaultsAndEndOfStreamOperationAck(boolean useStreamFaultsAndEndOfStreamOperationAck)

レプリケーターがストリーム 障害を使用するかどうかを指定します。

発言：既定値は false です

パラメーター:

useStreamFaultsAndEndOfStreamOperationAck - レプリケーターがストリーム 障害を使用する場合は true。それ以外の場合は false。

toNative

public long toNative(PinCollection pinCollection)

パラメーター:

pinCollection

toString

public String toString()