Partager via


FabricServicePartitionClient<C> Classe

Paramètres de type

C

type de client communication

public class FabricServicePartitionClient implements ServicePartitionClient

Spécifie une instance du client de communication qui peut communiquer avec les réplicas d’une partition particulière.

Récapitulatif du constructeur

Constructeur Description
FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName)

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’argument uri de service.

FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey)

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par les arguments partitionkey de l’URI de service.

FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector)

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey et réplica arguments du sélecteur.

FabricServicePartitionClient(CommunicationClientFactory<C> factory, URI serviceName, ServicePartitionKey partitionKey, TargetReplicaSelector targetReplicaSelector, String listenerName)

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey, réplica et les arguments de l’écouteur.

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

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey, réplica et les arguments de l’écouteur.

Résumé de la méthode

Modificateur et type Méthode et description
CommunicationClientFactory<C> getCommunicationClientFactory()

Obtient la fabrique du client de communication

ResolvedServicePartition getLastResolvedServicePartition()

Obtient la partition de service résolue qui a été définie sur le client.

String getListenerName()

Obtient le nom de l’écouteur dans le réplica auquel le client doit se connecter.

ServicePartitionKey getPartitionKey()

Obtient la clé de partition.

URI getServiceUri()

Obtient le nom du service

TargetReplicaSelector getTargetReplicaSelector()

Obtient les informations sur les réplica de la partition à laquelle le client doit se connecter.

<T> CompletableFuture<T> invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, CancellationToken cancellationToken, Class<?>... doNotRetryExceptionTypes)

Appelle la fonction donnée et effectue une nouvelle tentative pour les exceptions levées autres que les exceptions dans les doNotRetryExceptionTypes. Pour les exceptions qui ne se trouvent pas dans doNotRetryExceptionTypes, la méthode ReportOperationExceptionAsync() de CommunicationClientFactory contrôle si l’exception doit être retentée ou non.

<T> CompletableFuture<T> invokeWithRetryAsync(Function<C, CompletableFuture<T>> func, Class<?>... doNotRetryExceptionTypes)

Appelle la fonction donnée et effectue une nouvelle tentative pour les exceptions levées autres que les exceptions dans les doNotRetryExceptionTypes. Pour les exceptions qui ne se trouvent pas dans doNotRetryExceptionTypes, la méthode ReportOperationExceptionAsync() de CommunicationClientFactory contrôle si l’exception doit être retentée ou non.

Détails du constructeur

FabricServicePartitionClient

public FabricServicePartitionClient(CommunicationClientFactory factory, URI serviceName)

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’argument uri de service.

Paramètres:

factory - Fabrique de client de communication
serviceName - Nom du service

FabricServicePartitionClient

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

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par les arguments partitionkey de l’URI de service.

Paramètres:

factory - Fabrique de client de communication
serviceName - Nom du service
partitionKey - Clé de partition utilisée pour identifier la partition au sein du service.

FabricServicePartitionClient

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

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey et réplica arguments du sélecteur.

Paramètres:

factory - Fabrique de client de communication
serviceName - Nom du service
partitionKey - Clé de partition utilisée pour identifier la partition au sein du service.
targetReplicaSelector - Informations sur les réplica cibles

FabricServicePartitionClient

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

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey, réplica et les arguments de l’écouteur.

Paramètres:

factory - Fabrique de client de communication
serviceName - Nom du service
partitionKey - Clé de partition utilisée pour identifier la partition au sein du service.
targetReplicaSelector - Informations sur les réplica cibles
listenerName - Écouteur dans le réplica auquel le client doit se connecter

FabricServicePartitionClient

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

Instancie un client de partition de service qui utilise la fabrique de client de communication spécifiée pour créer un client afin de communiquer avec le point de terminaison de service identifié par l’URI de service, partitionkey, réplica et les arguments de l’écouteur.

Paramètres:

factory - Fabrique de client de communication
serviceName - Nom du service
partitionKey - Clé de partition utilisée pour identifier la partition au sein du service.
targetReplicaSelector - Informations sur les réplica cibles
listenerName - Écouteur dans le réplica auquel le client doit se connecter
retrySettings - Stratégie de nouvelle tentative pour les exceptions observées pendant la communication

Détails de la méthode

getCommunicationClientFactory

public CommunicationClientFactory getCommunicationClientFactory()

Obtient la fabrique du client de communication

Retours:

Fabrique de client de communication

getLastResolvedServicePartition

public ResolvedServicePartition getLastResolvedServicePartition()

Obtient la partition de service résolue qui a été définie sur le client.

Retours:

true si un ResolvedServicePartition a été défini

getListenerName

public String getListenerName()

Obtient le nom de l’écouteur dans le réplica auquel le client doit se connecter.

Retours:

Nom de l’écouteur

getPartitionKey

public ServicePartitionKey getPartitionKey()

Obtient la clé de partition.

Retours:

Clé de partition

getServiceUri

public URI getServiceUri()

Obtient le nom du service

Retours:

Nom du service

getTargetReplicaSelector

public TargetReplicaSelector getTargetReplicaSelector()

Obtient les informations sur les réplica de la partition à laquelle le client doit se connecter.

Retours:

invokeWithRetryAsync

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

Appelle la fonction donnée et effectue une nouvelle tentative pour les exceptions levées autres que les exceptions dans les doNotRetryExceptionTypes. Pour les exceptions qui ne se trouvent pas dans doNotRetryExceptionTypes, la méthode ReportOperationExceptionAsync() de CommunicationClientFactory contrôle si l’exception doit être retentée ou non.

Paramètres:

func - Fonction appelée
cancellationToken - Jeton pour signaler l’annulation d’une opération asynchrone.
doNotRetryExceptionTypes - Exceptions pour lesquelles le client de partition de service ne doit pas réessayer

Retours:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est le résultat de la fonction donnée dans l’argument .

invokeWithRetryAsync

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

Appelle la fonction donnée et effectue une nouvelle tentative pour les exceptions levées autres que les exceptions dans les doNotRetryExceptionTypes. Pour les exceptions qui ne se trouvent pas dans doNotRetryExceptionTypes, la méthode ReportOperationExceptionAsync() de CommunicationClientFactory contrôle si l’exception doit être retentée ou non.

Paramètres:

func - Fonction appelée
doNotRetryExceptionTypes - Exceptions pour lesquelles le client de partition de service ne doit pas réessayer

Retours:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est le résultat de la fonction donnée dans l’argument .

S’applique à