EventHubQueueCache<TCachedMessage> Classe
Définition
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
-
EventHubQueueCache<TCachedMessage>
- Dérivé
- Implémente
Constructeurs
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. |