JournaledGrain<TGrainState,TEventBase> Klasse

Definition

Namespace:

Orleans.EventSourcing

Assembly:

Orleans.EventSourcing.dll

Paket:

Microsoft.Orleans.EventSourcing v8.1.0

Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher.

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 Körnungszustand, 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 versionsbasierten Zustand mithilfe des Standardspeicheranbieters.
GrainFactory	Ruft ein -Objekt ab, das für den Zugriff auf andere Grains verwendet werden kann. Null, wenn dieses Grain nicht einer Runtime zugeordnet ist, z. B. bei direkter Erstellung für Komponententests. (Geerbt von Grain)
GrainReference	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher. (Geerbt von Grain)
IdentityString	Zeichenfolgendarstellung der SiloIdentity von Grain, einschließlich Typ und Primärschlüssel. (Geerbt von Grain)
RuntimeIdentity	Ein eindeutiger Bezeichner für das aktuelle Silo. Diese Zeichenfolge enthält keinen semantischen Inhalt, kann aber für die Protokollierung nützlich sein. (Geerbt von Grain)
ServiceProvider	Ruft den von der Runtime verwalteten IServiceProvider ab. Null, wenn dieses Grain nicht einer Runtime zugeordnet ist, z. B. bei direkter Erstellung für Komponententests. (Geerbt von Grain)
State	Ruft den aktuellen bestätigten Zustand ab. Enthält nur bestätigte Ereignisse.
TentativeState	Ruft den aktuellen vorläufigen Zustand ab. Umfasst sowohl bestätigte als auch nicht bestätigte Ereignisse.
UnconfirmedEvents	Gibt die aktuelle Warteschlange mit 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 Grains vorhanden sind.
DeactivateOnIdle()	Deaktivieren Sie diese Aktivierung des Grains, nachdem der aktuelle Grain-Methodenaufruf abgeschlossen ist. Dieser Aufruf markiert diese Aktivierung des aktuellen Grains, das am Ende der aktuellen Methode deaktiviert und entfernt werden soll. Der nächste Aufruf dieses Grains führt zu einer anderen zu verwendenden Aktivierung, was typischerweise bedeutet, dass eine neue Aktivierung automatisch von der Runtime erstellt wird. (Geerbt von Grain)
DelayDeactivation(TimeSpan)	Verzögerte Deaktivierung dieser Aktivierung mindestens für den angegebenen Zeitraum. Ein positiver timeSpan Wert bedeutet "Gc dieser Aktivierung für diese Zeitspanne verhindern". Ein negativer timeSpan Wert bedeutet", dass die vorherige Einstellung des DelayDeactivation-Aufrufs abgebrochen und diese Aktivierung sich basierend auf den regulären Aktivierungs garbage Collection-Einstellungen verhält. Die DeactivateOnIdle-Methode würde alle aktuellen "Keep Alive"-Einstellung rückgängig machen/außer Kraft setzen, sodass dieses Körnchen sofort für die Deaktivierung verfügbar ist. (Geerbt von Grain)
DisableStatsCollection()	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher.
EnableStatsCollection()	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher.
GetLogger()	Gibt ein Protokollierobjekt zurück, das der Code dieses Grains für die Ablaufverfolgung verwenden kann. Der Name der Protokollierung wird vom Kornklassennamen abgeleitet. (Geerbt von Grain)
GetLogger(String)	Gibt ein Protokollierobjekt zurück, das der Code dieses Grains 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 vom Grain registrierten Erinnerungen zurück. (Geerbt von Grain)
GetStats()	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher.
GetStreamProvider(String)	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher. (Geerbt von Grain)
GetStreamProviders()	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher. (Geerbt von Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	Wird direkt nach dem Erstellen von Grain aufgerufen, um den Adapter zu installieren. Der Protokollkonsistenzanbieter enthält eine Factorymethode, die den Adapter mit ausgewählten Typen für dieses Grain erstellt.
MigrateOnIdle()	Startet einen Versuch, diese instance an einen anderen Speicherort zu migrieren. Die Migration erfasst den aktuellen RequestContext, sodass er dem Platzierungsdirektor der Aktivierung zur Verfügung gestellt wird, sodass er ihn bei der Auswahl eines neuen Standorts berücksichtigen kann. Die Migration erfolgt asynchron, wenn keine Anforderungen ausgeführt werden, und nicht, wenn der Platzierungsdirektor der Aktivierung keinen alternativen Speicherort auswählt. (Geerbt von Grain)
OnActivateAsync()	Diese Methode wird am Ende des Aktivierungsprozesses eines Grains aufgerufen. Es wird aufgerufen, bevor Nachrichten an das Körnchen gesendet wurden. Bei Grains mit deklariertem persistentem Zustand wird diese Methode aufgerufen, nachdem die State-Eigenschaft aufgefüllt wurde. (Geerbt von Grain)
OnActivateAsync(CancellationToken)	Standardmäßig wartet das journalierte Grain nach der Aktivierung, bis die neueste Ansicht aus dem Speicher geladen wurde. Unterklassen können dieses Verhalten überschreiben und die Wartezeit bei Bedarf überspringen.
OnConnectionIssue(ConnectionIssue)	Wird aufgerufen, wenn beim zugrunde liegenden Persistenz- oder Replikationsprotokoll ein Verbindungsproblem besteht. Überschreiben Sie dies, um die Integrität des Protokollkonsistenzprotokolls zu überwachen und/oder Wiederholungsverzögerungen anzupassen. Alle ausgelösten Ausnahmen werden vom ILogViewAdaptorFactoryabgefangen und protokolliert.
OnConnectionIssueResolved(ConnectionIssue)	Wird aufgerufen, wenn ein zuvor gemeldetes Verbindungsproblem behoben wurde. Überschreiben Sie dies, um die Integrität des Protokollkonsistenzprotokolls zu überwachen. Alle ausgelösten Ausnahmen werden vom ILogViewAdaptorFactoryabgefangen und protokolliert.
OnDeactivateAsync()	Diese Methode wird zu Beginn des Prozesses zum Deaktivieren eines Grains aufgerufen. (Geerbt von Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	Diese Methode wird zu Beginn des Prozesses zum Deaktivieren eines Grains aufgerufen. (Geerbt von Grain)
OnStateChanged()	Wird aufgerufen, nachdem sich der bestätigte Zustand möglicherweise 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 immer dann aufgerufen, wenn sich der vorläufige Zustand aufgrund lokaler oder Remoteereignisse geändert hat. Überschreiben Sie dies, um auf Änderungen des Zustands zu reagieren.
Participate(IGrainLifecycle)	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher. (Geerbt von LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)	Auslösen eines Ereignisses bedingt. Gelingt nur, wenn es keine Konflikte gibt, d. h. in der Zwischenzeit keine anderen Ereignisse ausgelöst wurden.
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)	Lösen Sie mehrere Ereignisse als atomare Sequenz bedingt aus. Gelingt nur, wenn es keine Konflikte gibt, d. h. in der Zwischenzeit keine anderen Ereignisse ausgelöst wurden.
RaiseEvent<TEvent>(TEvent)	Löst ein Ereignis aus.
RaiseEvents<TEvent>(IEnumerable<TEvent>)	Lösen Sie mehrere Ereignisse als atomare Sequenz aus.
RefreshNow()	Ruft jetzt den neuesten Zustand ab und bestätigt alle zuvor ausgelösten Ereignisse. Dies erzwingt effektiv 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 Grains vorhanden sind.
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Grain zu senden. Das Grain muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Grain werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Grain deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Grains 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 von einer Aktivierung dieses Grains empfangen, auch wenn für dieses Grain mehrere Aktivierungen vorhanden sind. (Geerbt von Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	Registriert einen Timer, um regelmäßige Rückrufe an dieses Grain zu senden. (Geerbt von Grain)
RetrieveConfirmedEvents(Int32, Int32)	Ruft ein Segment der bestätigten Ereignissequenz ab, möglicherweise aus dem Speicher. Löst aus NotSupportedException , 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. Sofern sie nicht in der Unterklasse überschrieben wird, wird eine dynamische "Apply"-Funktion für den Zustand mit dem -Ereignis als Parameter aufgerufen. Alle von dieser Methode ausgelösten Ausnahmen werden vom Protokollansichtsanbieter abgefangen und protokolliert. Überschreiben Sie dies, um den Übergang des Zustands für ein bestimmtes Ereignis anzupassen.
UnregisterReminder(IGrainReminder)	Hebt die Registrierung einer zuvor registrierten Erinnerung auf. (Geerbt von Grain)

Explizite Schnittstellenimplementierungen

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)	wird bei Verbindungsproblemen vom Adapter aufgerufen.
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)	Wird vom Adapter aufgerufen, wenn ein Verbindungsproblem behoben ist.
IGrainBase.GrainContext	Eine Basisklasse für protokollkonsistente Grains unter Verwendung der Standardterminologie für die Ereignissourcierung. Alle Vorgänge sind reentrancy-sicher. (Geerbt von Grain)
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()	Protokollansichtsadapter für die Deaktivierung benachrichtigen
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()	Protokollansichtsadapter für die Aktivierung benachrichtigen (aufgerufen nach OnActivate auf Benutzerebene)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()	Protokollansichtsadapter für die Aktivierung benachrichtigen (wird vor OnActivate auf Benutzerebene aufgerufen)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)	Wird bei Zustandsänderung vom Adapter 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, nachdem der aktuelle Grain-Methodenaufruf abgeschlossen ist. Dieser Aufruf markiert diese Aktivierung des aktuellen Grains, das am Ende der aktuellen Methode deaktiviert und entfernt werden soll. Der nächste Aufruf dieses Grains führt zu einer anderen zu verwendenden Aktivierung, was typischerweise bedeutet, dass eine neue Aktivierung automatisch von der Runtime erstellt wird.
MigrateOnIdle(IGrainBase)	Startet einen Versuch, diese instance an einen anderen Speicherort zu migrieren. Die Migration erfasst den aktuellen RequestContext, sodass er dem Platzierungsdirektor der Aktivierung zur Verfügung gestellt wird, sodass er ihn bei der Auswahl eines neuen Standorts berücksichtigen kann. Die Migration erfolgt asynchron, wenn keine Anforderungen ausgeführt werden, und nicht, wenn der Platzierungsdirektor der Aktivierung keinen alternativen Speicherort auswählt.
AsReference(IAddressable, Type)	Gibt einen typisierten Verweis auf das bereitgestellte Grain zurück.
AsReference<TGrainInterface>(IAddressable)	Gibt einen typisierten Verweis auf das bereitgestellte Grain zurück.
Cast(IAddressable, Type)	Gibt einen typisierten Verweis auf das bereitgestellte Grain zurück.
Cast<TGrainInterface>(IAddressable)	Gibt einen typisierten Verweis auf das bereitgestellte Grain zurück.
GetGrainId(IAddressable)	Gibt die Korn-ID zurück, die dem angegebenen Grain entspricht.
GetPrimaryKey(IAddressable)	Gibt die Guid Darstellung eines körnigen Primärschlüssels zurück.
GetPrimaryKey(IAddressable, String)	Gibt die Guid Darstellung eines körnigen Primärschlüssels zurück.
GetPrimaryKeyLong(IAddressable)	Gibt die long Darstellung eines körnigen Primärschlüssels zurück.
GetPrimaryKeyLong(IAddressable, String)	Gibt die long Darstellung eines körnigen Primärschlüssels zurück.
GetPrimaryKeyString(IAddressable)	Gibt den string Primärschlüssel des Grains 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 vom Grain registrierten Erinnerungen zurück.
GetReminders(IGrainBase)	Gibt eine Liste aller vom Grain registrierten Erinnerungen zurück.
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Grain zu senden. Das Grain muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Grain werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Grain deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Grains 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 von einer Aktivierung dieses Grains empfangen, auch wenn für dieses Grain mehrere Aktivierungen vorhanden sind.
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	Registriert eine dauerhafte, zuverlässige Erinnerung, um regelmäßige Benachrichtigungen (Erinnerungen) an das Grain zu senden. Das Grain muss die Orleans.IRemindable Schnittstelle implementieren, und Erinnerungen für dieses Grain werden an die ReceiveReminder Rückrufmethode gesendet. Wenn das aktuelle Grain deaktiviert wird, wenn der Timer ausgelöst wird, wird eine neue Aktivierung dieses Grains 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 von einer Aktivierung dieses Grains empfangen, auch wenn für dieses Grain 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 Streamanbieter mit dem angegebenen nameab.
GetStreamProvider(IGrainBase, String)	Ruft den Streamanbieter mit dem angegebenen nameab.