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 использует конфигурацию развертывания, чтобы определить, сколько разрозненных объектов следует ожидать, и использует оракул состояния силоса, чтобы определить, какие из них доступны. Используя эти сведения, он пытается сбалансировать очереди с помощью оптимально подходящего алгоритма балансировки ресурсов.
FaultedSubscriptionException	Это исключение указывает на то, что в подписке потока произошла ошибка, которая переместила подписку в состояние сбоя. Работа с неисправными подписками должна быть прекращена.
HashRingBasedPartitionedStreamQueueMapper	Модуль сопоставления очередей, который отслеживает, какой раздел был сопоставлен с тем, с каким QueueId
HashRingBasedStreamQueueMapper	И IConsistentRingStreamQueueMapper , следовательно, IStreamQueueMapper который балансирует очереди, сопоставляя их с хеш-кольцом, состоящим из разрозненности.
ImplicitConsumerGrainExtensions	Методы расширения для объектов grain, неявно подписанных на потоки.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Эта подсистема балансировки поддерживает балансировку очередей в сценариях автоматического масштабирования кластера, непредвиденных сценариях сбоя сервера и пытается максимально поддерживать оптимальное распределение.
LoadShedQueueFlowController	Управление потоком, активированное при промыве нагрузки силоса. Это триггер "все или ничего", который запрашивает 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>	Этот интерфейс обобщает стандартный интерфейс IObserveable .NET, чтобы разрешить асинхронное использование элементов. Асинхронный здесь означает, что потребитель может асинхронно обрабатывать элементы и сообщать о завершении элемента производителю, завершив возвращенную задачу. Обратите внимание, что этот интерфейс вызывается (используется) потребителями элементов и реализуется производителями элементов. Это означает, что конечная точка производителя потока реализует этот интерфейс.
IAsyncObserver<T>	Этот интерфейс обобщает стандартный интерфейс IObserver .NET, чтобы разрешить асинхронное производство элементов. Обратите внимание, что этот интерфейс реализуется потребителями элементов и вызывается (используется) производителями элементов. Это означает, что конечная точка-получатель потока реализует этот интерфейс.
IAsyncStream	Этот интерфейс представляет объект , который служит в качестве распределенного рандеву между производителями и потребителями. Она похожа на reactive Framework Subject и не реализует IObserver интерфейсы IObservable .
IAsyncStream<T>	Этот интерфейс представляет объект , который служит в качестве распределенного рандеву между производителями и потребителями. Она похожа на reactive Framework Subject и не реализует IObserver интерфейсы IObservable .
IBatchContainer	Каждое сообщение очереди может быть разнородным упорядоченным набором событий. IBatchContainer содержит эти события и позволяет пользователям запрашивать в пакете определенный тип события.
IBatchContainerBatch	Пакет сообщений очереди (описание содержимого пакета см. в разделе IBatchContainer).
IConsistentRingStreamQueueMapper	Средство сопоставления очередей потоков отвечает за сопоставление диапазонов кругов от поставщика кругов балансировки нагрузки до потоковых очередей. Реализация должна быть потокобезопасной.
IDeploymentConfiguration	Интерфейс для доступа к конфигурации развертывания.
IQueueAdapter	Stream адаптер хранилища очередей. Это уровень абстракции, который скрывает сведения о реализации базовой системы очередей.
IQueueAdapterCache	Функциональные возможности для создания IQueueCache для заданной очереди.
IQueueAdapterFactory	Фабрика адаптеров. Это должно создать адаптер из конфигурации поставщика потока.
IQueueAdapterReceiver	Получает пакеты сообщений из одной секции очереди сообщений.
IQueueCache
IQueueCacheCursor	Перечисляет сообщения в потоке.
IQueueDataAdapter<TQueueMessage>	Преобразует данные события в сообщение очереди.
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Преобразует данные события в сообщение очереди и из нее
IQueueFlowController	Функции для управления потоком извлеченных элементов очереди.
IStreamFailureHandler	Функциональные возможности для обработки сбоев потока.
IStreamIdentity	Уникально идентифицирует поток.
IStreamIdMapper	Общий интерфейс для компонентов, которые сопоставляют с StreamIdKey
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	Определяет типы систем публикации и подписки, которые могут использовать поставщики потоков.