EventHubQueueCache<TCachedMessage> 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

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.

EventHub-Warteschlangencache, mit dem Entwickler ihre eigene zwischengespeicherte Datenstruktur bereitstellen können.

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Typparameter

TCachedMessage

Vererbung: Object
EventHubQueueCache<TCachedMessage>

Abgeleitet: Orleans.ServiceBus.Providers.EventHubQueueCache

Implementiert: IEventHubQueueCache IQueueFlowController IDisposable

Konstruktoren

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den EventHub-Warteschlangencache.
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Erstellen Sie den EventHub-Warteschlangencache.

Felder

cache	Zugrunde liegende Nachrichtencacheimplementierung
defaultMaxAddCount	Maximale Standardanzahl von Elementen, die zwischen Löschaufrufen zum Cache hinzugefügt werden können

Eigenschaften

Checkpointer

Logik zum Speichern der Warteschlangenposition

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.
AddCachePressureMonitor(ICachePressureMonitor)	Hinzufügen des Cachedruckmonitors zum Gegendruckalgorithmus des Caches
Dispose()	Führt anwendungsspezifische Aufgaben durch, die mit der Freigabe, der Zurückgabe oder dem Zurücksetzen von nicht verwalteten Ressourcen zusammenhängen.
GetCursor(IStreamIdentity, StreamSequenceToken)	Rufen Sie einen Cursor in den Cache ab, um Ereignisse aus einem Stream zu lesen.
GetMaxAddCount()	Das Limit der maximalen Anzahl von Elementen, die hinzugefügt werden können
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.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Verarbeitet Cachelöschsignale
SignalPurge()	Senden eines Löschsignals an den Cache. Der Cache führt eine zeitbasierte Bereinigung seiner zwischengespeicherten Nachrichten durch.
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.

Gilt für:

Freigeben über