Compartilhar via


Orleans.Providers.Streams.Common Namespace

Classes

BlockPoolMonitorDimensions

Dimensões de agregação para monitores de pool de blocos.

CacheDataComparerExtensions

Armazenar em cache funções de extensão do comparador de dados que alternam a ordem do argumento

CachedMessageBlock

CachedMessageBlock é um bloco de estruturas bem empacotadas que contêm dados de rastreamento para mensagens armazenadas em cache. Esses dados são fortemente empacotados para reduzir a pressão do GC. Os dados de rastreamento são usados pelo cache de fila para percorrer o cache que atende mensagens ordenadas da fila por fluxo.

CachedMessageBlock<TCachedMessage>

CachedMessageBlock é um bloco de estruturas bem empacotadas que contêm dados de rastreamento para mensagens armazenadas em cache. Esses dados são fortemente empacotados para reduzir a pressão do GC. Os dados de rastreamento são usados pelo cache de fila para percorrer o cache que atende mensagens ordenadas da fila por fluxo.

CachedMessageExtensions

Extensões para CachedMessage.

CacheMonitorDimensions

Dimensões de agregação para o monitor de cache.

ChronologicalEvictionStrategy

Estratégia de remoção que remove dados com base na idade.

ChronologicalEvictionStrategy<TCachedMessage>

Estratégia de remoção que remove dados com base na idade.

DefaultBlockPoolMonitor

Monitor do pool de blocos usado como uma opção padrão em GeneratorStreamProvider e MemoryStreamProvider.

DefaultCacheMonitor

monitor de cache usado como uma opção padrão em GeneratorStreamprovider e MemoryStreamProvider

DefaultQueueAdapterReceiverMonitor

Monitor do receptor do adaptador de fila usado como uma opção padrão em GeneratorStreamprovider e MemoryStreamProvider

EventSequenceToken

Token de sequência de fluxo que rastreia o número de sequência e o índice de eventos

EventSequenceTokenV2

Token de sequência de fluxo que rastreia o número de sequência e o índice de eventos

EvictionStrategyCommonUtils
FixedSizeBuffer

Gerencia um bloco contíguo de memória. Chama a ação de limpeza consigo mesma como a solicitação de limpeza quando é sinalizada para limpar.

MonitorAggregationDimensions

Classe base para manter dimensões de agregação de monitor

ObjectPool<T>

Pool de objetos simples que usa uma pilha para armazenar objetos disponíveis.

ObjectPoolMonitorBridge

ObjectPoolMonitor report metrics for ObjectPool, que são baseadas na contagem de objetos. Métricas de relatório BlockPoolMonitor para BlockPool, que são baseadas no tamanho da memória. Esses dois monitores convergem na infraestrutura de cache do Orleans, em que ObjectPool é usado como pool de blocos para alocar memória, em que cada objeto representa um bloco de memória que tem um tamanho. ObjectPoolMonitorBridge é a ponte entre esses dois monitores na infraestrutura de cache. Quando ObjectPoolMonitor estiver relatando uma métrica, o usuário configurado BlockPoolMonitor chamará seu método equivalente e relatará a métrica com base na matemática: memoryInByte = objectCount*objectSizeInByte

PersistentStreamProvider

Provedor de fluxo persistente que usa um adaptador para persistência

PersistentStreamProvider<TAdapterFactory>

Provedor de fluxo persistente que usa um adaptador para persistência

PooledQueueCache

O PooledQueueCache é um cache destinado a servir como um cache de mensagens em um IQueueCache. Ele é capaz de armazenar um grande número de mensagens (gigs no valor de mensagens) por longos períodos de tempo (minutos para indefinidos), enquanto incorre em um impacto mínimo de desempenho devido à coleta de lixo. Esse cache em pool aloca memória e nunca a libera. Ele mantém os recursos liberados disponíveis em pools que permanecem em uso do aplicativo durante a vida útil do serviço. Isso significa que esses objetos vão para gen2, são compactados e permanecem lá. Isso é relativamente barato, pois o único custo que eles agora incorrem é o custo de verificar se eles devem ser liberados em cada ciclo de coleta. Como esse cache usa um pequeno número de objetos grandes com grafos de objeto relativamente simples, eles são menos caros para verificar e, em seguida, um grande número de objetos menores com grafos de objeto mais complexos. Por motivos de desempenho, esse cache foi projetado para se alinhar mais com dados específicos da fila. Isso é, em parte, por que, ao contrário do SimpleQueueCache, esse cache não implementa IQueueCache. Destina-se a ser usado em implementações específicas da fila do IQueueCache.

PooledQueueCache<TQueueMessage,TCachedMessage>

O PooledQueueCache é um cache destinado a servir como um cache de mensagens em um IQueueCache. Ele é capaz de armazenar um grande número de mensagens (gigs no valor de mensagens) por longos períodos de tempo (minutos para indefinidos), enquanto incorre em um impacto mínimo de desempenho devido à coleta de lixo. Esse cache em pool aloca memória e nunca a libera. Ele mantém os recursos liberados disponíveis em pools que permanecem em uso do aplicativo durante a vida útil do serviço. Isso significa que esses objetos vão para gen2, são compactados e permanecem lá. Isso é relativamente barato, pois o único custo que eles agora incorrem é o custo de verificar se eles devem ser liberados em cada ciclo de coleta. Como esse cache usa um pequeno número de objetos grandes com grafos de objeto relativamente simples, eles são menos caros para verificar e, em seguida, um grande número de objetos menores com grafos de objeto mais complexos. Por motivos de desempenho, esse cache foi projetado para se alinhar mais com dados específicos da fila. Isso é, em parte, por que, ao contrário do SimpleQueueCache, esse cache não implementa IQueueCache. Destina-se a ser usado em implementações específicas da fila do IQueueCache.

PooledResource<T>

Classe de utilitário para dar suporte a objetos em pool, permitindo que eles acompanhem o pool de onde vieram e retornem a ele quando descartados

ReceiverMonitorDimensions

Dimensões de agregação para o monitor do receptor.

RecoverableStreamProviderSettings

Configurações comuns do provedor de fluxo compartilhadas por EventHubStreamProvider, MemoryStreamProvider e GeneratorStreamProvider

SegmentBuilder

Classe de utilitário para codificar dados em um ArraySegment.

SimpleQueueAdapterCache

Adaptador para caches de fila simples.

SimpleQueueCache

Um cache de fila que mantém itens na memória.

SimpleQueueCacheCursor

Cursor em um cache de fila simples.

StreamPosition

A posição do fluxo identifica exclusivamente a posição de um evento em um fluxo. Se adquirir uma posição de fluxo para um lote de eventos, a posição do fluxo será do primeiro evento no lote.

TimePurgePredicate

Determina se os dados devem ser limpos com base no tempo de folga.

Estruturas

CachedMessage

Essa é uma estrutura em cache bem empacotada que contém uma mensagem de fila. Ele deve conter apenas tipos de valor.

Interfaces

IBlockPoolMonitor

Monitorar métricas relacionadas ao pool de blocos de rastreamento. O pool de blocos é usado no sistema de cache para gerenciamento de memória

ICacheDataAdapter

O cache de filas em pool armazena dados em estruturas bem empacotadas que precisam ser transformadas em vários outros formatos rapidamente. Como os formatos de dados podem ser alterados por tipo de fila e formato de dados, essa interface permite que os desenvolvedores do adaptador criem transformações de dados personalizadas apropriadas para os vários tipos de dados de fila.

ICacheDataAdapter<TQueueMessage,TCachedMessage>

O cache de filas em pool armazena dados em estruturas bem empacotadas que precisam ser transformadas em vários outros formatos rapidamente. Como os formatos de dados podem ser alterados por tipo de fila e formato de dados, essa interface permite que os desenvolvedores do adaptador criem transformações de dados personalizadas apropriadas para os vários tipos de dados de fila.

ICacheDataComparer<TCachedMessage>

Compara mensagens armazenadas em cache com vários detalhes do fluxo

ICacheMonitor

Responsável por monitorar as métricas relacionadas ao cache.

IEvictionStrategy

Estratégia de remoção para o PooledQueueCache

IEvictionStrategy<TCachedMessage>

Estratégia de remoção para o PooledQueueCache

IObjectPool<T>

Interface do pool de objetos simples. Os objetos alocados devem ser retornados ao pool quando descartados.

IObjectPoolMonitor

Monitorar métricas relacionadas ao pool de objetos de rastreamento

IPurgeObservable

Funcionalidade para ações relacionadas à limpeza.

IPurgeObservable<TCachedMessage>

IPurgeObservable é implementado pelo cache para realizar ações relacionadas à limpeza e invocado por EvictionStrategy

IQueueAdapterReceiverMonitor

Responsável por monitorar as métricas de desempenho do receptor.

Enumerações

PersistentStreamProviderCommand

Comandos que podem ser manipulados pelo PersistentStreamProvider.

PersistentStreamProviderState