ReliableCollectionsActorStateProvider Klasse

Paket:

microsoft.servicefabric.actors.runtime

• java.lang.Object
• • StateProviderReplica
  • • ActorStateProvider
    • • microsoft.servicefabric.actors.runtime.ReliableCollectionsActorStateProvider

public class ReliableCollectionsActorStateProvider implements ActorStateProvider

Zusammenfassung zum Konstruktor

Konstruktor	Beschreibung
ReliableCollectionsActorStateProvider()
ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig)
ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig, int actorStateMapCount, int reminderMapCount)

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
void	abort() Beenden Sie das Zustandsanbieterreplikat erzwungen. Bemerkungen:Dies tritt in der Regel auf, wenn ein dauerhafter Fehler auf dem Knoten erkannt wird oder wenn Service Fabric den Lebenszyklus des Replikats aufgrund interner Fehler nicht zuverlässig verwalten kann.
CompletableFuture<?>	actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken) Diese Methode wird im Rahmen des Aktivierungsprozesses des Akteurs mit der angegebenen ID aufgerufen.
CompletableFuture<?>	backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) Führt eine vollständige Sicherung des gesamten zuverlässigen Zustands aus, der von diesem ReliableStateManager verwaltet wird. Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde ausgeführt. Vom BackupCallback zurückgegebener Boolescher Wert gibt an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException mit der entsprechenden Meldung aus, die angibt, dass backupCallback false zurückgegeben hat. Außerdem wird die Sicherung als nicht erfolgreich markiert.
CompletableFuture<?>	backupAsync(BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) Führt eine vollständige Sicherung des gesamten zuverlässigen Zustands aus, der von diesem ReliableStateManager verwaltet wird. Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde ausgeführt. Vom BackupCallback zurückgegebener Boolescher Wert gibt an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException mit der entsprechenden Meldung aus, die angibt, dass backupCallback false zurückgegeben hat. Außerdem wird die Sicherung als nicht erfolgreich markiert.
CompletableFuture<?>	changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken) Benachrichtigen Sie das Zustandsanbieterreplikat, dass sich seine Rolle ändert, z. B. in "Primär" oder "Sekundär".
CompletableFuture<?>	closeAsync(CancellationToken cancellationToken) Schließen Sie das Zustandsanbieterreplikat ordnungsgemäß. Bemerkungen:Dies tritt in der Regel auf, wenn der Code des Replikats aktualisiert wird, das Replikat aufgrund eines Lastenausgleichs verschoben wird oder ein vorübergehender Fehler erkannt wird.
CompletableFuture<Boolean>	containsStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken) Überprüft, ob der Akteurstatusanbieter einen Akteurstatus mit dem angegebenen Statusnamen enthält.
CompletableFuture<?>	deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken) Löscht die angegebene Actor-Erinnerung, sofern vorhanden.
CompletableFuture<?>	deleteRemindersAsync(Map<ActorId, Collection<String>> reminderNames, CancellationToken cancellationToken) Löscht den angegebenen Erinnerungssatz.
CompletableFuture<List<String>>	enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken) Erstellt eine Aufzählung aller Zustandsnamen, die dem angegebenen Akteur zugeordnet sind. Bemerkungen:Der vom Akteurstatusanbieter zurückgegebene Enumerator kann sicher gleichzeitig mit Lese- und Schreibvorgängen an den Zustandsanbieter verwendet werden. Sie stellt eine Momentaufnahme konsistente Ansicht des Zustandsanbieters dar.
CompletableFuture<PagedResult<ActorId>>	getActorsAsync(int numItemsToReturn, ContinuationToken continuationToken, CancellationToken cancellationToken) Ruft ActorIds vom Zustandsanbieter ab. Bemerkungen: Das
void	initialize(ActorTypeInformation actorTypeInformation) Initialisiert den Akteurzustandsanbieter mit Typinformationen des zugeordneten Akteurtyps.
void	initialize(StatefulServiceInitializationParameters initializationParameters) Initialisieren Sie das Zustandsanbieterreplikat mithilfe der Dienstinitialisierungsinformationen. Bemerkungen:Während der Initialisierung sollte keine komplexe Verarbeitung durchgeführt werden. In OpenAsync sollte eine teure oder lang andauernde Initialisierung durchgeführt werden.
CompletableFuture<ActorReminderCollection>	loadRemindersAsync(CancellationToken cancellationToken) Lädt alle Erinnerungen, die im Akteurzustandsanbieter enthalten sind.
<T> CompletableFuture<T>	loadStateAsync(ActorId actorId, String stateName, CancellationToken cancellationToken) Lädt den Akteurstatus, der dem angegebenen Statusnamen zugeordnet ist.
CompletableFuture<Replicator>	openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) Öffnen Sie das Zustandsanbieterreplikat zur Verwendung. Bemerkungen:Initialisierungstasks für erweiterte Zustandsanbieter können zu diesem Zeitpunkt gestartet werden.
CompletableFuture<?>	reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken) Wird aufgerufen, wenn eine Erinnerung ausgelöst wird und die Ausführung des Rückrufs receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period) erfolgreich abgeschlossen wird
CompletableFuture<?>	removeActorAsync(ActorId actorId, CancellationToken cancellationToken) Entfernt alle vorhandenen Zustände und Erinnerungen, die dem angegebenen Akteur atomar zugeordnet sind.
CompletableFuture<?>	restoreAsync(String backupFolderPath) Stellen Sie eine sicherung wieder her. Bemerkungen:Es wird eine sichere Wiederherstellung durchgeführt, d. h. die Wiederherstellung wird nur abgeschlossen, wenn die wiederherzustellenden Daten dem Status des aktuellen Replikats voraus sind.
CompletableFuture<?>	restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken) Wiederherstellen einer sicherung
CompletableFuture<?>	saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken) Speichert die angegebene Akteurerinnerung. Wenn eine Akteurerinnerung mit dem angegebenen Namen nicht vorhanden ist, wird die Akteurerinnerung hinzugefügt, andernfalls wird eine vorhandene Akteurerinnerung mit demselben Namen aktualisiert.
CompletableFuture<?>	saveStateAsync(ActorId actorId, List<ActorStateChange> stateChanges, CancellationToken cancellationToken) Speichert den angegebenen Satz von Akteurzustandsänderungen atomar. Bemerkungen: Die Auflistung der Zustandsänderungen sollte nur ein Element für einen bestimmten Zustandsnamen enthalten. Der Speichervorgang schlägt fehl, wenn versucht wird, einen bereits vorhandenen Akteurstatus hinzuzufügen oder einen nicht vorhandenen Akteurstatus zu aktualisieren bzw. zu entfernen.
void	setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync) Funktion, die bei vermuteten Datenverlusten aufgerufen wird

Geerbte Elemente

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

Details zum Konstruktor

ReliableCollectionsActorStateProvider

public ReliableCollectionsActorStateProvider()

ReliableCollectionsActorStateProvider

public ReliableCollectionsActorStateProvider(ReliableStateManagerConfiguration stateManagerConfig)

Parameter:

stateManagerConfig

ReliableCollectionsActorStateProvider

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

Parameter:

stateManagerConfig

actorStateMapCount

reminderMapCount

Details zur Methode

abort

public void abort()

Beenden Sie das Zustandsanbieterreplikat erzwungen.

Bemerkungen:Dies tritt in der Regel auf, wenn ein dauerhafter Fehler auf dem Knoten erkannt wird oder wenn Service Fabric den Lebenszyklus des Replikats aufgrund interner Fehler nicht zuverlässig verwalten kann.

Überschreibt:

ReliableCollectionsActorStateProvider.abort()

actorActivatedAsync

public CompletableFuture actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)

Diese Methode wird im Rahmen des Aktivierungsprozesses des Akteurs mit der angegebenen ID aufgerufen.

Überschreibt:

ReliableCollectionsActorStateProvider.actorActivatedAsync(ActorId actorId, CancellationToken cancellationToken)

Parameter:

actorId - ID des aktivierten Akteurs.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die die asynchrone Verarbeitung der Actor-Aktivierungsbenachrichtigung darstellt.

backupAsync

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

Führt eine vollständige Sicherung des gesamten zuverlässigen Zustands aus, der von diesem ReliableStateManager verwaltet wird.

Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde ausgeführt. Vom BackupCallback zurückgegebener Boolescher Wert gibt an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException mit der entsprechenden Meldung aus, die angibt, dass backupCallback false zurückgegeben hat. Außerdem wird die Sicherung als nicht erfolgreich markiert.

Überschreibt:

ReliableCollectionsActorStateProvider.backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback)

Parameter:

option - Der Typ der auszuführenden Sicherung.

timeout - Das Timeout für diesen Vorgang.

cancellationToken - Das Token zum Überwachen von Abbruchanforderungen.

backupCallback - Rückruf, der aufgerufen werden soll, wenn der Sicherungsordner lokal erstellt wurde und bereit ist, aus dem Knoten verschoben zu werden

Gibt zurück:

Aufgabe, die den asynchronen Sicherungsvorgang darstellt.

backupAsync

public CompletableFuture backupAsync(BiFunction> backupCallback)

Führt eine vollständige Sicherung des gesamten zuverlässigen Zustands aus, der von diesem ReliableStateManager verwaltet wird.

Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde ausgeführt. Vom BackupCallback zurückgegebener Boolescher Wert gibt an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException mit der entsprechenden Meldung aus, die angibt, dass backupCallback false zurückgegeben hat. Außerdem wird die Sicherung als nicht erfolgreich markiert.

Überschreibt:

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

Parameter:

backupCallback - Rückruf, der aufgerufen werden soll, wenn der Sicherungsordner lokal erstellt wurde und bereit ist, aus dem Knoten verschoben zu werden

Gibt zurück:

Aufgabe, die den asynchronen Sicherungsvorgang darstellt.

changeRoleAsync

public CompletableFuture changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Benachrichtigen Sie das Zustandsanbieterreplikat, dass sich seine Rolle ändert, z. B. in "Primär" oder "Sekundär".

Überschreibt:

ReliableCollectionsActorStateProvider.changeRoleAsync(ReplicaRole newRole, CancellationToken cancellationToken)

Parameter:

newRole - Die neue Replikatrolle, z. B. primär oder sekundär.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Aufgabe, die den asynchronen Änderungsrollenvorgang darstellt.

closeAsync

public CompletableFuture closeAsync(CancellationToken cancellationToken)

Schließen Sie das Zustandsanbieterreplikat ordnungsgemäß.

Bemerkungen:Dies tritt in der Regel auf, wenn der Code des Replikats aktualisiert wird, das Replikat aufgrund eines Lastenausgleichs verschoben wird oder ein vorübergehender Fehler erkannt wird.

Überschreibt:

ReliableCollectionsActorStateProvider.closeAsync(CancellationToken cancellationToken)

Parameter:

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Aufgabe, die den asynchronen Schließvorgang darstellt.

containsStateAsync

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

Überprüft, ob der Akteurstatusanbieter einen Akteurstatus mit dem angegebenen Statusnamen enthält.

Überschreibt:

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

Parameter:

actorId - ID des Akteurs, für den die Statusexistenz überprüft werden soll.

stateName - Name des Akteurstatus, der auf Existenz überprüft werden soll.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Überprüfungsvorgang darstellt. Der Wert des TResult-Parameters ist true, wenn der Zustand mit dem angegebenen Namen andernfalls false vorhanden ist.

deleteReminderAsync

public CompletableFuture deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)

Löscht die angegebene Actor-Erinnerung, sofern vorhanden.

Überschreibt:

ReliableCollectionsActorStateProvider.deleteReminderAsync(ActorId actorId, String reminderName, CancellationToken cancellationToken)

Parameter:

actorId - ID des Akteurs, für den die Erinnerung gelöscht werden soll.

reminderName - Name der zu löschenden Erinnerung.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Löschvorgang darstellt.

deleteRemindersAsync

public CompletableFuture deleteRemindersAsync(Map> reminderNames, CancellationToken cancellationToken)

Löscht den angegebenen Erinnerungssatz.

Überschreibt:

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

Parameter:

reminderNames - Der Satz der zu löschenden Erinnerungen

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Löschvorgang darstellt.

enumerateStateNamesAsync

public CompletableFuture> enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)

Erstellt eine Aufzählung aller Zustandsnamen, die dem angegebenen Akteur zugeordnet sind.

Bemerkungen:Der vom Akteurstatusanbieter zurückgegebene Enumerator kann sicher gleichzeitig mit Lese- und Schreibvorgängen an den Zustandsanbieter verwendet werden. Sie stellt eine Momentaufnahme konsistente Ansicht des Zustandsanbieters dar.

Überschreibt:

ReliableCollectionsActorStateProvider.enumerateStateNamesAsync(ActorId actorId, CancellationToken cancellationToken)

Parameter:

actorId - ID des Akteurs, für den enumerable erstellt werden soll.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Enumerationsvorgang darstellt. Der Wert des TResult-Parameters ist eine Aufzählung aller Zustandsnamen, die dem angegebenen Actor zugeordnet sind.

getActorsAsync

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

Ruft ActorIds vom Zustandsanbieter ab.

Bemerkungen: Das

Überschreibt:

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

Parameter:

numItemsToReturn - Anzahl der Elemente, die zurückgegeben werden sollen.

continuationToken - Ein Fortsetzungstoken, aus dem mit der Abfrage der Ergebnisse begonnen werden soll. Ein NULL-Wert des Fortsetzungstokens bedeutet, dass werte vom Anfang zurückgegeben werden.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Vorgang des Aufrufs an den Server darstellt.

initialize

public void initialize(ActorTypeInformation actorTypeInformation)

Initialisiert den Akteurzustandsanbieter mit Typinformationen des zugeordneten Akteurtyps.

Überschreibt:

ReliableCollectionsActorStateProvider.initialize(ActorTypeInformation actorTypeInformation)

Parameter:

actorTypeInformation - Typinformationen der Actor-Klasse

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

Initialisieren Sie das Zustandsanbieterreplikat mithilfe der Dienstinitialisierungsinformationen.

Bemerkungen:Während der Initialisierung sollte keine komplexe Verarbeitung durchgeführt werden. In OpenAsync sollte eine teure oder lang andauernde Initialisierung durchgeführt werden.

Überschreibt:

ReliableCollectionsActorStateProvider.initialize(StatefulServiceInitializationParameters initializationParameters)

Parameter:

initializationParameters - Dienstinitialisierungsinformationen wie Dienstname, Partitions-ID, Replikat-ID und Codepaketinformationen.

loadRemindersAsync

public CompletableFuture loadRemindersAsync(CancellationToken cancellationToken)

Lädt alle Erinnerungen, die im Akteurzustandsanbieter enthalten sind.

Überschreibt:

ReliableCollectionsActorStateProvider.loadRemindersAsync(CancellationToken cancellationToken)

Parameter:

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Ladevorgang darstellt. Der Wert des TResult-Parameters ist eine Sammlung aller Akteurerinnerungen, die im Actor-Zustandsanbieter enthalten sind.

loadStateAsync

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

Lädt den Akteurstatus, der dem angegebenen Statusnamen zugeordnet ist.

Überschreibt:

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

Parameter:

actorId - ID des Akteurs, für den der Zustand geladen werden soll.

stateName - Name des zu ladenden Akteurstatus.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Ladevorgang darstellt. Der Wert des TResult-Parameters enthält den Wert des Akteurzustands, der dem angegebenen Statusnamen zugeordnet ist.

openAsync

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

Öffnen Sie das Zustandsanbieterreplikat zur Verwendung.

Bemerkungen:Initialisierungstasks für erweiterte Zustandsanbieter können zu diesem Zeitpunkt gestartet werden.

Überschreibt:

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

Parameter:

openMode - Gibt an, ob es sich um ein neues oder vorhandenes Replikat handelt.

partition - Die Partition, zu der dieses Replikat gehört.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Aufgabe, die den asynchronen Geöffneten Vorgang darstellt. Das Ergebnis enthält den Replizierer, der für die Replikation des Zustands zwischen anderen Zustandsanbieterreplikaten in der Partition verantwortlich ist.

reminderCallbackCompletedAsync

public CompletableFuture reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Wird aufgerufen, wenn eine Erinnerung ausgelöst wird und die Ausführung des Rückrufs receiveReminderAsync(String reminderName, byte[] context, Duration timeSpan, Duration period) erfolgreich abgeschlossen wird

Überschreibt:

ReliableCollectionsActorStateProvider.reminderCallbackCompletedAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Parameter:

actorId - ID des Akteurs, der die Erinnerung besitzt

reminder - Akteurerinnerung, die erfolgreich abgeschlossen wurde.

cancellationToken - Das Token zum Überwachen von Abbruchanforderungen.

Gibt zurück:

Eine Aufgabe, die den asynchronen Erinnerungsrückruf darstellt, der die Verarbeitung von Benachrichtigungen abgeschlossen hat.

removeActorAsync

public CompletableFuture removeActorAsync(ActorId actorId, CancellationToken cancellationToken)

Entfernt alle vorhandenen Zustände und Erinnerungen, die dem angegebenen Akteur atomar zugeordnet sind.

Überschreibt:

ReliableCollectionsActorStateProvider.removeActorAsync(ActorId actorId, CancellationToken cancellationToken)

Parameter:

actorId - ID des Akteurs, für den der Status entfernt werden soll.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Entfernungsvorgang darstellt.

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath)

Stellen Sie eine sicherung wieder her.

Bemerkungen:Es wird eine sichere Wiederherstellung durchgeführt, d. h. die Wiederherstellung wird nur abgeschlossen, wenn die wiederherzustellenden Daten dem Status des aktuellen Replikats voraus sind.

Überschreibt:

ReliableCollectionsActorStateProvider.restoreAsync(String backupFolderPath)

Parameter:

backupFolderPath - Das Verzeichnis, aus dem das Replikat wiederhergestellt werden soll. Dieser Parameter darf nicht NULL oder leer sein oder nur Leerzeichen enthalten. UNC-Pfade können auch bereitgestellt werden.

Gibt zurück:

Aufgabe, die den asynchronen Wiederherstellungsvorgang darstellt.

restoreAsync

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

Wiederherstellen einer sicherung

Überschreibt:

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

Parameter:

backupFolderPath - Das Verzeichnis, aus dem das Replikat wiederhergestellt werden soll. Dieser Parameter darf nicht NULL oder leer sein oder nur Leerzeichen enthalten. UNC-Pfade können auch bereitgestellt werden.

restorePolicy - Die Wiederherstellungsrichtlinie.

timeout - Das Timeout für diesen Vorgang.

cancellationToken - Das Token zum Überwachen von Abbruchanforderungen.

Gibt zurück:

Aufgabe, die den asynchronen Wiederherstellungsvorgang darstellt.

saveReminderAsync

public CompletableFuture saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Speichert die angegebene Akteurerinnerung. Wenn eine Akteurerinnerung mit dem angegebenen Namen nicht vorhanden ist, wird die Akteurerinnerung hinzugefügt, andernfalls wird eine vorhandene Akteurerinnerung mit demselben Namen aktualisiert.

Überschreibt:

ReliableCollectionsActorStateProvider.saveReminderAsync(ActorId actorId, ActorReminder reminder, CancellationToken cancellationToken)

Parameter:

actorId - ID des Akteurs, für den die Erinnerung gespeichert werden soll.

reminder - Zu speichernde Akteurerinnerung.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Speichervorgang darstellt.

saveStateAsync

public CompletableFuture saveStateAsync(ActorId actorId, List stateChanges, CancellationToken cancellationToken)

Speichert den angegebenen Satz von Akteurzustandsänderungen atomar.

Bemerkungen: Die Auflistung der Zustandsänderungen sollte nur ein Element für einen bestimmten Zustandsnamen enthalten. Der Speichervorgang schlägt fehl, wenn versucht wird, einen bereits vorhandenen Akteurstatus hinzuzufügen oder einen nicht vorhandenen Akteurstatus zu aktualisieren bzw. zu entfernen.

Überschreibt:

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

Parameter:

actorId - ID des Akteurs, für den die Zustandsänderungen gespeichert werden sollen.

stateChanges - Sammlung der zu speichernden Zustandsänderungen.

cancellationToken -

CancellationToken-Objekt, um den Abbruch status des Vorgangs anzugeben.

Gibt zurück:

Eine Aufgabe, die den asynchronen Speichervorgang darstellt.

setOnDataLossCallback

public void setOnDataLossCallback(Function> onDataLossAsync)

Funktion, die bei vermuteten Datenverlusten aufgerufen wird

Überschreibt:

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

Parameter:

onDataLossAsync - Funktion, die als Teil der Verarbeitung vermuteter Datenverluste aufgerufen wird. Die Funktion akzeptiert CancellationToken und gibt eine CompletableFuture zurück, die die asynchrone Verarbeitung des Ereignisses darstellt. Gibt true zurück, gibt an, dass der Status des Replikats wiederhergestellt wurde. False gibt an, dass der Status des Replikats nicht geändert wurde.