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)

ソース:: 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)

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