Orleans.Providers.Streams.Common Espace de noms
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.
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 |