Compartir a través de


Orleans.Providers.Streams.Common Espacio de nombres

Clases

BlockPoolMonitorDimensions

Dimensiones de agregación para monitores de grupo de bloques.

CacheDataComparerExtensions

Funciones de extensión del comparador de datos de caché que cambian el orden de los argumentos

CachedMessageBlock

CachedMessageBlock es un bloque de estructuras estrechamente empaquetadas que contienen datos de seguimiento para mensajes almacenados en caché. Estos datos están estrechamente empaquetados para reducir la presión de GC. La memoria caché de cola usa los datos de seguimiento para recorrer la caché que atiende los mensajes ordenados de la cola por secuencia.

CachedMessageBlock<TCachedMessage>

CachedMessageBlock es un bloque de estructuras estrechamente empaquetadas que contienen datos de seguimiento para mensajes almacenados en caché. Estos datos están estrechamente empaquetados para reducir la presión de GC. La memoria caché de cola usa los datos de seguimiento para recorrer la caché que atiende los mensajes ordenados de la cola por secuencia.

CachedMessageExtensions

Extensiones para CachedMessage.

CacheMonitorDimensions

Dimensiones de agregación para el monitor de caché.

ChronologicalEvictionStrategy

Estrategia de expulsión que expulsa los datos en función de la edad.

ChronologicalEvictionStrategy<TCachedMessage>

Estrategia de expulsión que expulsa los datos en función de la edad.

DefaultBlockPoolMonitor

Bloquee el monitor de grupo que se usa como opción predeterminada en GeneratorStreamProvider y MemoryStreamProvider.

DefaultCacheMonitor

Monitor de caché usado como opción predeterminada en GeneratorStreamprovider y MemoryStreamProvider

DefaultQueueAdapterReceiverMonitor

Monitor receptor del adaptador de cola usado como opción predeterminada en GeneratorStreamprovider y MemoryStreamProvider

EventSequenceToken

Token de secuencia de secuencia que realiza un seguimiento del número de secuencia y el índice de eventos

EventSequenceTokenV2

Token de secuencia de secuencia que realiza un seguimiento del número de secuencia y el índice de eventos

EvictionStrategyCommonUtils
FixedSizeBuffer

Administra un bloque contiguo de memoria. Llama a la acción de purga con sí mismo como la solicitud de purga cuando se señala que se purga.

MonitorAggregationDimensions

Clase base para contener dimensiones de agregación de monitor

ObjectPool<T>

Grupo de objetos simple que usa una pila para almacenar objetos disponibles.

ObjectPoolMonitorBridge

Métricas del informe ObjectPoolMonitor para ObjectPool, que se basan en el recuento de objetos. Métricas del informe BlockPoolMonitor para BlockPool, que se basan en el tamaño de memoria. Estos dos monitores convergen en la infraestructura de caché de Orleans, donde ObjectPool se usa como grupo de bloques para asignar memoria, donde cada objeto representa un bloque de memoria que tiene un tamaño. ObjectPoolMonitorBridge es el puente entre estos dos monitores en la infraestructura de caché. Cuando ObjectPoolMonitor notifica una métrica, el usuario configurado BlockPoolMonitor llamará a su método homólogo y a la métrica de informes en función de las matemáticas: memoryInByte = objectCount*objectSizeInByte

PersistentStreamProvider

Proveedor de flujos persistente que usa un adaptador para la persistencia

PersistentStreamProvider<TAdapterFactory>

Proveedor de flujos persistente que usa un adaptador para la persistencia

PooledQueueCache

PooledQueueCache es una memoria caché que está pensada para servir como caché de mensajes en un IQueueCache. Es capaz de almacenar un gran número de mensajes (gigs worth of messages) durante largos períodos de tiempo (minutos a indefinidos), al tiempo que incurre en un impacto mínimo de rendimiento debido a la recolección de elementos no utilizados. Esta caché agrupada asigna memoria y nunca la libera. Mantiene los recursos liberados disponibles en los grupos que permanecen en uso de la aplicación a través de la vida útil del servicio. Esto significa que estos objetos van a gen2, se compactan y luego permanecen allí. Esto es relativamente barato, ya que el único costo que incurren ahora es el costo de comprobar si deben liberarse en cada ciclo de recolección. Dado que esta memoria caché usa pequeños números de objetos grandes con gráficos de objetos relativamente simples, son menos costosos de comprobar después grandes cantidades de objetos más pequeños con gráficos de objetos más complejos. Por motivos de rendimiento, esta memoria caché está diseñada para alinearse más estrechamente con los datos específicos de la cola. Esto es, en parte, por qué, a diferencia de SimpleQueueCache, esta memoria caché no implementa IQueueCache. Está pensado para usarse en implementaciones específicas de la cola de IQueueCache.

PooledQueueCache<TQueueMessage,TCachedMessage>

PooledQueueCache es una memoria caché que está pensada para servir como caché de mensajes en un IQueueCache. Es capaz de almacenar un gran número de mensajes (gigs worth of messages) durante largos períodos de tiempo (minutos a indefinidos), al tiempo que incurre en un impacto mínimo de rendimiento debido a la recolección de elementos no utilizados. Esta caché agrupada asigna memoria y nunca la libera. Mantiene los recursos liberados disponibles en los grupos que permanecen en uso de la aplicación a través de la vida útil del servicio. Esto significa que estos objetos van a gen2, se compactan y luego permanecen allí. Esto es relativamente barato, ya que el único costo que incurren ahora es el costo de comprobar si deben liberarse en cada ciclo de recolección. Dado que esta memoria caché usa pequeños números de objetos grandes con gráficos de objetos relativamente simples, son menos costosos de comprobar después grandes cantidades de objetos más pequeños con gráficos de objetos más complejos. Por motivos de rendimiento, esta memoria caché está diseñada para alinearse más estrechamente con los datos específicos de la cola. Esto es, en parte, por qué, a diferencia de SimpleQueueCache, esta memoria caché no implementa IQueueCache. Está pensado para usarse en implementaciones específicas de la cola de IQueueCache.

PooledResource<T>

Clase de utilidad para admitir objetos agrupados al permitirles realizar un seguimiento del grupo del que proceden y volver a él cuando se eliminan

ReceiverMonitorDimensions

Dimensiones de agregación para el monitor receptor.

RecoverableStreamProviderSettings

Configuración común del proveedor de flujos compartida por EventHubStreamProvider, MemoryStreamProvider y GeneratorStreamProvider

SegmentBuilder

Clase de utilidad para codificar datos en una clase ArraySegment.

SimpleQueueAdapterCache

Adaptador para cachés de cola sencillas.

SimpleQueueCache

Caché de colas que mantiene los elementos en memoria.

SimpleQueueCacheCursor

Cursor en una caché de cola simple.

StreamPosition

La posición de la secuencia identifica de forma única la posición de un evento en una secuencia. Si adquiere una posición de secuencia para un lote de eventos, la posición de la secuencia será del primer evento del lote.

TimePurgePredicate

Determina si los datos se deben purgar en función del tiempo de instrucciones.

Estructuras

CachedMessage

Se trata de una estructura almacenada en caché estrechamente empaquetada que contiene un mensaje de cola. Solo debe contener tipos de valor.

Interfaces

IBlockPoolMonitor

Supervise las métricas relacionadas con el grupo de bloques de seguimiento. El grupo de bloques se usa en el sistema de caché para la administración de memoria

ICacheDataAdapter

La caché de cola agrupada almacena los datos en estructuras estrechamente empaquetadas que deben transformarse rápidamente en otros formatos. Dado que los formatos de datos pueden cambiar por tipo de cola y formato de datos, esta interfaz permite a los desarrolladores de adaptadores crear transformaciones de datos personalizadas adecuadas para los distintos tipos de datos de cola.

ICacheDataAdapter<TQueueMessage,TCachedMessage>

La caché de cola agrupada almacena los datos en estructuras estrechamente empaquetadas que deben transformarse rápidamente en otros formatos. Dado que los formatos de datos pueden cambiar por tipo de cola y formato de datos, esta interfaz permite a los desarrolladores de adaptadores crear transformaciones de datos personalizadas adecuadas para los distintos tipos de datos de cola.

ICacheDataComparer<TCachedMessage>

Compara los mensajes almacenados en caché con varios detalles de flujo.

ICacheMonitor

Responsable de supervisar las métricas relacionadas con la caché.

IEvictionStrategy

Estrategia de expulsión para PooledQueueCache

IEvictionStrategy<TCachedMessage>

Estrategia de expulsión para PooledQueueCache

IObjectPool<T>

Interfaz de grupo de objetos simple. Los objetos asignados deben devolverse al grupo cuando se eliminan.

IObjectPoolMonitor

Supervisión de métricas relacionadas con el grupo de objetos de seguimiento

IPurgeObservable

Funcionalidad para acciones relacionadas con la purga.

IPurgeObservable<TCachedMessage>

IPurgeObservable se implementa mediante la memoria caché para realizar acciones relacionadas con purgas e invocadas por EvictionStrategy.

IQueueAdapterReceiverMonitor

Responsable de supervisar las métricas de rendimiento del receptor.

Enumeraciones

PersistentStreamProviderCommand

Comandos que se pueden controlar mediante .PersistentStreamProvider

PersistentStreamProviderState