EventHubAdapterFactory 클래스

정의

네임스페이스:

Orleans.Streaming.EventHubs

어셈블리:

Orleans.Streaming.EventHubs.dll

패키지:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

PersistentStreamProvider가 EventHub를 백 엔드 영구 이벤트 큐로 사용할 수 있도록 하는 큐 어댑터 팩터리입니다.

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

상속

Object

EventHubAdapterFactory

구현

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

생성자

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

PersistentStreamProvider가 EventHub를 백 엔드 영구 이벤트 큐로 사용할 수 있도록 하는 큐 어댑터 팩터리입니다.

필드

dataAdapter	데이터 어댑터
EventHubReceiverFactory	IEventHubReceiver를 만드는 팩터리
logger	Orleans 로깅
serviceProvider	프레임워크 서비스 공급자

속성

CacheFactory	eventhub 파티션에 대한 메시지 캐시를 만듭니다.
Direction	이 큐 어댑터의 방향: 읽기, 쓰기 또는 읽기Write.
IsRewindable	이 가 되감기 가능한 스트림 어댑터인지 여부를 결정합니다. 이전 시점의 구독을 지원합니다.
Name	어댑터 이름입니다. 주로 로깅용
QueueMapperFactory	큐 매퍼를 Create EventHub 파티션을 큐에 매핑
ReceiverMonitorFactory	수신기 모니터를 Create 성능 메트릭을 보고합니다. 팩터리 함수는 IEventHubReceiverMonitor를 반환해야 합니다.
StreamFailureHandlerFactory	파티션에 대한 오류 처리기를 만듭니다.

메서드

Create(IServiceProvider, String)	PersistentStreamProvider가 EventHub를 백 엔드 영구 이벤트 큐로 사용할 수 있도록 하는 큐 어댑터 팩터리입니다.
CreateAdapter()	Create 큐 어댑터입니다.
CreateCacheFactory(EventHubStreamCachePressureOptions)	IEventHubQueueCacheFactory를 Create. 기본적으로 EventHubQueueCacheFactory를 만듭니다. 사용자는 IEventHubQueueCacheFactory의 자체 구현 및 IEventHubQueueCacheFactory의 다른 사용자 지정을 반환하도록 이 함수를 재정의할 수 있습니다(있는 경우).
CreateQueueCache(QueueId)	지정된 큐 ID에 대한 캐시 Create
CreateReceiver(QueueId)	지정된 queueId에 대한 큐 수신기를 만듭니다.
GetDeliveryFailureHandler(QueueId)	큐에 대한 배달 실패 처리기 획득
GetPartitionIdsAsync()	eventhub에서 파티션 ID 가져오기
GetQueueAdapterCache()	Create 큐 메시지 캐시 어댑터
GetStreamQueueMapper()	Create 큐 매퍼
Init()	PersistentStreamProvider가 EventHub를 백 엔드 영구 이벤트 큐로 사용할 수 있도록 하는 큐 어댑터 팩터리입니다.
InitEventHubClient()	PersistentStreamProvider가 EventHub를 백 엔드 영구 이벤트 큐로 사용할 수 있도록 하는 큐 어댑터 팩터리입니다.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	제공된 streamId와 연결된 단일 일괄 처리로 이벤트 집합을 큐에 씁니다.

확장 메서드

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

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