Lire en anglais

Partager via


EventHubQueueCache Classe

Définition

Cache de messages qui stocke EventData en tant que CachedEventHubMessage dans un cache de messages mis en pool

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
Héritage
Héritage
EventHubQueueCache
Implémente

Constructeurs

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

Construire le cache en fonction d’un adaptateur de données personnalisé.

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

Construire le cache en fonction d’un adaptateur de données personnalisé.

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

Construire le cache en fonction d’un adaptateur de données personnalisé.

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

Construire le cache en fonction d’un adaptateur de données personnalisé.

EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

Construire le cache en fonction d’un pool de mémoires tampons. Utilisera l’adaptateur de données par défaut

EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

Construire le cache en fonction d’un pool de mémoires tampons. Utilisera l’adaptateur de données par défaut

EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

Cache de file d’attente EventHub.

Champs

cache

Implémentation du cache de messages sous-jacent Protégé à des fins de test

cache

Implémentation du cache de messages sous-jacent

(Hérité de EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount

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

(Hérité de EventHubQueueCache<TCachedMessage>)

Propriétés

Checkpointer

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

(Hérité de EventHubQueueCache<TCachedMessage>)
Partition

Cache de messages qui stocke EventData en tant que CachedEventHubMessage dans un cache de messages mis en pool

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.

(Hérité de EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)

Ajoutez une liste d’EventHub EventData au cache.

(Hérité de EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)

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

AddCachePressureMonitor(ICachePressureMonitor)

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

(Hérité de EventHubQueueCache<TCachedMessage>)
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.

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.

(Hérité de EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)

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

GetCursor(IStreamIdentity, StreamSequenceToken)

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

(Hérité de EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()

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

GetMaxAddCount()

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

(Hérité de EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)

Obtenez un décalage à partir du message mis en cache. Laissé à la classe dérivée, car seul il sait comment l’obtenir à partir du message mis en cache.

GetOffset(TCachedMessage)

Obtenez un décalage à partir du message mis en cache. Laissé à la classe dérivée, car seul il sait comment l’obtenir à partir du message mis en cache.

(Hérité de EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)

Gère les signaux de purge du cache

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

Gère les signaux de purge du cache

(Hérité de EventHubQueueCache<TCachedMessage>)
SignalPurge()

Envoyer un signal de purge au cache. Le cache effectue une purge basée sur le temps sur ses messages mis en cache

SignalPurge()

Envoyer un signal de purge au cache. Le cache effectue une purge basée sur le temps sur ses messages mis en cache

(Hérité de EventHubQueueCache<TCachedMessage>)
TryCalculateCachePressureContribution(StreamSequenceToken, Double)

cachePressureContribution doit être un double entre 0 et 1, indiquant le danger de suppression de l’élément 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.

TryGetNextMessage(Object, IBatchContainer)

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

(Hérité de EventHubQueueCache<TCachedMessage>)

S’applique à