StateProviderReplica Interface

Paquet:

microsoft.servicefabric.data

public interface StateProviderReplica

Définit les méthodes qu’un fournisseur d’état fiable réplica devez implémenter pour que Service Fabric interagisse avec celui-ci.

Résumé de la méthode

Modificateur et type	Méthode et description
void	abort() Abandon forcé du fournisseur d’état réplica. Remarques:Cela se produit généralement lorsqu’une erreur permanente est détectée sur le nœud ou lorsque Service Fabric ne peut pas gérer de manière fiable le cycle de vie de l’réplica en raison de défaillances internes.
CompletableFuture<?>	backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) Effectue une sauvegarde complète de tous les états fiables gérés par ce ReliableStateManager. Remarques: Une sauvegarde COMPLÈTE est effectuée avec un délai d’attente d’une heure. Les valeurs booléennes retournées par backupCallback indiquent si le service a réussi à déplacer le dossier de sauvegarde vers un emplacement externe. Si false est retourné, BackupAsync lève UnsupportedOperationException avec le message approprié indiquant que backupCallback a retourné false. En outre, la sauvegarde est marquée comme ayant échoué.
CompletableFuture<?>	backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) Effectue une sauvegarde complète de tous les états fiables gérés par ce ReliableStateManager. Remarques: Une sauvegarde COMPLÈTE est effectuée avec un délai d’attente d’une heure. Les valeurs booléennes retournées par backupCallback indiquent si le service a réussi à déplacer le dossier de sauvegarde vers un emplacement externe. Si false est retourné, BackupAsync lève UnsupportedOperationException avec le message approprié indiquant que backupCallback a retourné false. En outre, la sauvegarde est marquée comme ayant échoué.
CompletableFuture<?>	changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Informez le fournisseur d’état réplica que son rôle change, par exemple en principal ou secondaire.
CompletableFuture<?>	closeAsync(CancellationToken cancellationToken) Fermez normalement le réplica du fournisseur d’état. Remarques:Cela se produit généralement lorsque le code de l’réplica est mis à niveau, que le réplica est déplacé en raison de l’équilibrage de charge ou qu’une erreur temporaire est détectée.
void	initialize(StatefulServiceInitializationParameters initializationParameters) Initialisez le fournisseur d’état réplica à l’aide des informations d’initialisation du service. Remarques:Aucun traitement complexe ne doit être effectué lors de l’initialisation. Une initialisation coûteuse ou longue doit être effectuée dans OpenAsync.
CompletableFuture<Replicator>	openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) Ouvrez le fournisseur d’état réplica à utiliser. Remarques:Les tâches d’initialisation du fournisseur d’état étendu peuvent être démarrées à ce stade.
CompletableFuture<?>	restoreAsync(String backupFolderPath) Restaurer une sauvegarde effectuée. Remarques:Une restauration sécurisée est effectuée, ce qui signifie que la restauration ne sera effectuée que si les données à restaurer sont en avance sur l’état du réplica actuel.
CompletableFuture<?>	restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken) Restaurer une sauvegarde effectuée
void	setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync) Fonction appelée lors d’une perte de données suspectée

Détails de la méthode

abort

public void abort()

Abandon forcé du fournisseur d’état réplica.

Remarques:Cela se produit généralement lorsqu’une erreur permanente est détectée sur le nœud ou lorsque Service Fabric ne peut pas gérer de manière fiable le cycle de vie de l’réplica en raison de défaillances internes.

backupAsync

public CompletableFuture backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction> backupCallback)

Effectue une sauvegarde complète de tous les états fiables gérés par ce ReliableStateManager.

Remarques: Une sauvegarde COMPLÈTE est effectuée avec un délai d’attente d’une heure. Les valeurs booléennes retournées par backupCallback indiquent si le service a réussi à déplacer le dossier de sauvegarde vers un emplacement externe. Si false est retourné, BackupAsync lève UnsupportedOperationException avec le message approprié indiquant que backupCallback a retourné false. En outre, la sauvegarde est marquée comme ayant échoué.

Parameters:

option - Type de sauvegarde à effectuer.

timeout - Délai d’expiration de cette opération.

cancellationToken - Jeton pour surveiller les requêtes d'annulation.

backupCallback - Rappel à appeler lorsque le dossier de sauvegarde a été créé localement et est prêt à être déplacé hors du nœud

Returns:

Tâche qui représente l’opération de sauvegarde asynchrone.

backupAsync

public CompletableFuture backupAsync(BiFunction> backupCallback)

Effectue une sauvegarde complète de tous les états fiables gérés par ce ReliableStateManager.

Remarques: Une sauvegarde COMPLÈTE est effectuée avec un délai d’attente d’une heure. Les valeurs booléennes retournées par backupCallback indiquent si le service a réussi à déplacer le dossier de sauvegarde vers un emplacement externe. Si false est retourné, BackupAsync lève UnsupportedOperationException avec le message approprié indiquant que backupCallback a retourné false. En outre, la sauvegarde est marquée comme ayant échoué.

Parameters:

backupCallback - Rappel à appeler lorsque le dossier de sauvegarde a été créé localement et est prêt à être déplacé hors du nœud

Returns:

Tâche qui représente l’opération de sauvegarde asynchrone.

changeRoleAsync

public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Informez le fournisseur d’état réplica que son rôle change, par exemple en principal ou secondaire.

Parameters:

newRole - Le nouveau rôle réplica, par exemple principal ou secondaire.

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Returns:

Tâche qui représente l’opération de modification de rôle asynchrone.

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

Fermez normalement le réplica du fournisseur d’état.

Remarques:Cela se produit généralement lorsque le code de l’réplica est mis à niveau, que le réplica est déplacé en raison de l’équilibrage de charge ou qu’une erreur temporaire est détectée.

Parameters:

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Returns:

Tâche qui représente l’opération de fermeture asynchrone.

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

Initialisez le fournisseur d’état réplica à l’aide des informations d’initialisation du service.

Remarques:Aucun traitement complexe ne doit être effectué lors de l’initialisation. Une initialisation coûteuse ou longue doit être effectuée dans OpenAsync.

Parameters:

initializationParameters - Informations d’initialisation du service, telles que le nom du service, l’ID de partition, l’ID de réplica et les informations sur le package de code.

openAsync

public CompletableFuture openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)

Ouvrez le fournisseur d’état réplica à utiliser.

Remarques:Les tâches d’initialisation du fournisseur d’état étendu peuvent être démarrées à ce stade.

Parameters:

openMode - Indique s’il s’agit d’un réplica nouveau ou existant.

partition - Partition à laquelle appartient cette réplica.

cancellationToken -

CancellationTokenobjet pour indiquer l’annulation status de l’opération.

Returns:

Tâche qui représente l’opération d’ouverture asynchrone. Le résultat contient le réplicateur responsable de la réplication de l’état entre d’autres réplicas de fournisseur d’état dans la partition.

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath)

Restaurer une sauvegarde effectuée.

Remarques:Une restauration sécurisée est effectuée, ce qui signifie que la restauration ne sera effectuée que si les données à restaurer sont en avance sur l’état du réplica actuel.

Parameters:

backupFolderPath - Répertoire à partir duquel le réplica doit être restauré. Ce paramètre ne peut pas être null, vide ou contenir simplement un espace blanc. Des chemins UNC peuvent également être fournis.

Returns:

Tâche qui représente l’opération de restauration asynchrone.

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)

Restaurer une sauvegarde effectuée

Parameters:

backupFolderPath - Répertoire à partir duquel le réplica doit être restauré. Ce paramètre ne peut pas être null, vide ou contenir simplement un espace blanc. Des chemins UNC peuvent également être fournis.

restorePolicy - Stratégie de restauration.

timeout - Délai d’expiration de cette opération.

cancellationToken - Jeton pour surveiller les requêtes d'annulation.

Returns:

Tâche qui représente l’opération de restauration asynchrone.

setOnDataLossCallback

public void setOnDataLossCallback(Function> onDataLossAsync)

Fonction appelée lors d’une perte de données suspectée

Parameters:

onDataLossAsync - TODO. Fonction appelée dans le cadre d’un traitement suspect de perte de données. La fonction prend CancellationToken et retourne un CompletableFuture qui représente le traitement asynchrone de l’événement. Le retour de true indique que l’état du réplica a été restauré. False indique que l’état du réplica n’a pas été modifié.