EventHubQueueCache<TCachedMessage> 생성자

정의

네임스페이스:

Orleans.ServiceBus.Providers

어셈블리:

Orleans.Streaming.EventHubs.dll

패키지:

Microsoft.Orleans.OrleansServiceBus v2.4.5

오버로드

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

EventHub 큐 캐시를 생성합니다.

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

EventHub 큐 캐시를 생성합니다.

protected EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,TCachedMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<TCachedMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);

new Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, 'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheDataComparer<'CachedMessage (requires 'CachedMessage : struct)> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)>

Protected Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, TCachedMessage), comparer As ICacheDataComparer(Of TCachedMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of TCachedMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))

매개 변수

defaultMaxAddCount

Int32

제거 호출 사이에 캐시에 추가할 수 있는 기본 최대 항목 수입니다.

checkpointer

IStreamQueueCheckpointer<String>

큐 위치를 저장하는 데 사용되는 논리입니다.

cacheDataAdapter

ICacheDataAdapter<EventData,TCachedMessage>

다양한 유형의 큐 데이터에 적합한 데이터 변환을 수행합니다.

comparer

ICacheDataComparer<TCachedMessage>

캐시된 데이터 비교

logger

ILogger

evictionStrategy

IEvictionStrategy<TCachedMessage>

제거 전략 관리 제거 관련 이벤트

cacheMonitor

ICacheMonitor

cacheMonitorWriteInterval

Nullable<TimeSpan>