ReliableCollectionsActorStateProvider Classe
- java.
lang. Object - StateProviderReplica
- ActorStateProvider
- microsoft.
servicefabric. actors. runtime. ReliableCollectionsActorStateProvider
- microsoft.
public class ReliableCollectionsActorStateProvider implements ActorStateProvider
Récapitulatif du constructeur
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 du réplica en raison de défaillances internes. |
CompletableFuture<?> |
actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)
Cette méthode est appelée dans le cadre du processus d’activation de l’acteur avec l’ID spécifié. |
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 backupCallback 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 backupCallback 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 est en train de changer, par exemple en principal ou secondaire. |
CompletableFuture<?> |
closeAsync(CancellationToken cancellationToken)
Fermez de façon appropriée le réplica du fournisseur d’état.
Remarques:Cela se produit généralement lorsque le code du 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. |
CompletableFuture<Boolean> |
containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)
Vérifie si le fournisseur d’état de l’acteur contient un état d’acteur avec le nom d’état spécifié. |
CompletableFuture<?> |
deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)
Supprime le rappel de l’acteur spécifié s’il existe. |
CompletableFuture<?> |
deleteRemindersAsync(Map<ActorId, Collection<String>> reminderNames, CancellationToken cancellationToken)
Supprime l’ensemble de rappels spécifié |
CompletableFuture<List<String>> |
enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)
Crée un énumérable de tous les noms d’état associés à l’acteur spécifié.
Remarques:L’énumérateur retourné par le fournisseur d’état acteur peut être utilisé en même temps que les lectures et les écritures dans le fournisseur d’état. Il représente une vue instantané cohérente du fournisseur d’état. |
CompletableFuture<Paged |
getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken)
Obtient des Id d’acteur à partir du fournisseur d’état.
Remarques: Lla |
void |
initialize(ActorTypeInformation actorTypeInformation)
Initialise le fournisseur d’état de l’acteur avec les informations de type de type d’acteur qui lui sont associées. |
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. L’initialisation coûteuse ou longue doit être effectuée dans OpenAsync. |
CompletableFuture<Actor |
loadRemindersAsync(CancellationToken cancellationToken)
Charge tous les rappels contenus dans le fournisseur d’état de l’acteur. |
<T> CompletableFuture<T> |
loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)
Charge l’état de l’acteur associé au nom d’état spécifié. |
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<?> |
reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)
Appelé lorsqu’un rappel se déclenche et termine l’exécution de son rappel receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period) avec succès |
CompletableFuture<?> |
removeActorAsync(ActorId actorId, CancellationToken cancellationToken)
Supprime tous les états et rappels existants associés à l’acteur spécifié atomiquement. |
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 |
CompletableFuture<?> |
saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)
Enregistre le rappel de l’acteur spécifié. Si un rappel d’acteur portant un nom donné n’existe pas, il ajoute le rappel de l’acteur, sinon le rappel d’acteur existant portant le même nom est mis à jour. |
CompletableFuture<?> |
saveStateAsync(ActorId actorId, List<ActorStateChange> stateChanges, CancellationToken cancellationToken)
Enregistre atomiquement le jeu spécifié de modifications d’état de l’acteur.
Remarques: La collection de modifications d’état ne doit contenir qu’un seul élément pour un nom d’état donné. L’opération d’enregistrement échoue lorsque vous essayez d’ajouter un état d’acteur qui existe déjà ou de mettre à jour/supprimer un état d’acteur qui n’existe pas. |
void |
setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)
Fonction appelée lors d’une perte de données suspectée |
Membres hérités
Détails du constructeur
ReliableCollectionsActorStateProvider
public ReliableCollectionsActorStateProvider()
ReliableCollectionsActorStateProvider
public ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig)
Paramètres:
ReliableCollectionsActorStateProvider
public ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig, int actorStateMapCount, int reminderMapCount)
Paramètres:
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 du réplica en raison de défaillances internes.
Remplacements:
ReliableCollectionsActorStateProvider.abort()actorActivatedAsync
public CompletableFuture actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)
Cette méthode est appelée dans le cadre du processus d’activation de l’acteur avec l’ID spécifié.
Remplacements:
ReliableCollectionsActorStateProvider.actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
backupAsync
public CompletableFuture backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction
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 backupCallback retourné false. En outre, la sauvegarde est marquée comme ayant échoué.
Remplacements:
ReliableCollectionsActorStateProvider.backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)Paramètres:
Retours:
backupAsync
public CompletableFuture backupAsync(BiFunction
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 backupCallback retourné false. En outre, la sauvegarde est marquée comme ayant échoué.
Remplacements:
ReliableCollectionsActorStateProvider.backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)Paramètres:
Retours:
changeRoleAsync
public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)
Informez le fournisseur d’état réplica que son rôle est en train de changer, par exemple en principal ou secondaire.
Remplacements:
ReliableCollectionsActorStateProvider.changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
closeAsync
public CompletableFuture closeAsync(CancellationToken cancellationToken)
Fermez de façon appropriée le réplica du fournisseur d’état.
Remarques:Cela se produit généralement lorsque le code du 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.
Remplacements:
ReliableCollectionsActorStateProvider.closeAsync(CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
containsStateAsync
public CompletableFuture
Vérifie si le fournisseur d’état de l’acteur contient un état d’acteur avec le nom d’état spécifié.
Remplacements:
ReliableCollectionsActorStateProvider.containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
deleteReminderAsync
public CompletableFuture deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)
Supprime le rappel de l’acteur spécifié s’il existe.
Remplacements:
ReliableCollectionsActorStateProvider.deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
deleteRemindersAsync
public CompletableFuture deleteRemindersAsync(Map
Supprime l’ensemble de rappels spécifié
Remplacements:
ReliableCollectionsActorStateProvider.deleteRemindersAsync(Map<ActorId, Collection<String>> reminderNames, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
enumerateStateNamesAsync
public CompletableFuture> enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)
Crée un énumérable de tous les noms d’état associés à l’acteur spécifié.
Remarques:L’énumérateur retourné par le fournisseur d’état acteur peut être utilisé en même temps que les lectures et les écritures dans le fournisseur d’état. Il représente une vue instantané cohérente du fournisseur d’état.
Remplacements:
ReliableCollectionsActorStateProvider.enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
getActorsAsync
public CompletableFuture
Obtient des Id d’acteur à partir du fournisseur d’état.
Remarques: Lla
Remplacements:
ReliableCollectionsActorStateProvider.getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
initialize
public void initialize(ActorTypeInformation actorTypeInformation)
Initialise le fournisseur d’état de l’acteur avec les informations de type de type d’acteur qui lui sont associées.
Remplacements:
ReliableCollectionsActorStateProvider.initialize(ActorTypeInformation actorTypeInformation)Paramètres:
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. L’initialisation coûteuse ou longue doit être effectuée dans OpenAsync.
Remplacements:
ReliableCollectionsActorStateProvider.initialize(StatefulServiceInitializationParameters initializationParameters)Paramètres:
loadRemindersAsync
public CompletableFuture
Charge tous les rappels contenus dans le fournisseur d’état de l’acteur.
Remplacements:
ReliableCollectionsActorStateProvider.loadRemindersAsync(CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
loadStateAsync
public
Charge l’état de l’acteur associé au nom d’état spécifié.
Remplacements:
ReliableCollectionsActorStateProvider.loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
openAsync
public CompletableFuture
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.
Remplacements:
ReliableCollectionsActorStateProvider.openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
reminderCallbackCompletedAsync
public CompletableFuture reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)
Appelé lorsqu’un rappel se déclenche et termine l’exécution de son rappel receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period) avec succès
Remplacements:
ReliableCollectionsActorStateProvider.reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)Paramètres:
Retours:
removeActorAsync
public CompletableFuture removeActorAsync(ActorId actorId, CancellationToken cancellationToken)
Supprime tous les états et rappels existants associés à l’acteur spécifié atomiquement.
Remplacements:
ReliableCollectionsActorStateProvider.removeActorAsync(ActorId actorId, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
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.
Remplacements:
ReliableCollectionsActorStateProvider.restoreAsync(String backupFolderPath)Paramètres:
Retours:
restoreAsync
public CompletableFuture restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)
Restaurer une sauvegarde effectuée
Remplacements:
ReliableCollectionsActorStateProvider.restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)Paramètres:
Retours:
saveReminderAsync
public CompletableFuture saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)
Enregistre le rappel de l’acteur spécifié. Si un rappel d’acteur portant un nom donné n’existe pas, il ajoute le rappel de l’acteur, sinon le rappel d’acteur existant portant le même nom est mis à jour.
Remplacements:
ReliableCollectionsActorStateProvider.saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
saveStateAsync
public CompletableFuture saveStateAsync(ActorId actorId, List
Enregistre atomiquement le jeu spécifié de modifications d’état de l’acteur.
Remarques: La collection de modifications d’état ne doit contenir qu’un seul élément pour un nom d’état donné. L’opération d’enregistrement échoue lorsque vous essayez d’ajouter un état d’acteur qui existe déjà ou de mettre à jour/supprimer un état d’acteur qui n’existe pas.
Remplacements:
ReliableCollectionsActorStateProvider.saveStateAsync(ActorId actorId, List<ActorStateChange> stateChanges, CancellationToken cancellationToken)Paramètres:
CancellationTokenobjet pour indiquer l’annulation status de l’opération.
Retours:
setOnDataLossCallback
public void setOnDataLossCallback(Function
Fonction appelée lors d’une perte de données suspectée
Remplacements:
ReliableCollectionsActorStateProvider.setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)Paramètres:
S’applique à
Azure SDK for Java