Freigeben über


EventHubQueueCacheFactory.CreateCache Methode

Definition

Überlädt

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory)

Funktion, die einen EventHubQueueCache erstellt, der den EventHubQueueCache standardmäßig mithilfe der Konfiguration in der CreateBufferPool-Funktion und der AddCachePressureMonitors-Funktion konfiguriert.

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

Die Standardfunktion, die aufgerufen werden soll, um einen EventhubQueueCache in der IEventHubQueueCacheFactory.CreateCache-Methode zu erstellen. Der Benutzer kann diese Methode überschreiben, um weitere Anpassungen hinzuzufügen.

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory)

Funktion, die einen EventHubQueueCache erstellt, der den EventHubQueueCache standardmäßig mithilfe der Konfiguration in der CreateBufferPool-Funktion und der AddCachePressureMonitors-Funktion konfiguriert.

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

Parameter

partition
String
loggerFactory
ILoggerFactory

Gibt zurück

Implementiert

Gilt für:

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

Die Standardfunktion, die aufgerufen werden soll, um einen EventhubQueueCache in der IEventHubQueueCacheFactory.CreateCache-Methode zu erstellen. Der Benutzer kann diese Methode überschreiben, um weitere Anpassungen hinzuzufügen.

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

Parameter

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

Gibt zurück

Gilt für: