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
1 回の読み取りからキャッシュに追加できるメッセージの最大数
- 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
1 回の読み取りからキャッシュに追加できるメッセージの最大数
- 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>)
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