MemoryStreamQueueGrain Klasse

Definition

Namespace:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.

public class MemoryStreamQueueGrain : Orleans.Grain, Orleans.IGrainWithGuidKey, Orleans.Providers.IMemoryStreamQueueGrain, Orleans.Runtime.IGrainMigrationParticipant

type MemoryStreamQueueGrain = class
    inherit Grain
    interface IMemoryStreamQueueGrain
    interface IGrainWithGuidKey
    interface IGrain
    interface IAddressable
    interface IGrainMigrationParticipant

Public Class MemoryStreamQueueGrain
Inherits Grain
Implements IGrainMigrationParticipant, IGrainWithGuidKey, IMemoryStreamQueueGrain

Vererbung

Object

Grain

MemoryStreamQueueGrain

Implementiert

IGrain IGrainWithGuidKey IMemoryStreamQueueGrain IAddressable IGrainMigrationParticipant

Konstruktoren

MemoryStreamQueueGrain()

Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.

Eigenschaften

GrainContext	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest. (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	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest. (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)

Methoden

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)
Dequeue(Int32)	Dequeues bis zu einer maximalen Menge an maxCount-Ereignisdaten aus der Warteschlange.
Enqueue(MemoryMessageData)	Queues eine Ereignisdaten. Wenn die aktuelle Gesamtanzahl den maximalen Grenzwert erreicht. löst eine Ausnahme aus.
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)
GetStreamProvider(String)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest. (Geerbt von Grain)
GetStreamProviders()	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest. (Geerbt von Grain)
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)	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)
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)
Participate(IGrainLifecycle)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest. (Geerbt von Grain)
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)
UnregisterReminder(IGrainReminder)	Hebt die Registrierung einer zuvor registrierten Erinnerung auf. (Geerbt von Grain)

Explizite Schnittstellenimplementierungen

IGrainMigrationParticipant.OnDehydrate(IDehydrationContext)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.
IGrainMigrationParticipant.OnRehydrate(IRehydrationContext)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.

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)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.
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)	Speicherdatenstrom-Warteschlangenkorn. Dieses Korn funktioniert als Speicherwarteschlange mit Ereignisdaten. Enqueue- und Dequeue-Vorgänge werden unterstützt. die maximale Ereignisanzahl legt den maximalen Speichergrenzwert auf die Warteschlange fest.
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.