EventHubQueueCache Klasse

Referenz

Definition

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paket:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paket:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paket:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Quelle:: EventHubQueueCache.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Nachrichtencache, der EventData als CachedEventHubMessage in einem Poolnachrichtencache speichert

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Vererbung: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

Vererbung: Object
EventHubQueueCache

Implementiert: IEventHubQueueCache IQueueFlowController IDisposable

Konstruktoren

EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache mit einem benutzerdefinierten Datenadapter.
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache mit einem benutzerdefinierten Datenadapter.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache mit einem benutzerdefinierten Datenadapter.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache mit einem benutzerdefinierten Datenadapter.
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache unter Verwendung eines Pufferpools. Verwendet den Standarddatenadapter
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den Cache unter Verwendung eines Pufferpools. Verwendet den Standarddatenadapter
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)	EventHub-Warteschlangencache.

Felder

cache	Zugrunde liegende Nachrichtencacheimplementierung zu Testzwecken geschützt
cache	Zugrunde liegende Nachrichtencacheimplementierung (Geerbt von EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	Maximale Standardanzahl von Elementen, die zwischen Löschaufrufen zum Cache hinzugefügt werden können (Geerbt von EventHubQueueCache<TCachedMessage>)

Eigenschaften

Checkpointer	Logik zum Speichern der Warteschlangenposition (Geerbt von EventHubQueueCache<TCachedMessage>)
Partition	Nachrichtencache, der EventData als CachedEventHubMessage in einem Poolnachrichtencache speichert

Methoden

Add(List<EventData>, DateTime)	Fügen Sie dem Cache eine Liste von EventHub EventData hinzu.
Add(List<EventData>, DateTime)	Fügen Sie dem Cache eine Liste von EventHub EventData hinzu. (Geerbt von EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)	Fügen Sie dem Cache eine Liste von EventHub EventData hinzu. (Geerbt von EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)	Hinzufügen des Cachedruckmonitors zum Gegendruckalgorithmus des Caches
AddCachePressureMonitor(ICachePressureMonitor)	Hinzufügen des Cachedruckmonitors zum Gegendruckalgorithmus des Caches (Geerbt von EventHubQueueCache<TCachedMessage>)
Dispose()	Führt anwendungsspezifische Aufgaben durch, die mit der Freigabe, der Zurückgabe oder dem Zurücksetzen von nicht verwalteten Ressourcen zusammenhängen.
Dispose()	Führt anwendungsspezifische Aufgaben durch, die mit der Freigabe, der Zurückgabe oder dem Zurücksetzen von nicht verwalteten Ressourcen zusammenhängen. (Geerbt von EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)	Rufen Sie einen Cursor in den Cache ab, um Ereignisse aus einem Stream zu lesen.
GetCursor(IStreamIdentity, StreamSequenceToken)	Rufen Sie einen Cursor in den Cache ab, um Ereignisse aus einem Stream zu lesen. (Geerbt von EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()	Das Limit der maximalen Anzahl von Elementen, die hinzugefügt werden können
GetMaxAddCount()	Das Limit der maximalen Anzahl von Elementen, die hinzugefügt werden können (Geerbt von EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)	Abrufen des Offsets aus zwischengespeicherten Nachrichten. Bleibt der abgeleiteten Klasse überlassen, da nur sie weiß, wie dies aus der zwischengespeicherten Nachricht abgerufen werden kann.
GetOffset(TCachedMessage)	Abrufen des Offsets aus zwischengespeicherten Nachrichten. Bleibt der abgeleiteten Klasse überlassen, da nur sie weiß, wie dies aus der zwischengespeicherten Nachricht abgerufen werden kann. (Geerbt von EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)	Verarbeitet Cachelöschsignale
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Verarbeitet Cachelöschsignale (Geerbt von EventHubQueueCache<TCachedMessage>)
SignalPurge()	Senden eines Löschsignals an den Cache. Der Cache führt eine zeitbasierte Bereinigung seiner zwischengespeicherten Nachrichten durch.
SignalPurge()	Senden eines Löschsignals an den Cache. Der Cache führt eine zeitbasierte Bereinigung seiner zwischengespeicherten Nachrichten durch. (Geerbt von EventHubQueueCache<TCachedMessage>)
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution sollte ein Double zwischen 0 und 1 sein, der angibt, wie groß die Gefahr ist, dass das Element aus dem Cache entfernt wird. 0, das keine Gefahr anzeigt, 1, dass die Entfernung unmittelbar bevorsteht.
TryGetNextMessage(Object, IBatchContainer)	Versuchen Sie, die nächste Nachricht im Cache für den bereitgestellten Cursor abzurufen.
TryGetNextMessage(Object, IBatchContainer)	Versuchen Sie, die nächste Nachricht im Cache für den bereitgestellten Cursor abzurufen. (Geerbt von EventHubQueueCache<TCachedMessage>)

Gilt für:

Freigeben über