다음을 통해 공유


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는 배포 구성을 사용하여 예상할 사일로 수를 결정하고 사일로 상태 oracle을 사용하여 사용 가능한 사일로를 결정합니다. 이 정보를 사용하면 가장 적합한 리소스 분산 알고리즘을 사용하여 큐의 균형을 맞추려고 합니다.

FaultedSubscriptionException

이 예외는 구독을 오류 상태로 전환한 스트림 구독에서 오류가 발생했음을 나타냅니다. 오류가 발생한 구독에 대한 작업은 중단해야 합니다.

HashRingBasedPartitionedStreamQueueMapper

QueueId에 매핑된 파티션을 추적하는 큐 매퍼

HashRingBasedStreamQueueMapper

따라서 IStreamQueueMapperIConsistentRingStreamQueueMapper 일로로 구성된 해시 링에 매핑하여 큐의 균형을 맞추는 입니다.

ImplicitConsumerGrainExtensions

스트림을 암시적으로 구독하는 조직에 대한 확장 메서드입니다.

LeaseBasedQueueBalancer

LeaseBasedQueueBalancer. 이 분산 장치는 클러스터 자동 크기 조정 시나리오, 예기치 않은 서버 오류 시나리오에서 큐 분산을 지원하며 가능한 한 이상적인 배포를 지원하려고 합니다.

LoadShedQueueFlowController

사일로 부하 분산에 의해 트리거되는 흐름 제어입니다. 이 트리거는 또는 을 요청하는 MaxValue전체 또는 0없음 트리거입니다.

NoOpStreamDeliveryFailureHandler

IStreamFailureHandler 오류에 대한 응답으로 아무 작업도 수행하지 않습니다.

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
ProviderStartException

공급자가 시작되지 않을 때마다 예외가 throw됩니다.

PubSubSubscriptionState
QueueAdapterConstants

큐 어댑터에 대한 상수입니다.

QueueAdapterExtensions

에 대한 확장 메서드입니다.IQueueAdapter

QueueBalancerBase

StreamQueueBalancer의 기본 클래스

QueueCacheMissException

예외는 요청된 메시지가 큐 캐시에 없음을 나타냅니다.

QueueId

지속성 큐의 식별자입니다. Orleans 스트리밍 확장에서 사용됩니다.

RegexStreamNamespacePredicate

IStreamNamespacePredicate 정규식으로 스트림 네임스페이스를 필터링할 수 있는 구현입니다.

SequentialItem<T>

시퀀스 내의 스트림 항목을 나타냅니다.

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
StreamEventDeliveryFailureException

이 예외는 스트림 이벤트가 소비자에게 성공적으로 전달되지 않음을 나타냅니다.

StreamIdentity

Stream ID에는 스트림을 고유하게 식별하는 데 사용하는 공용 스트림 정보가 포함됩니다. Stream ID는 스트림 공급자당 고유합니다.

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>

이 인터페이스는 표준 .NET IObserveable 인터페이스를 일반화하여 항목의 비동기 사용을 허용합니다. 여기서 비동기적으로는 소비자가 반환된 작업을 완료하여 항목을 비동기적으로 처리하고 생산자에게 항목 완성을 신호를 보낼 수 있음을 의미합니다.

이 인터페이스는 항목 소비자가 호출(사용)하고 항목 생산자가 구현합니다. 즉, 스트림의 생산자 엔드포인트가 이 인터페이스를 구현합니다.

IAsyncObserver<T>

이 인터페이스는 표준 .NET IObserver 인터페이스를 일반화하여 항목의 비동기 프로덕션을 허용합니다.

이 인터페이스는 항목 소비자가 구현하고 항목 생산자가 호출(사용)합니다. 즉, 스트림의 소비자 엔드포인트는 이 인터페이스를 구현합니다.

IAsyncStream

이 인터페이스는 생산자와 소비자 간의 분산 랑데부 역할을 하는 개체를 나타냅니다. 이는 Reactive Framework Subject 와 유사하며 또는 인터페이스를 IObserverIObservable 구현합니다.

IAsyncStream<T>

이 인터페이스는 생산자와 소비자 간의 분산 랑데부 역할을 하는 개체를 나타냅니다. 이는 Reactive Framework Subject 와 유사하며 또는 인터페이스를 IObserverIObservable 구현합니다.

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

에 매핑 StreamId 되는 구성 요소에 대한 공통 인터페이스 Key

IStreamNamespacePredicate

를 사용하여 ImplicitStreamSubscriptionAttribute암시적 구독을 필터링하는 데 사용되는 네임스페이스 조건자를 Stream.

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