共用方式為


EventHubQueueCacheFactory.CreateCache 方法

定義

多載

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory)

建立 EventHubQueueCache 的函式,預設會使用 CreateBufferPool 函式和 AddCachePressureMonitors 函式中的組態來設定 EventHubQueueCache。

CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, EventHubMonitorAggregationDimensions)

要呼叫的預設函式,以在 IEventHubQueueCacheFactory.CreateCache 方法中建立 EventhubQueueCache。 使用者可以覆寫這個方法以新增更多自訂。

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory)

建立 EventHubQueueCache 的函式,預設會使用 CreateBufferPool 函式和 AddCachePressureMonitors 函式中的組態來設定 EventHubQueueCache。

public Orleans.Streaming.EventHubs.IEventHubQueueCache CreateCache (string partition, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILoggerFactory loggerFactory);
abstract member CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory -> Orleans.Streaming.EventHubs.IEventHubQueueCache
override this.CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory -> Orleans.Streaming.EventHubs.IEventHubQueueCache
Public Function CreateCache (partition As String, checkpointer As IStreamQueueCheckpointer(Of String), loggerFactory As ILoggerFactory) As IEventHubQueueCache

參數

partition
String
loggerFactory
ILoggerFactory

傳回

實作

適用於

CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, EventHubMonitorAggregationDimensions)

要呼叫的預設函式,以在 IEventHubQueueCacheFactory.CreateCache 方法中建立 EventhubQueueCache。 使用者可以覆寫這個方法以新增更多自訂。

protected virtual Orleans.Streaming.EventHubs.IEventHubQueueCache CreateCache (string partition, Orleans.Streaming.EventHubs.IEventHubDataAdapter dataAdatper, Orleans.Configuration.StreamStatisticOptions statisticOptions, Orleans.Configuration.StreamCacheEvictionOptions streamCacheEvictionOptions, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILoggerFactory loggerFactory, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, string blockPoolId, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Orleans.Streaming.EventHubs.EventHubMonitorAggregationDimensions sharedDimensions);
abstract member CreateCache : string * Orleans.Streaming.EventHubs.IEventHubDataAdapter * Orleans.Configuration.StreamStatisticOptions * Orleans.Configuration.StreamCacheEvictionOptions * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * string * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Streaming.EventHubs.EventHubMonitorAggregationDimensions -> Orleans.Streaming.EventHubs.IEventHubQueueCache
override this.CreateCache : string * Orleans.Streaming.EventHubs.IEventHubDataAdapter * Orleans.Configuration.StreamStatisticOptions * Orleans.Configuration.StreamCacheEvictionOptions * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * string * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Streaming.EventHubs.EventHubMonitorAggregationDimensions -> Orleans.Streaming.EventHubs.IEventHubQueueCache
Protected Overridable Function CreateCache (partition As String, dataAdatper As IEventHubDataAdapter, statisticOptions As StreamStatisticOptions, streamCacheEvictionOptions As StreamCacheEvictionOptions, checkpointer As IStreamQueueCheckpointer(Of String), loggerFactory As ILoggerFactory, bufferPool As IObjectPool(Of FixedSizeBuffer), blockPoolId As String, timePurge As TimePurgePredicate, sharedDimensions As EventHubMonitorAggregationDimensions) As IEventHubQueueCache

參數

partition
String
dataAdatper
IEventHubDataAdapter
statisticOptions
StreamStatisticOptions
streamCacheEvictionOptions
StreamCacheEvictionOptions
loggerFactory
ILoggerFactory
blockPoolId
String
timePurge
TimePurgePredicate

傳回

適用於