Partager via

FabricServicePartitionResolver Classe

  • Référence
Paquet:
microsoft.servicefabric.services.client

public class FabricServicePartitionResolver implements ServicePartitionResolver

Implémente la classe qui aide à déterminer le point de terminaison d’un service. Cette classe encapsule la méthode de system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(java.net.URI) FabricClient et implémente un mécanisme de sauvegarde/nouvelle tentative sur les erreurs de cette méthode.

Récapitulatif du champ

Modificateur et type Champ et description
final Duration defaultMaxRetryBackoffInterval

Il s’agit de l’intervalle de retour de nouvelle tentative maximale par défaut utilisé par la méthode ResolveAsync de ServicePartitionResolver lorsqu’elle est appelée sans spécifier explicitement l’argument maxRetryBackoffInterval.

final Duration defaultResolveTimeout

Il s’agit du délai d’expiration de résolution par défaut par tentative utilisé par la méthode ResolveAsync de ServicePartitionResolver lorsqu’elle est appelée sans spécifier explicitement l’argument resolveTimeoutPerTry.

Récapitulatif du constructeur

Constructeur Description
FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)

Instancie un ServicePartitionResolver, utilise les paramètres FabricClient et les points de terminaison de connexion donnés pour créer un instance de FabricClient.
FabricServicePartitionResolver(String... connectionEndpoints)

Instancie un ServicePartitionResolver, utilise les points de terminaison de connexion donnés pour créer un instance de FabricClient.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient)

Instancie un ServicePartitionResolver, appelant le délégué donné pour instancier FabricClient.
FabricServicePartitionResolver(Supplier<FabricClient> createFabricClient, Supplier<FabricClient> recreateFabricClient)

Instancie un ServicePartionResolver, appelant le premier délégué pour instancier FabricClient. Pendant la résolution de partition, si l’objet FabricClient est supprimé et qu’un deuxième délégué est fourni, il utilise le deuxième délégué pour recréer le FabricClient. Le deuxième délégué permet de spécifier une autre façon de créer FabricClient si FabricClient créé avec les premiers délégués sont supprimés.

Résumé de la méthode

Modificateur et type Méthode et description
ServicePartitionResolver getDefault()

Obtient le ServicePartitionResolver par défaut
Duration getResolveTimeout()
Duration getRetryBackoffInterval()
CompletableFuture<ResolvedServicePartition> resolveAsync(ResolvedServicePartition previousRsp)

Résout une partition du service spécifié en appelant la méthode de system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) FabricClient avec une sauvegarde/une nouvelle tentative en cas d’erreurs pouvant être retentées. Cela prend la partition de service résolue obtenue via un appel antérieur de la méthode ResolveAsync(). Cette surcharge d’API est utilisée dans les cas où le client sait que la partition de service résolue qu’il possède n’est plus valide.
CompletableFuture<ResolvedServicePartition> resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Résout une partition du service spécifié avec backoff/retenter en cas d’erreurs pouvant être retentées. Cela prend la partition de service résolue obtenue via un appel antérieur de la méthode ResolveAsync(). Cette surcharge d’API est utilisée dans les cas où le client sait que la partition de service résolue qu’il possède n’est plus valide.
CompletableFuture<ResolvedServicePartition> resolveAsync(URI serviceUri, ServicePartitionKey partitionKey)

Résout une partition du service spécifié en appelant la méthode de system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)FabricClient avec une sauvegarde/une nouvelle tentative en cas d’erreurs pouvant être retentées.
CompletableFuture<ResolvedServicePartition> resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Résout une partition du service spécifié en appelant system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) la méthode avec back-off/retenter en cas d’erreurs pouvant être retentées.
void setDefault(ServicePartitionResolver defaultServiceResolver)

Mises à jour le ServicePartitionResolver par défaut
void setResolveTimeout(Duration resolveTimeout)
void setRetryBackoffInterval(Duration retryBackoffInterval)

Détails du champ

defaultMaxRetryBackoffInterval

public static final Duration defaultMaxRetryBackoffInterval= Duration.ofSeconds(5)

Il s’agit de l’intervalle de retour de nouvelle tentative maximale par défaut utilisé par la méthode ResolveAsync de ServicePartitionResolver lorsqu’elle est appelée sans spécifier explicitement l’argument maxRetryBackoffInterval.

defaultResolveTimeout

public static final Duration defaultResolveTimeout= Duration.ofSeconds(30)

Il s’agit du délai d’expiration de résolution par défaut par tentative utilisé par la méthode ResolveAsync de ServicePartitionResolver lorsqu’elle est appelée sans spécifier explicitement l’argument resolveTimeoutPerTry.

Détails du constructeur

FabricServicePartitionResolver

public FabricServicePartitionResolver(FabricClientSettings settings, String... connectionEndpoints)

Instancie un ServicePartitionResolver, utilise les paramètres FabricClient et les points de terminaison de connexion donnés pour créer un instance de FabricClient.

Parameters:

settings - Paramètres du client Fabric
connectionEndpoints - Tableau de points de terminaison de gestion du cluster

FabricServicePartitionResolver

public FabricServicePartitionResolver(String... connectionEndpoints)

Instancie un ServicePartitionResolver, utilise les points de terminaison de connexion donnés pour créer un instance de FabricClient.

Parameters:

connectionEndpoints - Tableau de points de terminaison de gestion du cluster

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient)

Instancie un ServicePartitionResolver, appelant le délégué donné pour instancier FabricClient.

Parameters:

createFabricClient - Déléguer pour créer un client fabric

FabricServicePartitionResolver

public FabricServicePartitionResolver(Supplier createFabricClient, Supplier recreateFabricClient)

Instancie un ServicePartionResolver, appelant le premier délégué pour instancier FabricClient. Pendant la résolution de partition, si l’objet FabricClient est supprimé et qu’un deuxième délégué est fourni, il utilise le deuxième délégué pour recréer le FabricClient. Le deuxième délégué permet de spécifier une autre façon de créer FabricClient si FabricClient créé avec les premiers délégués sont supprimés.

Parameters:

createFabricClient - Déléguer pour créer un client fabric
recreateFabricClient - Déléguer pour créer un client fabric

Détails de la méthode

getDefault

public static ServicePartitionResolver getDefault()

Obtient le ServicePartitionResolver par défaut

Returns:

getResolveTimeout

public Duration getResolveTimeout()

getRetryBackoffInterval

public Duration getRetryBackoffInterval()

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp)

Résout une partition du service spécifié en appelant la méthode de system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) FabricClient avec une sauvegarde/une nouvelle tentative en cas d’erreurs pouvant être retentées. Cela prend la partition de service résolue obtenue via un appel antérieur de la méthode ResolveAsync(). Cette surcharge d’API est utilisée dans les cas où le client sait que la partition de service résolue qu’il possède n’est plus valide.

Parameters:

previousRsp - Partition de service précédente résolue

Returns:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est l’objet ResolvedServicePartition , qui contient les informations sur la partition de service résolue, y compris les points de terminaison de service.

resolveAsync

public CompletableFuture resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Résout une partition du service spécifié avec backoff/retenter en cas d’erreurs pouvant être retentées. Cela prend la partition de service résolue obtenue via un appel antérieur de la méthode ResolveAsync(). Cette surcharge d’API est utilisée dans les cas où le client sait que la partition de service résolue qu’il possède n’est plus valide.

Overrides:

FabricServicePartitionResolver.resolveAsync(ResolvedServicePartition previousRsp, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

previousRsp - Partition de service précédente résolue
resolveTimeoutPerTry - Délai d’attente passé à la méthode ServiceManagementClient::resolveServicePartitionAsync(URI)
maxRetryBackoffInterval - Intervalle de sauvegarde avant la nouvelle tentative lorsque la résolution de la partition de service échoue avec une exception pouvant être retentée.

Returns:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est l’objet ResolvedServicePartition , qui contient les informations sur la partition de service résolue, y compris les points de terminaison de service.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey)

Résout une partition du service spécifié en appelant la méthode de system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)FabricClient avec une sauvegarde/une nouvelle tentative en cas d’erreurs pouvant être retentées.

Parameters:

serviceUri - URI du service à résoudre
partitionKey - Clé qui identifie la partition à résoudre

Returns:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est l’objet ResolvedServicePartition , qui contient les informations sur la partition de service résolue, y compris les points de terminaison de service.

resolveAsync

public CompletableFuture resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Résout une partition du service spécifié en appelant system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) la méthode avec back-off/retenter en cas d’erreurs pouvant être retentées.

Overrides:

FabricServicePartitionResolver.resolveAsync(URI serviceUri, ServicePartitionKey partitionKey, Duration resolveTimeoutPerTry, Duration maxRetryBackoffInterval)

Parameters:

serviceUri - URI du service à résoudre
partitionKey - Clé qui identifie la partition à résoudre
resolveTimeoutPerTry - Délai d’attente passé à la system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI) méthode
maxRetryBackoffInterval - Intervalle à revenir en arrière avant de réessayer lorsque system.fabric.client.ServiceManagementClient#resolveServicePartitionAsync(URI)la méthode échoue avec une exception pouvant être retentée.

Returns:

qui représente une CompletableFuture opération en attente. Le résultat de la tâche est l’objet ResolvedServicePartition , qui contient les informations sur la partition de service résolue, y compris les points de terminaison de service.

setDefault

public static void setDefault(ServicePartitionResolver defaultServiceResolver)

Mises à jour le ServicePartitionResolver par défaut

Parameters:

defaultServiceResolver - Nouvelle valeur par défaut

setResolveTimeout

public void setResolveTimeout(Duration resolveTimeout)

Parameters:

resolveTimeout

setRetryBackoffInterval

public void setRetryBackoffInterval(Duration retryBackoffInterval)

Parameters:

retryBackoffInterval

S’applique à