Partager via


EventHubQueueCache<TCachedMessage> Classe

Définition

Cache de file d’attente EventHub qui permet aux développeurs de fournir leur propre structure de données mises en cache.

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

Paramètres de type

TCachedMessage
Héritage
EventHubQueueCache<TCachedMessage>
Dérivé
Implémente

Constructeurs

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

Champs

cache

Implémentation du cache de messages sous-jacent

defaultMaxAddCount

Nombre maximal par défaut d’éléments pouvant être ajoutés au cache entre les appels de vidage

Propriétés

Checkpointer

Logique utilisée pour stocker la position de la file d’attente

Méthodes

Add(List<EventData>, DateTime)

Ajoutez une liste d’EventHub EventData au cache.

Add(List<EventData>, DateTime)

Ajoutez une liste d’EventHub EventData au cache.

AddCachePressureMonitor(ICachePressureMonitor)

Ajouter un moniteur de pression du cache à l’algorithme de pression arrière du cache

Dispose()

Exécute les tâches définies par l'application associées à la libération ou à la redéfinition des ressources non managées.

GetCursor(IStreamIdentity, StreamSequenceToken)

Placez un curseur dans le cache pour lire les événements d’un flux.

GetMaxAddCount()

Limite du nombre maximal d’éléments pouvant être ajoutés

GetOffset(TCachedMessage)

Obtenez le décalage du message mis en cache. Laissé à la classe dérivée, car seul elle sait comment obtenir cela à partir du message mis en cache.

OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)

Gère les signaux de vidage du cache

SignalPurge()

Envoyer un signal de vidage au cache, le cache effectuera un vidage basé sur l’heure sur ses messages mis en cache

TryCalculateCachePressureContribution(StreamSequenceToken, Double)

cachePressureContribution doit être un double compris entre 0 et 1, indiquant le risque que l’élément soit supprimé du cache. 0 indiquant l’absence de danger, 1 indiquant que l’enlèvement est imminent.

TryGetNextMessage(Object, IBatchContainer)

Essayez d’obtenir le message suivant dans le cache pour le curseur fourni.

S’applique à