Partager via


Orleans.Providers.Streams.Common Espace de noms

Classes

BlockPoolMonitorDimensions

Dimensions d’agrégation pour les moniteurs de pool de blocs.

CacheDataComparerExtensions

Fonctions d’extension du comparateur de données de cache qui changent l’ordre des arguments

CachedMessageBlock

CachedMessageBlock est un bloc de structures étroitement compressées contenant des données de suivi pour les messages mis en cache. Ces données sont étroitement emballées pour réduire la pression gc. Les données de suivi sont utilisées par le cache de file d’attente pour parcourir le cache servant les messages de file d’attente ordonnés par flux.

CachedMessageBlock<TCachedMessage>

CachedMessageBlock est un bloc de structures étroitement compressées contenant des données de suivi pour les messages mis en cache. Ces données sont étroitement emballées pour réduire la pression gc. Les données de suivi sont utilisées par le cache de file d’attente pour parcourir le cache servant les messages de file d’attente ordonnés par flux.

CachedMessageExtensions

Extensions pour CachedMessage.

CacheMonitorDimensions

Dimensions d’agrégation pour le moniteur de cache.

ChronologicalEvictionStrategy

Stratégie d’éviction qui supprime les données en fonction de l’âge.

ChronologicalEvictionStrategy<TCachedMessage>

Stratégie d’éviction qui supprime les données en fonction de l’âge.

DefaultBlockPoolMonitor

Moniteur de pool de blocs utilisé comme option par défaut dans GeneratorStreamProvider et MemoryStreamProvider.

DefaultCacheMonitor

moniteur de cache utilisé comme option par défaut dans GeneratorStreamprovider et MemoryStreamProvider

DefaultQueueAdapterReceiverMonitor

Moniteur de récepteur d’adaptateur de file d’attente utilisé comme option par défaut dans GeneratorStreamprovider et MemoryStreamProvider

EventSequenceToken

Jeton de séquence de flux qui effectue le suivi du numéro de séquence et de l’index d’événement

EventSequenceTokenV2

Jeton de séquence de flux qui effectue le suivi du numéro de séquence et de l’index d’événement

EvictionStrategyCommonUtils
FixedSizeBuffer

Gère un bloc contigu de mémoire. Appelle l’action de vidage avec elle-même comme demande de vidage lorsqu’elle est signalée pour le vidage.

MonitorAggregationDimensions

Classe de base pour la conservation des dimensions d’agrégation du moniteur

ObjectPool<T>

Pool d’objets simple qui utilise une pile pour stocker les objets disponibles.

ObjectPoolMonitorBridge

Les métriques de rapport ObjectPoolMonitor pour ObjectPool, qui sont basées sur le nombre d’objets. Métriques de rapport BlockPoolMonitor pour BlockPool, qui sont basées sur la taille de la mémoire. Ces deux moniteurs convergent dans l’infrastructure de cache orleans, où ObjectPool est utilisé comme pool de blocs pour allouer de la mémoire, où chaque objet représente un bloc de mémoire de taille. ObjectPoolMonitorBridge est le pont entre ces deux moniteurs dans l’infrastructure de cache. Lorsque ObjectPoolMonitor signale une métrique, l’utilisateur configuré BlockPoolMonitor appelle sa méthode et sa métrique de création de rapports équivalentes en fonction des mathématiques : memoryInByte = objectCount*objectSizeInByte

PersistentStreamProvider

Fournisseur de flux persistant qui utilise un adaptateur pour la persistance

PersistentStreamProvider<TAdapterFactory>

Fournisseur de flux persistant qui utilise un adaptateur pour la persistance

PooledQueueCache

PooledQueueCache est un cache destiné à servir de cache de messages dans un IQueueCache. Il est capable de stocker un grand nombre de messages (en quantités de messages) pendant des périodes prolongées (minutes à indéfinies), tout en entraînant un impact minimal sur les performances en raison du nettoyage de la mémoire. Ce cache mis en pool alloue de la mémoire et ne la libère jamais. Il conserve les ressources libérées disponibles dans les pools qui restent utilisés par l’application tout au long de la durée de vie du service. Cela signifie que ces objets vont à gen2, sont compactés, puis y restent. Cela est relativement bon marché, car le seul coût qu’ils encourent maintenant est le coût de vérification pour voir s’ils doivent être libérés à chaque cycle de collecte. Étant donné que ce cache utilise un petit nombre d’objets volumineux avec des graphiques d’objets relativement simples, il est moins coûteux de vérifier qu’un grand nombre d’objets plus petits avec des graphiques d’objets plus complexes. Pour des raisons de performances, ce cache est conçu pour s’aligner plus étroitement avec les données spécifiques à la file d’attente. C’est en partie pourquoi, contrairement à SimpleQueueCache, ce cache n’implémente pas IQueueCache. Il est destiné à être utilisé dans les implémentations spécifiques à la file d’attente d’IQueueCache.

PooledQueueCache<TQueueMessage,TCachedMessage>

PooledQueueCache est un cache destiné à servir de cache de messages dans un IQueueCache. Il est capable de stocker un grand nombre de messages (en quantités de messages) pendant des périodes prolongées (minutes à indéfinies), tout en entraînant un impact minimal sur les performances en raison du nettoyage de la mémoire. Ce cache mis en pool alloue de la mémoire et ne la libère jamais. Il conserve les ressources libérées disponibles dans les pools qui restent utilisés par l’application tout au long de la durée de vie du service. Cela signifie que ces objets vont à gen2, sont compactés, puis y restent. Cela est relativement bon marché, car le seul coût qu’ils encourent maintenant est le coût de vérification pour voir s’ils doivent être libérés à chaque cycle de collecte. Étant donné que ce cache utilise un petit nombre d’objets volumineux avec des graphiques d’objets relativement simples, il est moins coûteux de vérifier qu’un grand nombre d’objets plus petits avec des graphiques d’objets plus complexes. Pour des raisons de performances, ce cache est conçu pour s’aligner plus étroitement avec les données spécifiques à la file d’attente. C’est en partie pourquoi, contrairement à SimpleQueueCache, ce cache n’implémente pas IQueueCache. Il est destiné à être utilisé dans les implémentations spécifiques à la file d’attente d’IQueueCache.

PooledResource<T>

Classe utilitaire pour prendre en charge les objets mis en pool en leur permettant de suivre le pool d’où ils proviennent et d’y revenir lorsqu’ils sont supprimés

ReceiverMonitorDimensions

Dimensions d’agrégation pour le moniteur de récepteur.

RecoverableStreamProviderSettings

Paramètres courants du fournisseur de flux partagés par EventHubStreamProvider, MemoryStreamProvider et GeneratorStreamProvider

SegmentBuilder

Classe utilitaire pour l’encodage de données dans un ArraySegment.

SimpleQueueAdapterCache

Adaptateur pour les caches de file d’attente simples.

SimpleQueueCache

Cache de file d’attente qui conserve les éléments en mémoire.

SimpleQueueCacheCursor

Curseur dans un cache de file d’attente simple.

StreamPosition

La position du flux identifie de manière unique la position d’un événement dans un flux. Si vous obtenez une position de flux pour un lot d’événements, la position du flux sera du premier événement du lot.

TimePurgePredicate

Détermine si les données doivent être purgées en fonction du temps d’arrêt.

Structures

CachedMessage

Il s’agit d’une structure mise en cache étroitement remplie contenant un message de file d’attente. Il doit contenir uniquement des types valeur.

Interfaces

IBlockPoolMonitor

Surveillez les métriques liées au pool de blocs de suivi. Le pool de blocs est utilisé dans le système de cache pour la gestion de la mémoire

ICacheDataAdapter

Le cache de file d’attente groupé stocke les données dans des structures étroitement compressées qui doivent être rapidement transformées en différents autres formats. Étant donné que les formats de données peuvent changer en fonction du type de file d’attente et du format de données, cette interface permet aux développeurs d’adaptateurs de créer des transformations de données personnalisées adaptées aux différents types de données de file d’attente.

ICacheDataAdapter<TQueueMessage,TCachedMessage>

Le cache de file d’attente groupé stocke les données dans des structures étroitement compressées qui doivent être rapidement transformées en différents autres formats. Étant donné que les formats de données peuvent changer en fonction du type de file d’attente et du format de données, cette interface permet aux développeurs d’adaptateurs de créer des transformations de données personnalisées adaptées aux différents types de données de file d’attente.

ICacheDataComparer<TCachedMessage>

Compare les messages mis en cache avec divers détails de flux

ICacheMonitor

Responsable de la surveillance des métriques liées au cache.

IEvictionStrategy

Stratégie d’éviction pour PooledQueueCache

IEvictionStrategy<TCachedMessage>

Stratégie d’éviction pour PooledQueueCache

IObjectPool<T>

Interface de pool d’objets simple. Les objets alloués doivent être retournés au pool lorsqu’ils sont supprimés.

IObjectPoolMonitor

Surveiller les métriques liées au pool d’objets de suivi

IPurgeObservable

Fonctionnalité pour les actions liées au vidage.

IPurgeObservable<TCachedMessage>

IPurgeObservable est implémenté par le cache pour effectuer des actions liées au vidage, et appelé par EvictionStrategy

IQueueAdapterReceiverMonitor

Responsable de la surveillance des métriques de performances du récepteur.

Énumérations

PersistentStreamProviderCommand

Commandes qui peuvent être gérées par .PersistentStreamProvider

PersistentStreamProviderState