EventHubQueueCacheFactory.CreateCache Метод

Ссылка

Определение

Пространство имен:: Orleans.ServiceBus.Providers

Сборка:: OrleansServiceBus.dll

Сборка:: Orleans.Streaming.EventHubs.dll

Пакет:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Пакет:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Пакет:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Перегрузки

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)	Функция, создающая EventHubQueueCache, которая по умолчанию настраивает EventHubQueueCache с помощью конфигурации в функции CreateBufferPool и функции AddCachePressureMonitors.
CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory, ITelemetryProducer)	Функция, создающая EventHubQueueCache, которая по умолчанию настраивает EventHubQueueCache с помощью конфигурации в функции CreateBufferPool и функции AddCachePressureMonitors.
CreateCache(String, EventHubStreamProviderSettings, IStreamQueueCheckpointer<String>, Logger, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions)	Функция по умолчанию для создания объекта EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки.
CreateCache(String, StreamStatisticOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	Функция по умолчанию для создания объекта EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки.
CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	Функция по умолчанию для создания объекта EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки.

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)

Функция, создающая EventHubQueueCache, которая по умолчанию настраивает EventHubQueueCache с помощью конфигурации в функции CreateBufferPool и функции 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

Параметры

partition: String

checkpointer: IStreamQueueCheckpointer<String>

logger: Logger

Возвращаемое значение

IEventHubQueueCache

Реализации

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)

Применяется к

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

Исходный код:: EventHubQueueCacheFactory.cs

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

Параметры

partition: String

checkpointer: IStreamQueueCheckpointer<String>

loggerFactory: ILoggerFactory

telemetryProducer: ITelemetryProducer

Возвращаемое значение

IEventHubQueueCache

Реализации

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

Применяется к

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

Функция по умолчанию для создания объекта EventhubQueueCache в методе IEventHubQueueCacheFactory.CreateCache. Пользователь может переопределить этот метод, чтобы добавить дополнительные настройки.

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

Параметры

partition: String

providerSettings: EventHubStreamProviderSettings

checkpointer: IStreamQueueCheckpointer<String>

cacheLogger: Logger

bufferPool: IObjectPool<FixedSizeBuffer>

blockPoolId: String

Идентификатор для пула блоков

timePurge: TimePurgePredicate

serializationManager: SerializationManager

sharedDimensions: EventHubMonitorAggregationDimensions

Возвращаемое значение

IEventHubQueueCache

Применяется к

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

Параметры

partition: String

statisticOptions: StreamStatisticOptions

checkpointer: IStreamQueueCheckpointer<String>

loggerFactory: ILoggerFactory

bufferPool: IObjectPool<FixedSizeBuffer>

blockPoolId: String

timePurge: TimePurgePredicate

serializationManager: SerializationManager

sharedDimensions: EventHubMonitorAggregationDimensions

telemetryProducer: ITelemetryProducer

Возвращаемое значение

IEventHubQueueCache

Применяется к

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

Исходный код:: 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