Поделиться через


Orleans.Streams Пространство имен

Классы

AggregatedQueueFlowController

Объект , IQueueFlowController который объединяет несколько других значений IQueueFlowController .

AsyncBatchObservableExtensions

Методы расширения для IAsyncBatchObservable<T>.

AsyncObservableExtensions

Методы расширения для IAsyncObservable<T>.

BatchContainerBatch

Пакет пакетных контейнеров, которые, если они настроены (см. StreamPullingAgentOptions), будут данными, извлекаемыми PersistenStreamPullingAgent из его базового кэша.

CacheFullException

Указывает, что кэш сообщений очереди заполнен.

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
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 который не выполняет никаких действий в ответ на сбои.

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
ProviderStartException

Исключение возникает каждый раз, когда поставщику не удается запустить.

PubSubSubscriptionState
QueueAdapterConstants

Константы для адаптеров очередей.

QueueAdapterExtensions

Методы расширения для .IQueueAdapter

QueueBalancerBase

Базовый класс для StreamQueueBalancer

QueueCacheMissException

Исключение означает, что запрошенного сообщения нет в кэше очереди.

QueueId

Идентификатор устойчивой очереди. Используется расширениями потоковой передачи Orleans.

RegexStreamNamespacePredicate

IStreamNamespacePredicate реализация, позволяющая фильтровать пространства имен потоков по регулярному выражению.

SequentialItem<T>

Представляет элемент потока в последовательности.

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
StreamEventDeliveryFailureException

Это исключение указывает, что событие потока не было успешно доставлено потребителю.

StreamIdentity

Stream удостоверение содержит сведения об общедоступном потоке, используемые для уникальной идентификации потока. Stream удостоверения уникальны только для каждого поставщика потока.

StreamPosition

Stream положение однозначно определяет положение события в потоке. При получении позиции потока для пакета событий позиция потока будет первой в пакете.

StreamProviderExtensions

Расширения для IStreamProvider.

StreamProviderManagerExtensions
StreamQueueBalancerType

Встроенный тип подсистемы балансировки очередей потоков, который изначально поддерживается в Orleans

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

IClusterClientPersistentStreamConfigurator
IConsistentRingStreamQueueMapper

Средство сопоставления очередей потоков отвечает за сопоставление диапазонов кругов от поставщика кругов балансировки нагрузки до потоковых очередей. Реализация должна быть потокобезопасной.

IDeploymentConfiguration

Интерфейс для доступа к конфигурации развертывания.

IQueueAdapter

Stream адаптер хранилища очередей. Это уровень абстракции, который скрывает сведения о реализации базовой системы очередей.

IQueueAdapterCache

Функциональные возможности для создания IQueueCache для заданной очереди.

IQueueAdapterFactory

Фабрика адаптеров. Это должно создать адаптер из конфигурации поставщика потока.

IQueueAdapterReceiver

Получает пакеты сообщений из одной секции очереди сообщений.

IQueueCache
IQueueCacheCursor

Перечисляет сообщения в потоке.

IQueueDataAdapter<TQueueMessage>

Преобразует данные события в сообщение очереди.

IQueueDataAdapter<TQueueMessage,TMessageBatch>

Преобразует данные события в сообщение очереди и из нее

IQueueFlowController

Функции для управления потоком извлеченных элементов очереди.

ISiloPersistentStreamConfigurator
ISiloRecoverableStreamConfigurator
IStreamFailureHandler

Функциональные возможности для обработки сбоев потока.

IStreamIdentity

Уникально идентифицирует поток.

IStreamIdMapper

Общий интерфейс для компонентов, которые сопоставляют с StreamIdKey

IStreamNamespacePredicate

Stream предикате пространства имен, используемого для фильтрации неявных подписок с помощью ImplicitStreamSubscriptionAttribute.

IStreamNamespacePredicateProvider

Преобразует строки шаблона предиката в IStreamNamespacePredicate экземпляры.

IStreamProvider

Функциональные возможности для предоставления потоков потребителям и производителям.

IStreamProviderImpl
IStreamProviderManager
IStreamPubSub
IStreamQueueBalanceListener

Прослушиватель подсистемы балансировки очередей потоков получает уведомления от подсистемы балансировки очередей потоков (IStreamQueueBalancer), указывающие на изменение баланса очередей. Она должна быть реализована компонентами, заинтересованными в балансировке нагрузки потоковой очереди. При получении уведомления об изменении прослушиватель должен запросить обновленный список очередей из балансировщика очередей.

IStreamQueueBalancer

Подсистема балансировки очередей потоков отвечает за балансировку нагрузки очередей во всех других связанных балансировщиках очередей. Он уведомляет все прослушиватели (IStreamQueueBalanceListener) об изменениях в распределении очередей. Методы GetMyQueues, SubscribeToQueueDistributionChangeEvents и UnSubscribeFromQueueDistributionChangeEvents, скорее всего, будут вызываться в потоке IStreamQueueBalanceListener, чтобы они были потокобезопасны.

IStreamQueueCheckpointer<TCheckpoint>

Функциональные возможности для создания контрольных точек потока.

IStreamQueueCheckpointerFactory

Фабрика для создания IStreamQueueCheckpointer<TCheckpoint> экземпляров.

IStreamQueueMapper

Средство сопоставления очередей потоков возвращает список всех очередей, а также отвечает за сопоставление потоков с очередями. Реализация должна быть потокобезопасной.

Перечисления

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection

Определяет, является ли поставщик потока доступен только для чтения, чтения и записи или только для записи.

StreamPubSubType

Определяет типы систем публикации и подписки, которые могут использовать поставщики потоков.

Делегаты

StreamFilterPredicate