Partager via


ReliableCollectionsActorStateProvider Classe

public class ReliableCollectionsActorStateProvider implements ActorStateProvider

Récapitulatif du constructeur

Constructeur Description
ReliableCollectionsActorStateProvider()
ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig)
ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig, int actorStateMapCount, int reminderMapCount)

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<PagedResult<ActorId>> 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<ActorReminderCollection> 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

microsoft.servicefabric.actors.runtime.ActorStateProviderInternal.currentReplicaRole() microsoft.servicefabric.actors.runtime.ActorStateProviderInternal.traceId() microsoft.servicefabric.actors.runtime.ActorStateProviderInternal.traceType() microsoft.servicefabric.actors.runtime.ActorStateProviderInternal.transientErrorRetryDelay()

Détails du constructeur

ReliableCollectionsActorStateProvider

public ReliableCollectionsActorStateProvider()

ReliableCollectionsActorStateProvider

public ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig)

Paramètres:

stateManagerConfig

ReliableCollectionsActorStateProvider

public ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig, int actorStateMapCount, int reminderMapCount)

Paramètres:

stateManagerConfig
actorStateMapCount
reminderMapCount

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:

actorId - ID de l’acteur activé.
cancellationToken -

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

Retours:

Tâche qui représente le traitement asynchrone de la notification d’activation de l’acteur.

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 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:

option - Type de sauvegarde à effectuer.
timeout - Délai d’attente 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 qu’il est prêt à être déplacé hors du nœud

Retours:

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 backupCallback retourné false. En outre, la sauvegarde est marquée comme ayant échoué.

Remplacements:

ReliableCollectionsActorStateProvider.backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)

Paramètres:

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

Retours:

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 est en train de changer, par exemple en principal ou secondaire.

Remplacements:

ReliableCollectionsActorStateProvider.changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Paramètres:

newRole - Le nouveau rôle réplica, tel que principal ou secondaire.
cancellationToken -

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

Retours:

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

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:

cancellationToken -

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

Retours:

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

containsStateAsync

public CompletableFuture 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é.

Remplacements:

ReliableCollectionsActorStateProvider.containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)

Paramètres:

actorId - ID de l’acteur pour lequel case activée’existence de l’état.
stateName - Nom de l’état de l’acteur à case activée d’existence.
cancellationToken -

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

Retours:

Tâche qui représente l’opération asynchrone case activée. La valeur du paramètre TResult est true si l’état avec le nom spécifié existe sinon false.

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:

actorId - ID de l’acteur pour lequel supprimer le rappel.
reminderName - Nom du rappel à supprimer.
cancellationToken -

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

Retours:

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

deleteRemindersAsync

public CompletableFuture deleteRemindersAsync(Map> reminderNames, CancellationToken cancellationToken)

Supprime l’ensemble de rappels spécifié

Remplacements:

ReliableCollectionsActorStateProvider.deleteRemindersAsync(Map<ActorId, Collection<String>> reminderNames, CancellationToken cancellationToken)

Paramètres:

reminderNames - Ensemble de rappels à supprimer
cancellationToken -

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

Retours:

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

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:

actorId - ID de l’acteur pour lequel créer un énumérable.
cancellationToken -

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

Retours:

Tâche qui représente l’opération d’énumération asynchrone. La valeur du paramètre TResult est énumérable de tous les noms d’état associés à l’acteur spécifié.

getActorsAsync

public CompletableFuture> getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken)

Obtient des Id d’acteur à partir du fournisseur d’état.

Remarques: Lla

Remplacements:

ReliableCollectionsActorStateProvider.getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken)

Paramètres:

numItemsToReturn - Nombre d’éléments à retourner.
continuationToken - Jeton de continuation à partir duquel commencer à interroger les résultats. Une valeur null de jeton de continuation signifie que commencez à retourner des valeurs au début.
cancellationToken -

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

Retours:

Tâche qui représente l’opération asynchrone d’appel au serveur.

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:

actorTypeInformation - Informations de type de la classe d’acteur

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:

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

loadRemindersAsync

public CompletableFuture loadRemindersAsync(CancellationToken cancellationToken)

Charge tous les rappels contenus dans le fournisseur d’état de l’acteur.

Remplacements:

ReliableCollectionsActorStateProvider.loadRemindersAsync(CancellationToken cancellationToken)

Paramètres:

cancellationToken -

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

Retours:

Tâche qui représente l’opération de chargement asynchrone. La valeur du paramètre TResult est une collection de tous les rappels d’acteur contenus dans le fournisseur d’état de l’acteur.

loadStateAsync

public CompletableFuture loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)

Charge l’état de l’acteur associé au nom d’état spécifié.

Remplacements:

ReliableCollectionsActorStateProvider.loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken)

Paramètres:

actorId - ID de l’acteur pour lequel charger l’état.
stateName - Nom de l’état de l’acteur à charger.
cancellationToken -

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

Retours:

Tâche qui représente l’opération de chargement asynchrone. La valeur du paramètre TResult contient la valeur de l’état d’acteur associée à un nom d’état donné.

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.

Remplacements:

ReliableCollectionsActorStateProvider.openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken)

Paramètres:

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.

Retours:

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.

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:

actorId - ID de l’acteur qui possède le rappel
reminder - Rappel de l’acteur qui s’est terminé avec succès.
cancellationToken - Jeton pour surveiller les requêtes d'annulation.

Retours:

Tâche qui représente le traitement des notifications terminées par le rappel de rappel asynchrone.

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:

actorId - ID de l’acteur pour lequel supprimer l’état.
cancellationToken -

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

Retours:

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

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:

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.

Retours:

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

Remplacements:

ReliableCollectionsActorStateProvider.restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken)

Paramètres:

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.

Retours:

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

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:

actorId - ID de l’acteur pour lequel enregistrer le rappel.
reminder - Rappel de l’acteur à enregistrer.
cancellationToken -

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

Retours:

Tâche qui représente l’opération d’écriture d’enregistrement asynchrone.

saveStateAsync

public CompletableFuture saveStateAsync(ActorId actorId, List 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.

Remplacements:

ReliableCollectionsActorStateProvider.saveStateAsync(ActorId actorId, List<ActorStateChange> stateChanges, CancellationToken cancellationToken)

Paramètres:

actorId - ID de l’acteur pour lequel enregistrer les modifications d’état.
stateChanges - Collection de modifications d’état à enregistrer.
cancellationToken -

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

Retours:

Tâche qui représente l’opération d’écriture d’enregistrement asynchrone.

setOnDataLossCallback

public void setOnDataLossCallback(Function> onDataLossAsync)

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

Remplacements:

ReliableCollectionsActorStateProvider.setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)

Paramètres:

onDataLossAsync - 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é.

S’applique à