EventHubQueueCacheFactory.CreateCache Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory) |
Функция, создающая EventHubQueueCache, которая по умолчанию настраивает EventHubQueueCache с помощью конфигурации в функциях CreateBufferPool и AddCachePressureMonitors. |
CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, EventHubMonitorAggregationDimensions) |
Функция по умолчанию, вызываемая для создания EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки. |
CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory)
Функция, создающая EventHubQueueCache, которая по умолчанию настраивает EventHubQueueCache с помощью конфигурации в функциях CreateBufferPool и AddCachePressureMonitors.
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
- checkpointer
- IStreamQueueCheckpointer<String>
- loggerFactory
- ILoggerFactory
Возвращаемое значение
Реализации
Применяется к
CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, EventHubMonitorAggregationDimensions)
Функция по умолчанию, вызываемая для создания EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки.
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
- checkpointer
- IStreamQueueCheckpointer<String>
- loggerFactory
- ILoggerFactory
- bufferPool
- IObjectPool<FixedSizeBuffer>
- blockPoolId
- String
- timePurge
- TimePurgePredicate
- sharedDimensions
- EventHubMonitorAggregationDimensions