Orleans.Streams Espacio de nombres

Clases

AggregatedQueueFlowController	que IQueueFlowController agrega varios otros IQueueFlowController valores.
AsyncBatchObservableExtensions	Métodos de extensión para IAsyncBatchObservable<T>.
AsyncObservableExtensions	Métodos de extensión para IAsyncObservable<T>.
BatchContainerBatch	Un lote de contenedores por lotes, que, si está configurado (consulte StreamPullingAgentOptions), serán los datos extraídos por La persistenciaStreamPullingAgent de su caché subyacente.
CacheFullException	Indica que la caché de mensajes de cola está llena.
ConstructorStreamNamespacePredicateProvider	Stream proveedor de predicado de espacio de nombres que admite objetos que se pueden construir y, opcionalmente, aceptar una cadena como argumento de constructor.
DataNotAvailableException	La excepción indica que los datos solicitados no están disponibles.
DefaultStreamIdMapper	Implementación predeterminada IStreamIdMapper .
DefaultStreamNamespacePredicateProvider	Implementación predeterminada de IStreamNamespacePredicateProvider para predicados de flujo admitidos internamente.
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer es un equilibrador de cola de flujos que usa información de implementación para ayudar a equilibrar la distribución de colas. DeploymentBasedQueueBalancer usa la configuración de implementación para determinar cuántos silos esperar y usa un oráculo de estado de silo para determinar cuáles de los silos están disponibles. Con esta información, intenta equilibrar las colas mediante un algoritmo de equilibrio de recursos de mejor ajuste.
FaultedSubscriptionException	Esta excepción indica que se ha producido un error en una suscripción de flujo que ha colocado la suscripción en un estado erróneo. Se debe abandonar el trabajo en suscripciones erróneas.
HashRingBasedPartitionedStreamQueueMapper	Asignador de colas que realiza un seguimiento de la partición a la que se ha asignado QueueId
HashRingBasedStreamQueueMapper	Un IConsistentRingStreamQueueMapper y, por tanto, IStreamQueueMapper que equilibra las colas asignándolas a un anillo hash que consta de silos.
ImplicitConsumerGrainExtensions	Métodos de extensión para granos suscritos implícitamente a secuencias.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Este equilibrador admite el equilibrio de colas en escenarios de escalado automático de clústeres, escenarios inesperados de error de servidor e intenta admitir la distribución ideal tanto como sea posible.
LoadShedQueueFlowController	Control de flujo desencadenado por el desprendimiento de carga de silo. Se trata de un desencadenador todo o nada que solicitará MaxValue, o 0.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler que no hace nada en respuesta a los errores.
ProviderStartException	Excepción que se produce cada vez que no se ha podido iniciar un proveedor.
PubSubSubscriptionState
QueueAdapterConstants	Constantes para adaptadores de cola.
QueueAdapterExtensions	Métodos de extensión para IQueueAdapter
QueueBalancerBase	Clase base para StreamQueueBalancer
QueueCacheMissException	La excepción indica que el mensaje solicitado no está en la caché de colas.
QueueId	Identificador de una cola duradera. Usado por extensiones de streaming de Orleans.
RegexStreamNamespacePredicate	IStreamNamespacePredicate implementación que permite filtrar espacios de nombres de flujo por expresión regular.
SequentialItem<T>	Representa un elemento de secuencia dentro de una secuencia.
StreamEventDeliveryFailureException	Esta excepción indica que un evento de secuencia no se entregó correctamente al consumidor.
StreamIdentity	Stream identidad contiene la información de flujo pública que se usa para identificar de forma única una secuencia. Stream identidades solo son únicas por proveedor de flujos.
StreamPosition	Stream posición 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.
StreamProviderExtensions	Extensiones para IStreamProvider.
StreamSequenceToken	Identificador que representa el número o token de secuencia de flujo. El consumidor puede suscribirse a la secuencia mientras se especifica el inicio del token de secuencia de suscripción. Esto significa que la infraestructura de flujo entregará eventos de secuencia a partir de este token de secuencia.
StreamSequenceTokenUtilities	Utilidades para comparar StreamSequenceToken instancias.
StreamSubscriptionHandle<T>	Identificador que representa esta suscripción. El consumidor puede serializar y almacenar el identificador para cancelar la suscripción más adelante, por ejemplo, en otra activación en este grano.
StreamSubscriptionHandleExtensions	Métodos de extensión para StreamSubscriptionHandle<T>.
StreamSubscriptionHandlerFactory	Generador para crear StreamSubscriptionHandle<T> instancias.

Interfaces

IAsyncBatchObservable<T>	Esta interfaz generaliza la interfaz IAsyncObserver para permitir la producción y el consumo de lotes de elementos. Tenga en cuenta que esta interfaz la implementan los consumidores de elementos e invocan (usan) los productores de elementos. Esto significa que el punto de conexión de consumidor de una secuencia implementa esta interfaz.
IAsyncBatchObserver<T>	Esta interfaz generaliza la interfaz IAsyncObserver para permitir la producción y el consumo de lotes de elementos. Tenga en cuenta que esta interfaz la implementan los consumidores de elementos e invocan (usan) los productores de elementos. Esto significa que el punto de conexión de consumidor de una secuencia implementa esta interfaz.
IAsyncBatchProducer<T>	Esta interfaz generaliza la interfaz IAsyncObserver para permitir la producción de lotes de elementos. Tenga en cuenta que los productores de elementos invocan (usan) esta interfaz.
IAsyncObservable<T>	Esta interfaz generaliza la interfaz IObserveable estándar de .NET para permitir el consumo asincrónico de elementos. Asincrónico aquí significa que el consumidor puede procesar los elementos de forma asincrónica y señalar la finalización de elementos al productor completando la tarea devuelta. Tenga en cuenta que los consumidores de elementos invocan (usan) esta interfaz e implementan los productores de artículos. Esto significa que el punto de conexión de productor de una secuencia implementa esta interfaz.
IAsyncObserver<T>	Esta interfaz generaliza la interfaz IObserver estándar de .NET para permitir la producción asincrónica de elementos. Tenga en cuenta que esta interfaz la implementan los consumidores de elementos e invocan (usan) los productores de elementos. Esto significa que el punto de conexión de consumidor de una secuencia implementa esta interfaz.
IAsyncStream	Esta interfaz representa un objeto que actúa como encuentro distribuido entre productores y consumidores. Es similar a un marco Subject reactivo e implementa IObserver interfaces ni IObservable .
IAsyncStream<T>	Esta interfaz representa un objeto que actúa como encuentro distribuido entre productores y consumidores. Es similar a un marco Subject reactivo e implementa IObserver interfaces ni IObservable .
IBatchContainer	Cada mensaje de cola puede ser un conjunto heterogéneo y ordenado de eventos. IBatchContainer contiene estos eventos y permite a los usuarios consultar el lote para un tipo específico de evento.
IBatchContainerBatch	Un lote de mensajes de cola (consulte IBatchContainer para obtener una descripción del contenido del lote).
IConsistentRingStreamQueueMapper	El asignador de colas de secuencias es responsable de asignar intervalos de anillos desde el proveedor de anillos de equilibrio de carga para transmitir colas. La implementación debe ser segura para subprocesos.
IDeploymentConfiguration	Interfaz para acceder a la configuración de implementación.
IQueueAdapter	Stream adaptador de Queue Storage. Se trata de una capa de abstracción que oculta los detalles de implementación del sistema de puesta en cola subyacente.
IQueueAdapterCache	Funcionalidad para crear una IQueueCache para una cola determinada.
IQueueAdapterFactory	Fábrica del adaptador. Esto debe crear un adaptador a partir de la configuración del proveedor de flujos.
IQueueAdapterReceiver	Recibe lotes de mensajes de una sola partición de una cola de mensajes.
IQueueCache
IQueueCacheCursor	Enumera los mensajes de una secuencia.
IQueueDataAdapter<TQueueMessage>	Convierte los datos de eventos en un mensaje de cola.
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Convierte los datos de eventos en y desde el mensaje de cola.
IQueueFlowController	Funcionalidad para controlar el flujo de elementos de cola recuperados.
IStreamFailureHandler	Funcionalidad para controlar errores de flujo.
IStreamIdentity	Identifica de forma única una secuencia.
IStreamIdMapper	Interfaz común para los componentes que asignan a StreamId un Key
IStreamNamespacePredicate	Stream predicado de espacio de nombres usado para filtrar suscripciones implícitas mediante ImplicitStreamSubscriptionAttribute.
IStreamNamespacePredicateProvider	Convierte cadenas de patrón de predicado en IStreamNamespacePredicate instancias.
IStreamProvider	Funcionalidad para proporcionar flujos a consumidores y productores.
IStreamPubSub
IStreamQueueBalanceListener	El agente de escucha del equilibrador de colas de flujos recibe notificaciones de un equilibrador de cola de flujo (IStreamQueueBalancer) que indica que el saldo de las colas ha cambiado. Debe implementarse por los componentes interesados en el equilibrio de carga de la cola de flujos. Cuando se recibe la notificación de cambio, el agente de escucha debe solicitar la lista actualizada de colas del equilibrador de colas.
IStreamQueueBalancer	El equilibrador de colas de flujo es responsable de equilibrar la carga de las colas en todos los demás equilibradores de cola relacionados. Notifica a los agentes de escucha (IStreamQueueBalanceListener) los cambios realizados en la distribución de colas. Método GetMyQueues, SubscribeToQueueDistributionChangeEvents y UnSubscribeFromQueueDistributionChangeEvents probablemente se llamarán en el subproceso de IStreamQueueBalanceListener, por lo que deben ser seguros para subprocesos
IStreamQueueCheckpointer<TCheckpoint>	Funcionalidad para la creación de puntos de comprobación de una secuencia.
IStreamQueueCheckpointerFactory	Generador para crear IStreamQueueCheckpointer<TCheckpoint> instancias.
IStreamQueueMapper	El asignador de colas de secuencias devuelve una lista de todas las colas y también es responsable de asignar secuencias a colas. La implementación debe ser segura para subprocesos.

Enumeraciones

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	Identifica si un proveedor de flujos es de solo lectura, de lectura y escritura o de solo escritura.
StreamPubSubType	Identifica los tipos de sistema de publicación y suscripción que pueden usar los proveedores de flujos.