EventHubQueueCache 생성자
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
오버로드
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
사용자 지정 데이터 어댑터가 지정된 캐시를 생성합니다.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
큐 데이터를 캐시에 맞게 조정
- comparer
- ICacheDataComparer<CachedEventHubMessage>
스트림 정보를 캐시된 데이터와 비교
- logger
- ILogger
캐시 로거
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
캐시에 대한 제거 전략
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
사용자 지정 데이터 어댑터가 지정된 캐시를 생성합니다.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
큐 데이터를 캐시에 맞게 조정
- comparer
- ICacheDataComparer<CachedEventHubMessage>
스트림 정보를 캐시된 데이터와 비교
- logger
- Logger
캐시 로거
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
캐시에 대한 제거 전략
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
버퍼 풀이 지정된 캐시를 생성합니다. 기본 데이터 어댑터를 사용합니다.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Microsoft.Extensions.Logging.ILogger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Microsoft.Extensions.Logging.ILogger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As ILogger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- bufferPool
- IObjectPool<FixedSizeBuffer>
버퍼 풀 캐시는 원시 버퍼에 사용해야 합니다.
- timePurge
- TimePurgePredicate
시간 기반 제거를 트리거하는 데 사용되는 조건자
- logger
- ILogger
캐시 로거
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
버퍼 풀이 지정된 캐시를 생성합니다. 기본 데이터 어댑터를 사용합니다.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Orleans.Runtime.Logger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Runtime.Logger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As Logger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- bufferPool
- IObjectPool<FixedSizeBuffer>
버퍼 풀 캐시는 원시 버퍼에 사용해야 합니다.
- timePurge
- TimePurgePredicate
시간 기반 제거를 트리거하는 데 사용되는 조건자
- logger
- Logger
캐시 로거
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
사용자 지정 데이터 어댑터가 지정된 캐시를 생성합니다.
public EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- defaultMaxAddCount
- Int32
단일 읽기에서 캐시에 추가할 수 있는 최대 메시지 수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
큐 데이터를 캐시에 맞게 조정
- comparer
- ICacheDataComparer<CachedEventHubMessage>
스트림 정보를 캐시된 데이터와 비교
- logger
- ILogger
캐시 로거
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
캐시에 대한 제거 전략
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
사용자 지정 데이터 어댑터가 지정된 캐시를 생성합니다.
public EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))매개 변수
- defaultMaxAddCount
- Int32
단일 읽기에서 캐시에 추가할 수 있는 최대 메시지 수
- checkpointer
- IStreamQueueCheckpointer<String>
큐 검사점 기록기
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
큐 데이터를 캐시에 맞게 조정
- comparer
- ICacheDataComparer<CachedEventHubMessage>
스트림 정보를 캐시된 데이터와 비교
- logger
- Logger
캐시 로거
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
캐시에 대한 제거 전략
- cacheMonitor
- ICacheMonitor
적용 대상
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)
- Source:
- EventHubQueueCache.cs
EventHub 큐 캐시.
public EventHubQueueCache (string partition, int defaultMaxAddCount, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.ServiceBus.Providers.IEventHubDataAdapter dataAdapter, Orleans.Providers.Streams.Common.IEvictionStrategy evictionStrategy, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval, TimeSpan? metadataMinTimeInCache);new Orleans.ServiceBus.Providers.EventHubQueueCache : string * int * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.ServiceBus.Providers.IEventHubDataAdapter * Orleans.Providers.Streams.Common.IEvictionStrategy * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (partition As String, defaultMaxAddCount As Integer, bufferPool As IObjectPool(Of FixedSizeBuffer), dataAdapter As IEventHubDataAdapter, evictionStrategy As IEvictionStrategy, checkpointer As IStreamQueueCheckpointer(Of String), logger As ILogger, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan), metadataMinTimeInCache As Nullable(Of TimeSpan))매개 변수
- partition
- String
이 인스턴스를 캐싱하는 파티션입니다.
- defaultMaxAddCount
- Int32
제거 호출 사이에 캐시에 추가할 수 있는 기본 최대 항목 수입니다.
- bufferPool
- IObjectPool<FixedSizeBuffer>
원시 데이터 블록 풀.
- dataAdapter
- IEventHubDataAdapter
EventData를 캐시됨으로 조정합니다.
- evictionStrategy
- IEvictionStrategy
제거 전략 관리 제거 관련 이벤트
- checkpointer
- IStreamQueueCheckpointer<String>
큐 위치를 저장하는 데 사용되는 논리입니다.
- logger
- ILogger
- cacheMonitor
- ICacheMonitor