EventHubAdapterFactory 클래스

정의

네임스페이스:

Orleans.ServiceBus.Providers

어셈블리:

Orleans.Streaming.EventHubs.dll

패키지:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubAdapterFactory.cs

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

파생

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

구현

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

생성자

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

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

필드

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

속성

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

메서드

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

확장 메서드

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

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