Compartir a través de


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.

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
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.

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
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.

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
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.

StreamProviderManagerExtensions
StreamQueueBalancerType

Tipo de equilibrador de cola de flujos integrado que se admite de forma nativa en Orleans

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).

IClusterClientPersistentStreamConfigurator
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.

ISiloPersistentStreamConfigurator
ISiloRecoverableStreamConfigurator
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.

IStreamProviderImpl
IStreamProviderManager
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.

Delegados

StreamFilterPredicate