ActorStateProvider Interface

Paquet:

microsoft.servicefabric.actors.runtime

public interface ActorStateProvider extends StateProviderReplica

Représente l’interface qu’un fournisseur d’état d’acteur doit implémenter pour que le runtime d’acteur communique avec lui.

Résumé de la méthode

Modificateur et type	Méthode et description
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<Boolean>	containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken) Vérifie si le fournisseur d’état d’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 d’acteur peut être utilisé simultanément avec les lectures et é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 les ActorIds du fournisseur d’état. Remarques: Lla
void	initialize(ActorTypeInformation actorTypeInformation) Initialise le fournisseur d’état d’acteur avec les informations de type du type d’acteur qui lui est associé.
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 acteur associé au nom d’état spécifié.
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é de manière atomique.
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 de façon atomique l’ensemble 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 lors de la tentative d’ajout d’un état d’acteur qui existe déjà ou de mise à jour/suppression d’un état d’acteur qui n’existe pas.

Membres hérités

StateProviderReplica.abort() StateProviderReplica.backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) StateProviderReplica.backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) StateProviderReplica.changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) StateProviderReplica.closeAsync(CancellationToken cancellationToken) StateProviderReplica.initialize(StatefulServiceInitializationParameters initializationParameters) StateProviderReplica.openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) StateProviderReplica.restoreAsync(String backupFolderPath) StateProviderReplica.restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken) StateProviderReplica.setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync)

Détails de la méthode

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

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.

containsStateAsync

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

Vérifie si le fournisseur d’état d’acteur contient un état d’acteur avec le nom d’état spécifié.

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.

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é

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 d’acteur peut être utilisé simultanément avec les lectures et écritures dans le fournisseur d’état. Il représente une vue instantané cohérente du fournisseur d’état.

Paramètres:

actorId - ID de l’acteur pour lequel créer l’é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 les ActorIds du fournisseur d’état.

Remarques: Lla

Paramètres:

numItemsToReturn - Nombre d’éléments à retourner.

continuationToken - Jeton de continuation à partir duquel commencer l’interrogation des résultats. Une valeur Null de jeton de continuation signifie que commencer à retourner des valeurs à partir du 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 d’acteur avec les informations de type du type d’acteur qui lui est associé.

Paramètres:

actorTypeInformation - Informations de type de la classe actor

loadRemindersAsync

public CompletableFuture loadRemindersAsync(CancellationToken cancellationToken)

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

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 acteur associé au nom d’état spécifié.

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 acteur associé à un nom d’état donné.

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

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:

Une tâche qui représente le rappel asynchrone a terminé le traitement de la notification.

removeActorAsync

public CompletableFuture removeActorAsync(ActorId actorId, CancellationToken cancellationToken)

Supprime tous les états et rappels existants associés à l’acteur spécifié de manière atomique.

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.

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.

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 de façon atomique l’ensemble 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 lors de la tentative d’ajout d’un état d’acteur qui existe déjà ou de mise à jour/suppression d’un état d’acteur qui n’existe pas.

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.