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

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

Dérivé: Orleans.ServiceBus.Providers.EventHubQueueCache

Implémente: IEventHubQueueCache IQueueFlowController IDisposable

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 à

Partager via