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는 배포 구성을 사용하여 예상할 사일로 수를 결정하고 사일로 상태 oracle을 사용하여 사용 가능한 사일로를 결정합니다. 이 정보를 사용하면 가장 적합한 리소스 분산 알고리즘을 사용하여 큐의 균형을 맞추려고 합니다.
FaultedSubscriptionException	이 예외는 구독을 오류 상태로 전환한 스트림 구독에서 오류가 발생했음을 나타냅니다. 오류가 발생한 구독에 대한 작업은 중단해야 합니다.
HashRingBasedPartitionedStreamQueueMapper	QueueId에 매핑된 파티션을 추적하는 큐 매퍼
HashRingBasedStreamQueueMapper	따라서 IStreamQueueMapper 사 IConsistentRingStreamQueueMapper 일로로 구성된 해시 링에 매핑하여 큐의 균형을 맞추는 입니다.
ImplicitConsumerGrainExtensions	스트림을 암시적으로 구독하는 조직에 대한 확장 메서드입니다.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. 이 분산 장치는 클러스터 자동 크기 조정 시나리오, 예기치 않은 서버 오류 시나리오에서 큐 분산을 지원하며 가능한 한 이상적인 배포를 지원하려고 합니다.
LoadShedQueueFlowController	사일로 부하 분산에 의해 트리거되는 흐름 제어입니다. 이 트리거는 또는 을 요청하는 MaxValue전체 또는 0없음 트리거입니다.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler 오류에 대한 응답으로 아무 작업도 수행하지 않습니다.
ProviderStartException	공급자가 시작되지 않을 때마다 예외가 throw됩니다.
PubSubSubscriptionState
QueueAdapterConstants	큐 어댑터에 대한 상수입니다.
QueueAdapterExtensions	에 대한 확장 메서드입니다.IQueueAdapter
QueueBalancerBase	StreamQueueBalancer의 기본 클래스
QueueCacheMissException	예외는 요청된 메시지가 큐 캐시에 없음을 나타냅니다.
QueueId	지속성 큐의 식별자입니다. Orleans 스트리밍 확장에서 사용됩니다.
RegexStreamNamespacePredicate	IStreamNamespacePredicate 정규식으로 스트림 네임스페이스를 필터링할 수 있는 구현입니다.
SequentialItem<T>	시퀀스 내의 스트림 항목을 나타냅니다.
StreamEventDeliveryFailureException	이 예외는 스트림 이벤트가 소비자에게 성공적으로 전달되지 않음을 나타냅니다.
StreamIdentity	Stream ID에는 스트림을 고유하게 식별하는 데 사용하는 공용 스트림 정보가 포함됩니다. Stream ID는 스트림 공급자당 고유합니다.
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	이 인터페이스는 생산자와 소비자 간의 분산 랑데부 역할을 하는 개체를 나타냅니다. 이는 Reactive Framework Subject 와 유사하며 또는 인터페이스를 IObserverIObservable 구현합니다.
IAsyncStream<T>	이 인터페이스는 생산자와 소비자 간의 분산 랑데부 역할을 하는 개체를 나타냅니다. 이는 Reactive Framework Subject 와 유사하며 또는 인터페이스를 IObserverIObservable 구현합니다.
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	를 사용하여 ImplicitStreamSubscriptionAttribute암시적 구독을 필터링하는 데 사용되는 네임스페이스 조건자를 Stream.
IStreamNamespacePredicateProvider	조건자 패턴 문자열을 인스턴스로 IStreamNamespacePredicate 변환합니다.
IStreamProvider	소비자 및 생산자에게 스트림을 제공하는 기능입니다.
IStreamPubSub
IStreamQueueBalanceListener	스트림 큐 분산 장치 수신기는 스트림 큐 분산 장치(IStreamQueueBalancer)에서 큐의 균형이 변경되었음을 나타내는 알림을 받습니다. 스트림 큐 부하 분산에 관심이 있는 구성 요소에 의해 구현되어야 합니다. 변경 알림이 수신되면 수신기는 큐 분산 장치에서 업데이트된 큐 목록을 요청해야 합니다.
IStreamQueueBalancer	스트림 큐 분산 장치는 다른 모든 관련 큐 분산 장치에서 큐의 부하 분산을 담당합니다. 모든 수신기(IStreamQueueBalanceListener)에게 큐 배포에 대한 변경 내용을 알 수 있습니다. GetMyQueues, SubscribeToQueueDistributionChangeEvents 및 UnSubscribeFromQueueDistributionChangeEvents는 스레드로부터 안전해야 하므로 IStreamQueueBalanceListener의 스레드에서 호출될 가능성이 높습니다.
IStreamQueueCheckpointer<TCheckpoint>	스트림 검사점 지정에 대한 기능입니다.
IStreamQueueCheckpointerFactory	인스턴스를 만들기 IStreamQueueCheckpointer<TCheckpoint> 위한 팩터리입니다.
IStreamQueueMapper	스트림 큐 매퍼는 모든 큐 목록을 반환하며 스트림을 큐에 매핑하는 작업도 담당합니다. 구현은 스레드로부터 안전해야 합니다.

열거형

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	스트림 공급자가 읽기 전용, 읽기-쓰기 또는 쓰기 전용인지 여부를 식별합니다.
StreamPubSubType	스트림 공급자가 사용할 수 있는 게시/구독 시스템 유형을 식별합니다.