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)

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

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