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

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

重载

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)	创建 EventHubQueueCache 的函数，默认情况下将使用 CreateBufferPool 函数和 AddCachePressureMonitors 函数中的配置来配置 EventHubQueueCache。
CreateCache(String, IStreamQueueCheckpointer<String>, ILoggerFactory, ITelemetryProducer)	创建 EventHubQueueCache 的函数，默认情况下将使用 CreateBufferPool 函数和 AddCachePressureMonitors 函数中的配置来配置 EventHubQueueCache。
CreateCache(String, EventHubStreamProviderSettings, IStreamQueueCheckpointer<String>, Logger, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions)	要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。
CreateCache(String, StreamStatisticOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。
CreateCache(String, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<String>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, String, TimePurgePredicate, SerializationManager, EventHubMonitorAggregationDimensions, ITelemetryProducer)	要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。

CreateCache(String, IStreamQueueCheckpointer<String>, Logger)

创建 EventHubQueueCache 的函数，默认情况下将使用 CreateBufferPool 函数和 AddCachePressureMonitors 函数中的配置来配置 EventHubQueueCache。

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)

Source:: EventHubQueueCacheFactory.cs

创建 EventHubQueueCache 的函数，默认情况下将使用 CreateBufferPool 函数和 AddCachePressureMonitors 函数中的配置来配置 EventHubQueueCache。

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)

要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。

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

块池的 ID

timePurge: TimePurgePredicate

serializationManager: SerializationManager

sharedDimensions: EventHubMonitorAggregationDimensions

IEventHubQueueCache

适用于

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

要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。

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)

Source:: EventHubQueueCacheFactory.cs

要调用的默认函数以在 IEventHubQueueCacheFactory.CreateCache 方法中创建 EventhubQueueCache。用户可以重写此方法以添加更多自定义项。

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