EventHubQueueCacheFactory.CreateCache Método

Referencia

Definición

Espacio de nombres:: Orleans.ServiceBus.Providers

Ensamblado:: OrleansServiceBus.dll

Ensamblado:: Orleans.Streaming.EventHubs.dll

Paquete:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquete:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquete:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Sobrecargas

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)	Función que crea un EventHubQueueCache, que de forma predeterminada configurará EventHubQueueCache mediante la configuración de la función CreateBufferPool y la función AddCachePressureMonitors.
CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory, ITelemetryProducer)	Función que crea un EventHubQueueCache, que de forma predeterminada configurará EventHubQueueCache mediante la configuración de la función CreateBufferPool y la función AddCachePressureMonitors.
CreateCache(String, EventHubStreamProviderSettings, IStreamQueueCheckpointer<String>, Logger, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions)	Función predeterminada a la que se va a llamar para crear un eventhubQueueCache en el método IEventHubQueueCacheFactory.CreateCache. El usuario puede invalidar este método para agregar más personalización.
CreateCache(String, StreamStatisticOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	Función predeterminada a la que se va a llamar para crear un eventhubQueueCache en el método IEventHubQueueCacheFactory.CreateCache. El usuario puede invalidar este método para agregar más personalización.
CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	Función predeterminada a la que se va a llamar para crear un eventhubQueueCache en el método IEventHubQueueCacheFactory.CreateCache. El usuario puede invalidar este método para agregar más personalización.

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)

Función que crea un EventHubQueueCache, que de forma predeterminada configurará EventHubQueueCache mediante la configuración de la función CreateBufferPool y la función AddCachePressureMonitors.

public Orleans.ServiceBus.Providers.IEventHubQueueCache CreateCache (string partition, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Runtime.Logger logger);

abstract member CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Runtime.Logger -> Orleans.ServiceBus.Providers.IEventHubQueueCache
override this.CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Runtime.Logger -> Orleans.ServiceBus.Providers.IEventHubQueueCache

Public Function CreateCache (partition As String, checkpointer As IStreamQueueCheckpointer(Of String), logger As Logger) As IEventHubQueueCache

Parámetros

partition: String

checkpointer: IStreamQueueCheckpointer<String>

logger: Logger

Devoluciones

IEventHubQueueCache

Implementaciones

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)

Se aplica a

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory, ITelemetryProducer)

Source:: EventHubQueueCacheFactory.cs

Función que crea un EventHubQueueCache, que de forma predeterminada configurará EventHubQueueCache mediante la configuración de la función CreateBufferPool y la función AddCachePressureMonitors.

public Orleans.ServiceBus.Providers.IEventHubQueueCache CreateCache (string partition, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILoggerFactory loggerFactory, Orleans.Runtime.ITelemetryProducer telemetryProducer);

abstract member CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.IEventHubQueueCache
override this.CreateCache : string * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILoggerFactory * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.IEventHubQueueCache

Public Function CreateCache (partition As String, checkpointer As IStreamQueueCheckpointer(Of String), loggerFactory As ILoggerFactory, telemetryProducer As ITelemetryProducer) As IEventHubQueueCache

Parámetros

partition: String

checkpointer: IStreamQueueCheckpointer<String>

loggerFactory: ILoggerFactory

telemetryProducer: ITelemetryProducer

Devoluciones

IEventHubQueueCache

Implementaciones

CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory, ITelemetryProducer)

Se aplica a

CreateCache(String, EventHubStreamProviderSettings, IStreamQueueCheckpointer<String>, Logger, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions)

Función predeterminada a la que se va a llamar para crear un eventhubQueueCache en el método IEventHubQueueCacheFactory.CreateCache. El usuario puede invalidar este método para agregar más personalización.

protected virtual Orleans.ServiceBus.Providers.IEventHubQueueCache CreateCache (string partition, Orleans.ServiceBus.Providers.EventHubStreamProviderSettings providerSettings, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Runtime.Logger cacheLogger, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, string blockPoolId, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Orleans.Serialization.SerializationManager serializationManager, Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions sharedDimensions);

abstract member CreateCache : string * Orleans.ServiceBus.Providers.EventHubStreamProviderSettings * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * string * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions -> Orleans.ServiceBus.Providers.IEventHubQueueCache
override this.CreateCache : string * Orleans.ServiceBus.Providers.EventHubStreamProviderSettings * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * string * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions -> Orleans.ServiceBus.Providers.IEventHubQueueCache

Protected Overridable Function CreateCache (partition As String, providerSettings As EventHubStreamProviderSettings, checkpointer As IStreamQueueCheckpointer(Of String), cacheLogger As Logger, bufferPool As IObjectPool(Of FixedSizeBuffer), blockPoolId As String, timePurge As TimePurgePredicate, serializationManager As SerializationManager, sharedDimensions As EventHubMonitorAggregationDimensions) As IEventHubQueueCache

Parámetros

partition: String

providerSettings: EventHubStreamProviderSettings

checkpointer: IStreamQueueCheckpointer<String>

cacheLogger: Logger

bufferPool: IObjectPool<FixedSizeBuffer>

blockPoolId: String

Identificador del grupo de bloques

timePurge: TimePurgePredicate

serializationManager: SerializationManager

sharedDimensions: EventHubMonitorAggregationDimensions

Devoluciones

IEventHubQueueCache

Se aplica a

CreateCache(String, StreamStatisticOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)

protected virtual Orleans.ServiceBus.Providers.IEventHubQueueCache CreateCache (string partition, Orleans.Configuration.StreamStatisticOptions statisticOptions, 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.Serialization.SerializationManager serializationManager, Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions sharedDimensions, Orleans.Runtime.ITelemetryProducer telemetryProducer);

abstract member CreateCache : string * Orleans.Configuration.StreamStatisticOptions * 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.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.IEventHubQueueCache
override this.CreateCache : string * Orleans.Configuration.StreamStatisticOptions * 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.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.IEventHubQueueCache

Protected Overridable Function CreateCache (partition As String, statisticOptions As StreamStatisticOptions, checkpointer As IStreamQueueCheckpointer(Of String), loggerFactory As ILoggerFactory, bufferPool As IObjectPool(Of FixedSizeBuffer), blockPoolId As String, timePurge As TimePurgePredicate, serializationManager As SerializationManager, sharedDimensions As EventHubMonitorAggregationDimensions, telemetryProducer As ITelemetryProducer) As IEventHubQueueCache

Parámetros

partition: String

statisticOptions: StreamStatisticOptions

checkpointer: IStreamQueueCheckpointer<String>

loggerFactory: ILoggerFactory

bufferPool: IObjectPool<FixedSizeBuffer>

blockPoolId: String

timePurge: TimePurgePredicate

serializationManager: SerializationManager

sharedDimensions: EventHubMonitorAggregationDimensions

telemetryProducer: ITelemetryProducer

Devoluciones

IEventHubQueueCache

Se aplica a

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

Source:: EventHubQueueCacheFactory.cs

protected virtual Orleans.ServiceBus.Providers.IEventHubQueueCache CreateCache (string partition, Orleans.ServiceBus.Providers.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.Serialization.SerializationManager serializationManager, Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions sharedDimensions, Orleans.Runtime.ITelemetryProducer telemetryProducer);

abstract member CreateCache : string * Orleans.ServiceBus.Providers.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.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.IEventHubQueueCache
override this.CreateCache : string * Orleans.ServiceBus.Providers.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.Serialization.SerializationManager * Orleans.ServiceBus.Providers.EventHubMonitorAggregationDimensions * Orleans.Runtime.ITelemetryProducer -> Orleans.ServiceBus.Providers.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, serializationManager As SerializationManager, sharedDimensions As EventHubMonitorAggregationDimensions, telemetryProducer As ITelemetryProducer) As IEventHubQueueCache