GeneratorAdapterFactory 클래스

정의

네임스페이스:

Orleans.Providers.Streams.Generator

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

스트림 생성기 스트림 공급자용 어댑터 팩터리입니다. 이 팩터리는 어댑터 및 어댑터 팩터리 역할을 합니다. 구성 가능한 생성기를 사용하여 스토리지에서 읽는 대신 이벤트 스트림을 생성하는 수신기를 만듭니다.

public class GeneratorAdapterFactory : Orleans.Providers.IControllable, Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type GeneratorAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache
    interface IControllable

Public Class GeneratorAdapterFactory
Implements IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

상속

Object

GeneratorAdapterFactory

구현

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

생성자

GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

스트림 생성기 스트림 공급자용 어댑터 팩터리입니다. 이 팩터리는 어댑터 및 어댑터 팩터리 역할을 합니다. 구성 가능한 생성기를 사용하여 스토리지에서 읽는 대신 이벤트 스트림을 생성하는 수신기를 만듭니다.

필드

BlockPoolMonitorFactory	블록 풀 관련 메트릭을 모니터링하는 블록 풀 모니터 만들기 IBlockPoolMonitor 반환
CacheMonitorFactory	캐시 관련 메트릭을 보고하는 캐시 모니터 만들기 ICacheMonitor 반환
ReceiverMonitorFactory	QueueAdapterReceiver 관련 메트릭을 모니터링하는 모니터 만들기 IQueueAdapterReceiverMonitor 반환

속성

Direction	이 큐 어댑터의 방향: 읽기, 쓰기 또는 읽기Write.
IsRewindable	되감기 가능한 스트림 어댑터인지 여부를 확인합니다. 이전 시점의 구독을 지원합니다.
Name	어댑터 이름입니다. IQueueAdapter에서.

메서드

Create(IServiceProvider, String)	새 GeneratorAdapterFactory 인스턴스를 만듭니다.
CreateAdapter()	어댑터 만들기
CreateQueueCache(QueueId)	지정된 큐 ID에 대한 캐시 만들기
CreateReceiver(QueueId)	지정된 queueId에 대한 큐 수신기를 만듭니다.
ExecuteCommand(Int32, Object)	컨트롤 명령을 실행하는 함수입니다.
GetDeliveryFailureHandler(QueueId)	배달 실패 처리기 가져오기
GetQueueAdapterCache()	캐시 어댑터 가져오기
GetStreamQueueMapper()	스트림 큐 매퍼 가져오기
Init()	팩터리를 초기화합니다.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	제공된 streamId와 연결된 단일 일괄 처리로 이벤트 집합을 큐에 씁니다.

확장 메서드

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

제공 streamId된 와 연결된 단일 일괄 처리로 이벤트 집합을 큐에 씁니다.