Orleans.Streams Namespace

Classes

AggregatedQueueFlowController	Um IQueueFlowController que agrega vários outros IQueueFlowController valores.
AsyncBatchObservableExtensions	Métodos de extensão para IAsyncBatchObservable<T>.
AsyncObservableExtensions	Métodos de extensão para IAsyncObservable<T>.
BatchContainerBatch	Um lote de contêineres em lotes, que se configurados (consulte StreamPullingAgentOptions), serão os dados extraídos pelo PersistenStreamPullingAgent do cache subjacente
CacheFullException	Indica que o cache de mensagens da fila está cheio.
ConstructorStreamNamespacePredicateProvider	Stream provedor de predicado de namespace que dá suporte a objetos que podem ser construídos e, opcionalmente, aceitam uma cadeia de caracteres como um argumento de construtor.
DataNotAvailableException	Exceção indica que os dados solicitados não estão disponíveis.
DefaultStreamIdMapper	A implementação padrão IStreamIdMapper .
DefaultStreamNamespacePredicateProvider	Implementação padrão de IStreamNamespacePredicateProvider para predicados de fluxo com suporte interno.
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer é um balanceador de fila de fluxo que usa informações de implantação para ajudar a equilibrar a distribuição de filas. DeploymentBasedQueueBalancer usa a configuração de implantação para determinar quantos silos esperar e usa um silo status oracle para determinar quais dos silos estão disponíveis. Com essas informações, ele tenta equilibrar as filas usando um algoritmo de balanceamento de recursos mais adequado.
FaultedSubscriptionException	Essa exceção indica que ocorreu um erro em uma assinatura de fluxo que colocou a assinatura em um estado com falha. O trabalho em assinaturas com falha deve ser abandonado.
HashRingBasedPartitionedStreamQueueMapper	Mapeador de fila que rastreia qual partição foi mapeada para a qual QueueId
HashRingBasedStreamQueueMapper	Um IConsistentRingStreamQueueMapper e, portanto, IStreamQueueMapper que equilibra as filas mapeando-as para um anel de hash que consiste em silos.
ImplicitConsumerGrainExtensions	Métodos de extensão para granularidades implicitamente inscritos em fluxos.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Esse balanceador dá suporte ao balanceamento de fila em cenários de dimensionamento automático de cluster, cenários inesperados de falha do servidor e tenta dar suporte à distribuição ideal o máximo possível.
LoadShedQueueFlowController	Controle de fluxo disparado pelo derramamento de carga de silo. Esse é um gatilho tudo ou nada que solicitará MaxValue, ou 0.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler que não faz nada em resposta a falhas.
ProviderStartException	Exceção gerada sempre que um provedor não for iniciado.
PubSubSubscriptionState
QueueAdapterConstants	Constantes para adaptadores de fila.
QueueAdapterExtensions	Métodos de extensão para IQueueAdapter
QueueBalancerBase	Classe base para StreamQueueBalancer
QueueCacheMissException	A exceção indica que a mensagem solicitada não está no cache da fila.
QueueId	Identificador de uma fila durável. Usado por extensões de streaming do Orleans.
RegexStreamNamespacePredicate	IStreamNamespacePredicate implementação que permite filtrar namespaces de fluxo por expressão regular.
SequentialItem<T>	Representa um item de fluxo dentro de uma sequência.
StreamEventDeliveryFailureException	Essa exceção indica que um evento de fluxo não foi entregue com êxito ao consumidor.
StreamIdentity	Stream identidade contém as informações de fluxo público usadas para identificar exclusivamente um fluxo. Stream identidades são exclusivas apenas por provedor de fluxo.
StreamPosition	Stream posição 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.
StreamProviderExtensions	Extensões para IStreamProvider.
StreamSequenceToken	Identificador que representa o número/token da sequência de fluxo. O consumidor pode assinar o fluxo ao especificar o início do token de sequência de assinatura. Isso significa que a infraestrutura de fluxo fornecerá eventos de fluxo a partir desse token de sequência.
StreamSequenceTokenUtilities	Utilitários para comparar StreamSequenceToken instâncias.
StreamSubscriptionHandle<T>	Manipule a representação dessa assinatura. O consumidor pode serializar e armazenar o identificador para cancelar a assinatura posteriormente, por exemplo, em outra ativação nesse grão.
StreamSubscriptionHandleExtensions	Métodos de extensão para StreamSubscriptionHandle<T>.
StreamSubscriptionHandlerFactory	Fábrica para criar StreamSubscriptionHandle<T> instâncias.

Interfaces

IAsyncBatchObservable<T>	Essa interface generaliza a interface IAsyncObserver para permitir a produção e o consumo de lotes de itens. Observe que essa interface é implementada por consumidores de itens e invocada (usada) pelos produtores de itens. Isso significa que o ponto de extremidade do consumidor de um fluxo implementa essa interface.
IAsyncBatchObserver<T>	Essa interface generaliza a interface IAsyncObserver para permitir a produção e o consumo de lotes de itens. Observe que essa interface é implementada por consumidores de itens e invocada (usada) pelos produtores de itens. Isso significa que o ponto de extremidade do consumidor de um fluxo implementa essa interface.
IAsyncBatchProducer<T>	Essa interface generaliza a interface IAsyncObserver para permitir a produção de lotes de itens. Observe que essa interface é invocada (usada) pelos produtores de itens.
IAsyncObservable<T>	Essa interface generaliza a interface IObserveable padrão do .NET para permitir o consumo assíncrono de itens. Assíncrono aqui significa que o consumidor pode processar itens de forma assíncrona e sinalizar a conclusão do item para o produtor concluindo a Tarefa retornada. Observe que essa interface é invocada (usada) pelos consumidores de itens e implementada pelos produtores de itens. Isso significa que o ponto de extremidade do produtor de um fluxo implementa essa interface.
IAsyncObserver<T>	Essa interface generaliza a interface IObserver padrão do .NET para permitir a produção assíncrona de itens. Observe que essa interface é implementada por consumidores de itens e invocada (usada) pelos produtores de itens. Isso significa que o ponto de extremidade do consumidor de um fluxo implementa essa interface.
IAsyncStream	Essa interface representa um objeto que serve como um encontro distribuído entre produtores e consumidores. Ele é semelhante a uma Estrutura Subject Reativa e implementa IObserver nem IObservable interfaces.
IAsyncStream<T>	Essa interface representa um objeto que serve como um encontro distribuído entre produtores e consumidores. Ele é semelhante a uma Estrutura Subject Reativa e implementa IObserver nem IObservable interfaces.
IBatchContainer	Cada mensagem de fila tem permissão para ser um conjunto heterogêneo e ordenado de eventos. IBatchContainer contém esses eventos e permite que os usuários consultem o lote para um tipo específico de evento.
IBatchContainerBatch	Um lote de mensagens de fila (consulte IBatchContainer para obter a descrição do conteúdo do lote)
IConsistentRingStreamQueueMapper	O mapeador de fila de fluxo é responsável por mapear intervalos de anéis do provedor de anel de balanceamento de carga para filas de fluxo. A implementação deve ser thread-safe.
IDeploymentConfiguration	Interface para acessar a configuração de implantação.
IQueueAdapter	Stream adaptador de armazenamento de fila. Essa é uma camada de abstração que oculta os detalhes de implementação do sistema de enfileiramento subjacente.
IQueueAdapterCache	Funcionalidade para criar um IQueueCache para uma determinada fila.
IQueueAdapterFactory	Fábrica de adaptadores. Isso deve criar um adaptador a partir da configuração do provedor de fluxo
IQueueAdapterReceiver	Recebe lotes de mensagens de uma única partição de uma fila de mensagens.
IQueueCache
IQueueCacheCursor	Enumera as mensagens em um fluxo.
IQueueDataAdapter<TQueueMessage>	Converte dados de evento em mensagem de fila
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Converte dados de evento de e para a mensagem de fila
IQueueFlowController	Funcionalidade para controlar o fluxo de itens de fila recuperados.
IStreamFailureHandler	Funcionalidade para lidar com falhas de fluxo.
IStreamIdentity	Identifica exclusivamente um fluxo.
IStreamIdMapper	Interface comum para componentes que mapeiam um StreamId para um Key
IStreamNamespacePredicate	Stream predicado de namespace usado para filtrar assinaturas implícitas usando ImplicitStreamSubscriptionAttribute.
IStreamNamespacePredicateProvider	Converte cadeias de caracteres de padrão de predicado em IStreamNamespacePredicate instâncias.
IStreamProvider	Funcionalidade para fornecer fluxos para consumidores e produtores.
IStreamPubSub
IStreamQueueBalanceListener	O ouvinte do balanceador de filas de fluxo recebe notificações de um balanceador de fila de fluxo (IStreamQueueBalancer) indicando que o saldo de filas foi alterado. Ele deve ser implementado por componentes interessados no balanceamento de carga da fila de fluxo. Quando a notificação de alteração é recebida, o ouvinte deve solicitar a lista atualizada de filas do balanceador de filas.
IStreamQueueBalancer	O balanceador de filas de fluxo é responsável por balancear carga de filas em todos os outros balanceadores de fila relacionados. Ele notifica todos os ouvintes (IStreamQueueBalanceListener) de alterações na distribuição de filas. O método GetMyQueues, SubscribeToQueueDistributionChangeEvents e UnSubscribeFromQueueDistributionChangeEvents provavelmente serão chamados no thread do IStreamQueueBalanceListener, portanto, eles precisam ser thread safe
IStreamQueueCheckpointer<TCheckpoint>	Funcionalidade para o ponto de verificação de um fluxo.
IStreamQueueCheckpointerFactory	Fábrica para criar IStreamQueueCheckpointer<TCheckpoint> instâncias.
IStreamQueueMapper	O mapeador da fila de fluxo retorna uma lista de todas as filas e também é responsável por mapear fluxos para filas. A implementação deve ser thread-safe.

Enumerações

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	Identifica se um provedor de fluxo é somente leitura, leitura-gravação ou somente gravação.
StreamPubSubType	Identifica os tipos de sistema de publicação/assinatura que os provedores de fluxo podem usar.