FabricServicePartitionClient<C> クラス

  • リファレンス
パッケージ:
microsoft.servicefabric.services.communication.client

型パラメーター

C

通信クライアントの種類

public class FabricServicePartitionClient implements ServicePartitionClient

特定のパーティションのレプリカと通信できる通信クライアントのインスタンスを指定します。

コンストラクターの概要

コンストラクター 説明
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName)

指定された通信クライアント ファクトリを使用して、サービス URI 引数で識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey)

指定された通信クライアント ファクトリを使用して、サービス URI の partitionkey 引数で識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ セレクター引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ、リスナーの引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ、リスナーの引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

メソッドの概要

修飾子と型 メソッドと説明
CommunicationClientFactory<C> getCommunicationClientFactory()

通信クライアント ファクトリを取得します
ResolvedServicePartition getLastResolvedServicePartition()

クライアントで設定された解決済みサービス パーティションを取得します。
String getListenerName()

クライアントが接続するレプリカ内のリスナーの名前を取得します。
ServicePartitionKey getPartitionKey()

パーティション キーを取得します。
URI getServiceUri()

サービスの名前を取得します
TargetReplicaSelector getTargetReplicaSelector()

クライアントが接続するパーティション内のレプリカに関する情報を取得します。
<T> CompletableFuture<T> invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, CancellationToken cancellationToken, Class<?>... doNotRetryExceptionTypes)

指定された関数を呼び出し、doNotRetryExceptionTypes 内の例外以外にスローされた例外を再試行します。 doNotRetryExceptionTypes にない例外の場合、CommunicationClientFactory の ReportOperationExceptionAsync() メソッドは、例外を再試行するかどうかを制御します。
<T> CompletableFuture<T> invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, Class<?>... doNotRetryExceptionTypes)

指定された関数を呼び出し、doNotRetryExceptionTypes 内の例外以外にスローされた例外を再試行します。 doNotRetryExceptionTypes にない例外の場合、CommunicationClientFactory の ReportOperationExceptionAsync() メソッドは、例外を再試行するかどうかを制御します。

コンストラクターの詳細

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName)

指定された通信クライアント ファクトリを使用して、サービス URI 引数で識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

パラメーター:

factory - 通信クライアント ファクトリ
serviceName - サービスの名前

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey)

指定された通信クライアント ファクトリを使用して、サービス URI の partitionkey 引数で識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

パラメーター:

factory - 通信クライアント ファクトリ
serviceName - サービスの名前
partitionKey - サービス内のパーティションを識別するために使用されるパーティション キー。

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ セレクター引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

パラメーター:

factory - 通信クライアント ファクトリ
serviceName - サービスの名前
partitionKey - サービス内のパーティションを識別するために使用されるパーティション キー。
targetReplicaSelector - ターゲット レプリカ情報

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ、リスナーの引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

パラメーター:

factory - 通信クライアント ファクトリ
serviceName - サービスの名前
partitionKey - サービス内のパーティションを識別するために使用されるパーティション キー。
targetReplicaSelector - ターゲット レプリカ情報
listenerName - クライアントが接続するレプリカ内のリスナー

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName, OperationRetrySettings retrySettings)

指定された通信クライアント ファクトリを使用して、サービス URI、パーティションキー、レプリカ、リスナーの引数によって識別されるサービス エンドポイントと通信するクライアントを作成するサービス パーティション クライアントをインスタンス化します。

パラメーター:

factory - 通信クライアント ファクトリ
serviceName - サービスの名前
partitionKey - サービス内のパーティションを識別するために使用されるパーティション キー。
targetReplicaSelector - ターゲット レプリカ情報
listenerName - クライアントが接続するレプリカ内のリスナー
retrySettings - 通信中に表示される例外の再試行ポリシー

メソッドの詳細

getCommunicationClientFactory

public CommunicationClientFactory getCommunicationClientFactory()

通信クライアント ファクトリを取得します

戻り値:

通信クライアント ファクトリ

getLastResolvedServicePartition

public ResolvedServicePartition getLastResolvedServicePartition()

クライアントで設定された解決済みサービス パーティションを取得します。

戻り値:

ResolvedServicePartition が設定されている場合は true

getListenerName

public String getListenerName()

クライアントが接続するレプリカ内のリスナーの名前を取得します。

戻り値:

リスナー名

getPartitionKey

public ServicePartitionKey getPartitionKey()

パーティション キーを取得します。

戻り値:

パーティション キー

getServiceUri

public URI getServiceUri()

サービスの名前を取得します

戻り値:

サービスの名前

getTargetReplicaSelector

public TargetReplicaSelector getTargetReplicaSelector()

クライアントが接続するパーティション内のレプリカに関する情報を取得します。

戻り値:

invokeWithRetryAsync

public CompletableFuture invokeWithRetryAsync(Function> func, CancellationToken cancellationToken, Class... doNotRetryExceptionTypes)

指定された関数を呼び出し、doNotRetryExceptionTypes 内の例外以外にスローされた例外を再試行します。 doNotRetryExceptionTypes にない例外の場合、CommunicationClientFactory の ReportOperationExceptionAsync() メソッドは、例外を再試行するかどうかを制御します。

パラメーター:

func - 呼び出される関数
cancellationToken - 非同期操作の取り消しを通知するトークン。
doNotRetryExceptionTypes - サービス パーティション クライアントが再試行しない例外

戻り値:

CompletableFuture未処理の操作を表す 。 Task の結果は、 引数で指定された関数の結果です。

invokeWithRetryAsync

public CompletableFuture invokeWithRetryAsync(Function> func, Class... doNotRetryExceptionTypes)

指定された関数を呼び出し、doNotRetryExceptionTypes 内の例外以外にスローされた例外を再試行します。 doNotRetryExceptionTypes にない例外の場合、CommunicationClientFactory の ReportOperationExceptionAsync() メソッドは、例外を再試行するかどうかを制御します。

パラメーター:

func - 呼び出される関数
doNotRetryExceptionTypes - サービス パーティション クライアントが再試行しない例外

戻り値:

CompletableFuture未処理の操作を表す 。 Task の結果は、 引数で指定された関数の結果です。

適用対象