StateProviderReplica Schnittstelle

Paket:

microsoft.servicefabric.data

public interface StateProviderReplica

Definiert Methoden, die ein zuverlässiges Zustandsanbieterreplikat implementieren muss, damit Service Fabric mit dem Replikat interagieren kann.

Methodenzusammenfassung

Modifizierer und Typ	Methode und Beschreibung
void	abort() Beenden Sie das Zustandsanbieterreplikat gewaltsam. 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<?>	backupAsync(BackupOption option, Duration timeout, CancellationToken cancellationToken, BiFunction<BackupInfo, CancellationToken, CompletableFuture<Boolean>> backupCallback) Führt eine vollständige Sicherung des gesamten zuverlässigen Zustands durch, der von diesem ReliableStateManager verwaltet wird. Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde durchgeführt. Vom BackupCallback zurückgegebene boolesche Daten geben an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException aus, wobei die entsprechende Meldung angibt, dass backupCallback false zurückgegeben wurde. 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 durch, der von diesem ReliableStateManager verwaltet wird. Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde durchgeführt. Vom BackupCallback zurückgegebene boolesche Daten geben an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException aus, wobei die entsprechende Meldung angibt, dass backupCallback false zurückgegeben wurde. 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 des Lastenausgleichs verschoben wird oder ein vorübergehender Fehler erkannt wird.
void	initialize(StatefulServiceInitializationParameters initializationParameters) Initialisieren Sie das Statusanbieterreplikat mithilfe der Dienstinitialisierungsinformationen. Bemerkungen:Während der Initialisierung sollte keine komplexe Verarbeitung durchgeführt werden. Eine teure oder lang andauernde Initialisierung sollte in OpenAsync erfolgen.
CompletableFuture<Replicator>	openAsync(ReplicaOpenMode openMode, StatefulServicePartition partition, CancellationToken cancellationToken) Öffnen Sie das Zustandsanbieterreplikat zur Verwendung. Bemerkungen:Die Initialisierungsaufgaben des erweiterten Zustandsanbieters können zu diesem Zeitpunkt gestartet werden.
CompletableFuture<?>	restoreAsync(String backupFolderPath) Stellen Sie eine sicherung wieder her. Bemerkungen:Es wird eine sichere Wiederherstellung durchgeführt, was bedeutet, dass die Wiederherstellung nur abgeschlossen wird, wenn die wiederherzustellenden Daten vor dem Zustand des aktuellen Replikats sind.
CompletableFuture<?>	restoreAsync(String backupFolderPath, RestorePolicy restorePolicy, Duration timeout, CancellationToken cancellationToken) Wiederherstellen einer sicherung
void	setOnDataLossCallback(Function<CancellationToken, CompletableFuture<Boolean>> onDataLossAsync) Funktion, die bei vermuteten Datenverlusten aufgerufen wird

Details zur Methode

abort

public void abort()

Beenden Sie das Zustandsanbieterreplikat gewaltsam.

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.

backupAsync

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

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

Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde durchgeführt. Vom BackupCallback zurückgegebene boolesche Daten geben an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException aus, wobei die entsprechende Meldung angibt, dass backupCallback false zurückgegeben wurde. Außerdem wird die Sicherung als nicht erfolgreich markiert.

Parameters:

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

Returns:

Aufgabe, die den asynchronen Sicherungsvorgang darstellt.

backupAsync

public CompletableFuture backupAsync(BiFunction> backupCallback)

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

Bemerkungen: Eine VOLLSTÄNDIGE Sicherung wird mit einem Timeout von einer Stunde durchgeführt. Vom BackupCallback zurückgegebene boolesche Daten geben an, ob der Dienst den Sicherungsordner erfolgreich an einen externen Speicherort verschieben konnte. Wenn false zurückgegeben wird, löst BackupAsync UnsupportedOperationException aus, wobei die entsprechende Meldung angibt, dass backupCallback false zurückgegeben wurde. Außerdem wird die Sicherung als nicht erfolgreich markiert.

Parameters:

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

Returns:

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

Parameters:

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

cancellationToken -

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

Returns:

Aufgabe, die den asynchronen Vorgang der Rollenänderung 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 des Lastenausgleichs verschoben wird oder ein vorübergehender Fehler erkannt wird.

Parameters:

cancellationToken -

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

Returns:

Aufgabe, die den asynchronen Vorgang zum Schließen darstellt.

initialize

public void initialize(StatefulServiceInitializationParameters initializationParameters)

Initialisieren Sie das Statusanbieterreplikat mithilfe der Dienstinitialisierungsinformationen.

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

Parameters:

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

openAsync

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

Öffnen Sie das Zustandsanbieterreplikat zur Verwendung.

Bemerkungen:Die Initialisierungsaufgaben des erweiterten Zustandsanbieters können zu diesem Zeitpunkt gestartet werden.

Parameters:

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 die Abbruch-status des Vorgangs anzugeben.

Returns:

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

restoreAsync

public CompletableFuture restoreAsync(String backupFolderPath)

Stellen Sie eine sicherung wieder her.

Bemerkungen:Es wird eine sichere Wiederherstellung durchgeführt, was bedeutet, dass die Wiederherstellung nur abgeschlossen wird, wenn die wiederherzustellenden Daten vor dem Zustand des aktuellen Replikats sind.

Parameters:

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

Returns:

Aufgabe, die den asynchronen Wiederherstellungsvorgang darstellt.

restoreAsync

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

Wiederherstellen einer sicherung

Parameters:

backupFolderPath - Das Verzeichnis, aus dem das Replikat wiederhergestellt werden soll. Dieser Parameter darf nicht NULL, leer 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.

Returns:

Aufgabe, die den asynchronen Wiederherstellungsvorgang darstellt.

setOnDataLossCallback

public void setOnDataLossCallback(Function> onDataLossAsync)

Funktion, die bei vermuteten Datenverlusten aufgerufen wird

Parameters:

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