JournaledGrain<TGrainState,TEventBase> Klasse

Definition

Namespace:

Orleans.EventSourcing

Assembly:

Orleans.EventSourcing.dll

Paket:

Microsoft.Orleans.EventSourcing v8.2.0

Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.

public abstract class JournaledGrain<TGrainState,TEventBase> : Orleans.EventSourcing.LogConsistentGrain<TGrainState>, Orleans.EventSourcing.ILogConsistencyProtocolParticipant, Orleans.EventSourcing.ILogViewAdaptorHost<TGrainState,TEventBase>, Orleans.IGrain where TGrainState : class, new() where TEventBase : class

type JournaledGrain<'GrainState, 'EventBase (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState) and 'EventBase : null)> = class
    inherit LogConsistentGrain<'GrainState (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState))>
    interface ILogConsistencyProtocolParticipant
    interface IGrain
    interface IAddressable
    interface ILogViewAdaptorHost<'GrainState, 'EventBase (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState) and 'EventBase : null)>
    interface IConnectionIssueListener

Public MustInherit Class JournaledGrain(Of TGrainState, TEventBase)
Inherits LogConsistentGrain(Of TGrainState)
Implements IGrain, ILogConsistencyProtocolParticipant, ILogViewAdaptorHost(Of TGrainState, TEventBase)

Typparameter

TGrainState

Der Typ für den Kornzustand, d. h. die Aggregatansicht des Ereignisprotokolls.

TEventBase

Die allgemeine Basisklasse für die Ereignisse

Vererbung

Object

Grain

LogConsistentGrain<TGrainState>

JournaledGrain<TGrainState,TEventBase>

Abgeleitet

Orleans.EventSourcing.JournaledGrain<TGrainState>

Implementiert

IGrain IAddressable IConnectionIssueListener ILogConsistencyProtocolParticipant ILogViewAdaptorHost<TGrainState,TEventBase>

Konstruktoren

JournaledGrain<TGrainState,TEventBase>()

Initialisiert eine neue Instanz der JournaledGrain<TGrainState,TEventBase> Klasse.

Eigenschaften

DefaultAdaptorFactory	Wenn kein Protokollkonsistenzanbieter angegeben ist, speichern Sie den Versionsstatus mithilfe des Standardspeicheranbieters.
GrainContext	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe. (Geerbt von Grain)
GrainFactory	Ruft ein Objekt ab, das für den Zugriff auf andere Getreide verwendet werden kann. Null, wenn dieser Korn nicht einer Runtime zugeordnet ist, z. B. wenn sie direkt für Komponententests erstellt wird. (Geerbt von Grain)
GrainReference	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe. (Geerbt von Grain)
IdentityString	Zeichenfolgendarstellung der SiloIdentity des Korns, einschließlich Typ und Primärschlüssel. (Geerbt von Grain)
RuntimeIdentity	Ein eindeutiger Bezeichner für den aktuellen Silo. Für diese Zeichenfolge gibt es keinen semantischen Inhalt, kann aber für die Protokollierung hilfreich sein. (Geerbt von Grain)
ServiceProvider	Ruft den von der Laufzeit verwalteten IServiceProvider ab. Null, wenn dieser Korn nicht einer Runtime zugeordnet ist, z. B. wenn sie direkt für Komponententests erstellt wird. (Geerbt von Grain)
State	Ruft den aktuellen bestätigten Zustand ab. Umfasst nur bestätigte Ereignisse.
TentativeState	Ruft den aktuellen Zustand mit Vorbehalt ab. Umfasst sowohl bestätigte als auch nicht bestätigte Ereignisse.
UnconfirmedEvents	Gibt die aktuelle Warteschlange von nicht bestätigten Ereignissen zurück.
Version	Ruft die Version des aktuellen bestätigten Zustands ab. Entspricht der Gesamtzahl der bestätigten Ereignisse.

Methoden

ConfirmEvents()	Wartet, bis alle zuvor ausgelösten Ereignisse bestätigt wurden. warten Sie dies nach dem Auslösen eines oder mehrerer Ereignisse, um sicherzustellen, dass Ereignisse beibehalten werden, bevor sie fortfahren, oder um eine starke Konsistenz (Linearisierbarkeit) zu gewährleisten, auch wenn mehrere Instanzen dieses Korns vorhanden sind.
DeactivateOnIdle()	Deaktivieren Sie diese Aktivierung des Korns, nachdem der aktuelle Kornmethodenaufruf abgeschlossen wurde. Dieser Aufruf markiert diese Aktivierung des aktuellen Korns, das deaktiviert und am Ende der aktuellen Methode entfernt wird. Der nächste Aufruf dieses Korns führt dazu, dass eine andere Aktivierung verwendet wird, was typischerweise bedeutet, dass eine neue Aktivierung automatisch von der Laufzeit erstellt wird. (Geerbt von Grain)
DelayDeactivation(TimeSpan)	Verzögern der Deaktivierung dieser Aktivierung mindestens für die angegebene Zeitdauer. Ein positiver timeSpan Wert bedeutet "GC dieser Aktivierung für diesen Zeitraum verhindern". Ein negativer timeSpan Wert bedeutet "die vorherige Einstellung des DelayDeactivation-Aufrufs abbrechen und dieses Aktivierungsverhalten basierend auf den regulären Einstellungen für die Aktivierungsbereinigung vornehmen". Die DeactivateOnIdle-Methode würde alle aktuellen "Keep Alive"-Einstellungen rückgängig machen/ außer Kraft setzen, sodass dieses Korn sofort für die Deaktivierung verfügbar ist. (Geerbt von Grain)
DisableStatsCollection()	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.
EnableStatsCollection()	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.
GetLogger()	Gibt ein Loggerobjekt zurück, das der Code dieses Korns für die Ablaufverfolgung verwenden kann. Der Name des Loggers wird vom Kornklassennamen abgeleitet. (Geerbt von Grain)
GetLogger(String)	Gibt ein Loggerobjekt zurück, das der Code dieses Korns für die Ablaufverfolgung verwenden kann. (Geerbt von Grain)
GetReminder(String)	Gibt eine zuvor registrierte Erinnerung zurück. (Geerbt von Grain)
GetReminders()	Gibt eine Liste aller Erinnerungen zurück, die vom Korn registriert wurden. (Geerbt von Grain)
GetStats()	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.
GetStreamProvider(String)	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe. (Geerbt von Grain)
GetStreamProviders()	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe. (Geerbt von Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	Wird direkt nach der Konstruktion des Getreides aufgerufen, um den Adapter zu installieren. Der Protokollkonsistenzanbieter enthält eine Factorymethode, mit der der Adapter mit ausgewählten Typen für dieses Korn erstellt wird.
MigrateOnIdle()	Startet einen Versuch, diese Instanz an einen anderen Speicherort zu migrieren. Die Migration erfasst die aktuelle RequestContext, sodass sie dem Platzierungsdirektor der Aktivierung zur Verfügung gestellt wird, damit sie beim Auswählen eines neuen Speicherorts berücksichtigt werden kann. Die Migration erfolgt asynchron, wenn keine Anforderungen ausgeführt werden, und tritt nicht auf, wenn der Platzierungsdirektor der Aktivierung keinen alternativen Speicherort auswählt. (Geerbt von Grain)
OnActivateAsync()	Diese Methode wird am Ende des Prozesses der Aktivierung eines Getreides aufgerufen. Es wird aufgerufen, bevor alle Nachrichten an das Korn verteilt wurden. Bei Körnern mit deklariertem persistentem Zustand wird diese Methode aufgerufen, nachdem die State-Eigenschaft aufgefüllt wurde. (Geerbt von Grain)
OnActivateAsync(CancellationToken)	Standardmäßig wartet das aufgezeichnete Getreide bei der Aktivierung, bis sie die neueste Ansicht aus dem Speicher geladen hat. Unterklassen können dieses Verhalten außer Kraft setzen und die Wartezeit bei Bedarf überspringen.
OnConnectionIssue(ConnectionIssue)	Wird aufgerufen, wenn das zugrunde liegende Persistenz- oder Replikationsprotokoll in irgendeiner Art von Verbindungsproblemen ausgeführt wird. Überschreiben Sie dies, um den Status des Protokollkonsistenzprotokolls und/oder zum Anpassen von Wiederholungsverzögerungen zu überwachen. Alle ausgelösten Ausnahmen werden vom ILogViewAdaptorFactoryabgefangen und protokolliert.
OnConnectionIssueResolved(ConnectionIssue)	Wird aufgerufen, wenn ein zuvor gemeldetes Verbindungsproblem behoben wurde. Überschreiben Sie dies, um den Status des Protokollkonsistenzprotokolls zu überwachen. Alle ausgelösten Ausnahmen werden vom ILogViewAdaptorFactoryabgefangen und protokolliert.
OnDeactivateAsync()	Diese Methode wird am Anfang des Prozesses der Deaktivierung eines Getreides aufgerufen. (Geerbt von Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	Diese Methode wird am Anfang des Prozesses der Deaktivierung eines Getreides aufgerufen. (Geerbt von Grain)
OnStateChanged()	Wird aufgerufen, nachdem sich der bestätigten Zustand geändert hat (d. h. die bestätigte Versionsnummer ist größer). Überschreiben Sie dies, um auf Änderungen des bestätigten Zustands zu reagieren.
OnTentativeStateChanged()	Wird aufgerufen, wenn sich der Vorbehaltszustand aufgrund von lokalen oder Remoteereignissen möglicherweise geändert hat. Überschreiben Sie dies, um auf Änderungen des Zustands zu reagieren.
Participate(IGrainLifecycle)	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe. (Geerbt von LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)	Auslösen eines Ereignisses bedingt. Ist nur erfolgreich, wenn keine Konflikte vorhanden sind, d. h., in der Zwischenzeit wurden keine anderen Ereignisse ausgelöst.
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)	Auslösen mehrerer Ereignisse als Atomsequenz bedingt. Ist nur erfolgreich, wenn keine Konflikte vorhanden sind, d. h., in der Zwischenzeit wurden keine anderen Ereignisse ausgelöst.
RaiseEvent<TEvent>(TEvent)	Löst ein Ereignis aus.
RaiseEvents<TEvent>(IEnumerable<TEvent>)	Auslösen mehrerer Ereignisse als Atomsequenz.
RefreshNow()	Ruft den aktuellen Zustand jetzt ab und bestätigt alle zuvor ausgelösten Ereignisse. Effektiv erzwingt dies die Synchronisierung mit dem globalen Zustand. Warten Sie darauf, bevor Sie den Zustand lesen, um eine starke Konsistenz (Linearisierbarkeit) zu gewährleisten, auch wenn mehrere Instanzen dieses Korns vorhanden sind.
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Korn zu senden. Das Korn muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Korn werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Korn deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Korns erstellt, um diese Erinnerung zu erhalten. Wenn bereits eine vorhandene Erinnerung mit demselben Namen vorhanden ist, wird diese Erinnerung mit dieser neuen Erinnerung überschrieben. Erinnerungen werden immer durch eine Aktivierung dieses Korns empfangen, auch wenn für dieses Korn mehrere Aktivierungen vorhanden sind. (Geerbt von Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	Veraltet. Registriert einen Timer, um regelmäßige Rückrufe an dieses Korn zu senden. (Geerbt von Grain)
RetrieveConfirmedEvents(Int32, Int32)	Ruft ein Segment der bestätigten Ereignissequenz ab, möglicherweise aus dem Speicher. Löst NotSupportedException aus, wenn die Ereignisse nicht zum Lesen verfügbar sind. Ob Ereignisse verfügbar sind und wie lange, hängt von den verwendeten Anbietern und deren Konfiguration ab.
TransitionState(TGrainState, TEventBase)	Definiert, wie Ereignisse auf den Zustand angewendet werden. Es sei denn, sie wird in der Unterklasse außer Kraft gesetzt, sie ruft eine dynamische "Apply"-Funktion für den Zustand auf, wobei das Ereignis als Parameter gilt. Alle von dieser Methode ausgelösten Ausnahmen werden vom Protokollansichtsanbieter abgefangen und protokolliert. Überschreiben Sie dies, um anzupassen, wie der Zustand für ein bestimmtes Ereignis übertragen wird.
UnregisterReminder(IGrainReminder)	Hebt die Registrierung einer zuvor registrierten Erinnerung auf. (Geerbt von Grain)

Explizite Schnittstellenimplementierungen

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)	von Adaptor bei Verbindungsproblemen aufgerufen.
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)	Wird von Adaptor aufgerufen, wenn ein Verbindungsproblem behoben wird.
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()	Protokollansichts-Adaptor zur Deaktivierung benachrichtigen
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()	Benachrichtigen des Aktivierungsadapters für die Protokollansicht (aufgerufen nach OnActivate auf Benutzerebene)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()	Benachrichtigen des Aktivierungsadapters für die Protokollansicht (aufgerufen vor OnActivate auf Benutzerebene)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)	Wird von Adaptor bei Zustandsänderung aufgerufen.
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)	Wird vom Adaptor aufgerufen, um die Ansicht zu aktualisieren, wenn Einträge angefügt werden.

Erweiterungsmethoden

DeactivateOnIdle(IGrainBase)	Deaktivieren Sie diese Kornaktivierung nach Abschluss des aktuellen Kornmethodenaufrufs. Dieser Aufruf markiert diese Aktivierung des aktuellen Korns, das deaktiviert und am Ende der aktuellen Methode entfernt wird. Der nächste Aufruf dieses Korns führt dazu, dass eine andere Aktivierung verwendet wird, was typischerweise bedeutet, dass eine neue Aktivierung automatisch von der Laufzeit erstellt wird.
MigrateOnIdle(IGrainBase)	Startet einen Versuch, diese Instanz an einen anderen Speicherort zu migrieren. Die Migration erfasst die aktuelle RequestContext, sodass sie dem Platzierungsdirektor der Aktivierung zur Verfügung gestellt wird, damit sie beim Auswählen eines neuen Speicherorts berücksichtigt werden kann. Die Migration erfolgt asynchron, wenn keine Anforderungen ausgeführt werden, und tritt nicht auf, wenn der Platzierungsdirektor der Aktivierung keinen alternativen Speicherort auswählt.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, GrainTimerCreationOptions)	Erstellt einen Korntimer.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, TimeSpan, TimeSpan)	Erstellt einen Korntimer.
RegisterGrainTimer(IGrainBase, Func<Task>, GrainTimerCreationOptions)	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.
RegisterGrainTimer(IGrainBase, Func<Task>, TimeSpan, TimeSpan)	Erstellt einen Korntimer.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, GrainTimerCreationOptions)	Erstellt einen Korntimer.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, TimeSpan, TimeSpan)	Erstellt einen Korntimer.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, GrainTimerCreationOptions)	Eine Basisklasse für logkonsensierte Getreide mit standard event-sourcing terminologie. Alle Vorgänge sind reentrancy-safe.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, TimeSpan, TimeSpan)	Erstellt einen Korntimer.
AsReference(IAddressable, Type)	Gibt einen typierten Verweis auf das angegebene Korn zurück.
AsReference<TGrainInterface>(IAddressable)	Gibt einen typierten Verweis auf das angegebene Korn zurück.
Cast(IAddressable, Type)	Gibt einen typierten Verweis auf das angegebene Korn zurück.
Cast<TGrainInterface>(IAddressable)	Gibt einen typierten Verweis auf das angegebene Korn zurück.
GetGrainId(IAddressable)	Gibt die Korn-ID zurück, die dem bereitgestellten Getreide entspricht.
GetPrimaryKey(IAddressable)	Gibt die Guid Darstellung eines Getreide-Primärschlüssels zurück.
GetPrimaryKey(IAddressable, String)	Gibt die Guid Darstellung eines Getreide-Primärschlüssels zurück.
GetPrimaryKeyLong(IAddressable)	Gibt die long Darstellung eines Getreide-Primärschlüssels zurück.
GetPrimaryKeyLong(IAddressable, String)	Gibt die long Darstellung eines Getreide-Primärschlüssels zurück.
GetPrimaryKeyString(IAddressable)	Gibt den string Primärschlüssel des Korns zurück.
IsPrimaryKeyBasedOnLong(IAddressable)	Gibt zurück, ob ein Teil des Primärschlüssels vom Typ longist.
GetReminder(Grain, String)	Gibt eine zuvor registrierte Erinnerung zurück.
GetReminder(IGrainBase, String)	Gibt eine zuvor registrierte Erinnerung zurück.
GetReminders(Grain)	Gibt eine Liste aller Erinnerungen zurück, die vom Korn registriert wurden.
GetReminders(IGrainBase)	Gibt eine Liste aller Erinnerungen zurück, die vom Korn registriert wurden.
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Korn zu senden. Das Korn muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Korn werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Korn deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Korns erstellt, um diese Erinnerung zu erhalten. Wenn bereits eine vorhandene Erinnerung mit demselben Namen vorhanden ist, wird diese Erinnerung mit dieser neuen Erinnerung überschrieben. Erinnerungen werden immer durch eine Aktivierung dieses Korns empfangen, auch wenn für dieses Korn mehrere Aktivierungen vorhanden sind.
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Korn zu senden. Das Korn muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Korn werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Korn deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Korns erstellt, um diese Erinnerung zu erhalten. Wenn bereits eine vorhandene Erinnerung mit demselben Namen vorhanden ist, wird diese Erinnerung mit dieser neuen Erinnerung überschrieben. Erinnerungen werden immer durch eine Aktivierung dieses Korns empfangen, auch wenn für dieses Korn mehrere Aktivierungen vorhanden sind.
UnregisterReminder(Grain, IGrainReminder)	Hebt die Registrierung einer zuvor registrierten Erinnerung auf.
UnregisterReminder(IGrainBase, IGrainReminder)	Hebt die Registrierung einer zuvor registrierten Erinnerung auf.
GetStreamProvider(Grain, String)	Ruft den Datenstromanbieter mit dem angegebenen nameab.
GetStreamProvider(IGrainBase, String)	Ruft den Datenstromanbieter mit dem angegebenen nameab.