Orleans.Streams 命名空间

类

AggregatedQueueFlowController	聚合 IQueueFlowController 多个其他 IQueueFlowController 值的 。
AsyncBatchObservableExtensions	IAsyncBatchObservable<T> 的扩展方法。
AsyncObservableExtensions	IAsyncObservable<T> 的扩展方法。
BatchContainerBatch	一批批处理容器（如果配置 (请参阅 StreamPullingAgentOptions) ）将是 PersistenStreamPullingAgent 从其基础缓存中拉取的数据
CacheFullException	指示队列消息缓存已满。
ConstructorStreamNamespacePredicateProvider	Stream命名空间谓词提供程序，它支持可以构造的对象，并选择性地接受字符串作为构造函数参数。
DataNotAvailableException	异常指示请求的数据不可用。
DefaultStreamIdMapper	默认 IStreamIdMapper 实现。
DefaultStreamNamespacePredicateProvider	内部支持的流谓词的默认实现 IStreamNamespacePredicateProvider 。
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer 是一个流队列均衡器，它使用部署信息来帮助平衡队列分布。 DeploymentBasedQueueBalancer 使用部署配置来确定预期的接收器数，并使用 silo 状态 oracle 来确定哪些接收器可用。 借助此信息，它会尝试使用最适合的资源均衡算法来平衡队列。
FaultedSubscriptionException	此异常表示流订阅上发生了错误，该流订阅已将订阅置于错误状态。 应放弃对有故障订阅的工作。
HashRingBasedPartitionedStreamQueueMapper	跟踪映射到哪个分区的 QueueId 的队列映射器
HashRingBasedStreamQueueMapper	因此IStreamQueueMapper，IConsistentRingStreamQueueMapper它通过将队列映射到由 silo 组成的哈希环来平衡队列。
ImplicitConsumerGrainExtensions	隐式订阅流的 grain 的扩展方法。
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer。 此均衡器支持群集自动缩放方案、意外服务器故障方案中的队列均衡，并尝试尽可能多地支持理想的分发。
LoadShedQueueFlowController	由 silo 卸载触发的流控制。 这是一个全有或全无触发器，它将请求 MaxValue、 或 0。
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler 它不执行任何操作来响应失败。
ProviderStartException	每当未能启动提供程序时引发的异常。
PubSubSubscriptionState
QueueAdapterConstants	队列适配器的常量。
QueueAdapterExtensions	的扩展方法IQueueAdapter
QueueBalancerBase	StreamQueueBalancer 的基类
QueueCacheMissException	异常指示请求的消息不在队列缓存中。
QueueId	持久队列的标识符。 由 Orleans 流式处理扩展使用。
RegexStreamNamespacePredicate	IStreamNamespacePredicate 实现允许按正则表达式筛选流命名空间。
SequentialItem<T>	表示序列中的流项。
StreamEventDeliveryFailureException	此异常表示流事件未成功传送给使用者。
StreamIdentity	Stream标识包含用于唯一标识流的公共流信息。 Stream标识仅针对每个流提供程序是唯一的。
StreamPosition	Stream位置唯一标识事件在流中的位置。 如果获取一批事件的流位置，则流位置将是批处理中的第一个事件。
StreamProviderExtensions	的 IStreamProvider扩展。
StreamSequenceToken	表示流序列号/令牌的句柄。 使用者可以在指定订阅序列令牌的开头时订阅流。 这意味着流基础结构将从此序列令牌开始传送流事件。
StreamSequenceTokenUtilities	用于比较实例的 StreamSequenceToken 实用工具。
StreamSubscriptionHandle<T>	表示此订阅的句柄。 使用者可以序列化和存储句柄，以便稍后取消订阅，例如在此粒度上的另一个激活中。
StreamSubscriptionHandleExtensions	StreamSubscriptionHandle<T> 的扩展方法。
StreamSubscriptionHandlerFactory	用于创建 StreamSubscriptionHandle<T> 实例的工厂。

接口

IAsyncBatchObservable<T>	此接口通用化 IAsyncObserver 接口，以允许生产和使用批项。 请注意，此接口由项使用者实现，并调用 (项生成者) 使用的接口。 这意味着流的使用者终结点实现此接口。
IAsyncBatchObserver<T>	此接口通用化 IAsyncObserver 接口，以允许生产和使用批项。 请注意，此接口由项使用者实现，并调用 (项生成者) 使用的接口。 这意味着流的使用者终结点实现此接口。
IAsyncBatchProducer<T>	此接口通用化 IAsyncObserver 接口，以允许生成批项。 请注意， (项生成者) 使用，调用此接口。
IAsyncObservable<T>	此接口通用化标准 .NET IObserveable 接口，以允许异步使用项。 此处异步表示使用者可以异步处理项，并通过完成返回的任务向生成者发出项完成信号。 请注意，此接口 (由项使用者) 使用，并由项生成者实现。 这意味着流的生成者终结点实现此接口。
IAsyncObserver<T>	此接口通用化标准 .NET IObserver 接口，以允许异步生成项。 请注意，此接口由项使用者实现，并调用 (项生成者) 使用的接口。 这意味着流的使用者终结点实现此接口。
IAsyncStream	此接口表示一个对象，该对象充当生成者和使用者之间的分布式会合。 它类似于反应框架Subject，实现 也不IObservable实现IObserver接口。
IAsyncStream<T>	此接口表示一个对象，该对象充当生成者和使用者之间的分布式会合。 它类似于反应框架Subject，实现 也不IObservable实现IObserver接口。
IBatchContainer	允许每个队列消息是一组异类的有序事件。 IBatchContainer 包含这些事件，允许用户在批处理中查询特定类型的事件。
IBatchContainerBatch	一批队列消息 (请参阅 IBatchContainer，了解批处理内容的说明)
IConsistentRingStreamQueueMapper	流队列映射程序负责将环范围从负载均衡环提供程序映射到流队列。 实现必须是线程安全的。
IDeploymentConfiguration	用于访问部署配置的接口。
IQueueAdapter	Stream队列存储适配器。 这是一个抽象层，用于隐藏基础队列系统的实现详细信息。
IQueueAdapterCache	用于为给定队列创建 IQueueCache 的功能。
IQueueAdapterFactory	适配器工厂。 这应从流提供程序配置创建适配器
IQueueAdapterReceiver	从消息队列的单个分区接收成批的消息。
IQueueCache
IQueueCacheCursor	枚举流中的消息。
IQueueDataAdapter<TQueueMessage>	将事件数据转换为队列消息
IQueueDataAdapter<TQueueMessage,TMessageBatch>	将事件数据与队列消息转换和从队列消息转换
IQueueFlowController	用于控制检索到的队列项流的功能。
IStreamFailureHandler	用于处理流故障的功能。
IStreamIdentity	唯一标识流。
IStreamIdMapper	将 映射到 StreamId 的组件的通用接口 Key
IStreamNamespacePredicate	Stream命名空间谓词，用于使用 ImplicitStreamSubscriptionAttribute筛选隐式订阅。
IStreamNamespacePredicateProvider	将谓词模式字符串转换为 IStreamNamespacePredicate 实例。
IStreamProvider	用于向使用者和生成者提供流的功能。
IStreamPubSub
IStreamQueueBalanceListener	流队列均衡器侦听器从流队列均衡器接收通知， (IStreamQueueBalancer) 指示队列平衡已更改。 它应由对流队列负载均衡感兴趣的组件实现。 收到更改通知后，侦听器应从队列均衡器请求更新的队列列表。
IStreamQueueBalancer	流队列均衡器负责在所有其他相关队列均衡器之间对队列进行负载均衡。 它通知任何侦听器 (IStreamQueueBalanceListener) 队列分布的更改。 方法 GetMyQueues、SubscribeToQueueDistributionChangeEvents 和 UnSubscribeFromQueueDistributionChangeEvents 可能会调用 IStreamQueueBalanceListener 的线程，因此它们需要线程安全
IStreamQueueCheckpointer<TCheckpoint>	用于检查流检查点的功能。
IStreamQueueCheckpointerFactory	用于创建 IStreamQueueCheckpointer<TCheckpoint> 实例的工厂。
IStreamQueueMapper	流队列映射器返回所有队列的列表，还负责将流映射到队列。 实现必须是线程安全的。

枚举

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	标识流提供程序是只读、读写还是只写。
StreamPubSubType	标识流提供程序可以使用的发布/订阅系统类型。