EventHubQueueCache Classe

Référence

Définition

Espace de noms:: Orleans.Streaming.EventHubs

Assembly:: Orleans.Streaming.EventHubs.dll

Paquet:: Microsoft.Orleans.Streaming.EventHubs v7.2.5

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.0.0

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.1.0

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

public class EventHubQueueCache : IDisposable, Orleans.Streaming.EventHubs.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Héritage: Object
EventHubQueueCache

Implémente: IEventHubQueueCache IQueueFlowController IDisposable

Constructeurs

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

Propriétés

Partition

Cache de file d’attente EventHub

Méthodes

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(StreamId, 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
SignalPurge()	Envoyer un signal de vidage au cache, le cache effectuera un vidage basé sur l’heure sur ses messages mis en cache
TryGetNextMessage(Object, IBatchContainer)	Essayez d’obtenir le message suivant dans le cache pour le curseur fourni.

S’applique à

Partager via