EventHubQueueCache Classe

Référence

Définition

Espace de noms:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paquet:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquet:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquet:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubQueueCache.cs

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

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: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

Héritage: Object
EventHubQueueCache

Implémente: IEventHubQueueCache IQueueFlowController IDisposable

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 à

Partager via