Edit

Share via

EventHubQueueCache Constructor

  • Reference

Definition

Namespace:
Orleans.Streaming.EventHubs
Assembly:
Orleans.Streaming.EventHubs.dll
Package:
Microsoft.Orleans.Streaming.EventHubs v7.2.5
Package:
Microsoft.Orleans.Streaming.EventHubs v8.0.0
Package:
Microsoft.Orleans.Streaming.EventHubs v8.1.0

EventHub queue cache.

public EventHubQueueCache (string partition, int defaultMaxAddCount, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Streaming.EventHubs.IEventHubDataAdapter dataAdapter, Orleans.Providers.Streams.Common.IEvictionStrategy evictionStrategy, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval, TimeSpan? metadataMinTimeInCache);
new Orleans.Streaming.EventHubs.EventHubQueueCache : string * int * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Streaming.EventHubs.IEventHubDataAdapter * Orleans.Providers.Streams.Common.IEvictionStrategy * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> * Nullable<TimeSpan> -> Orleans.Streaming.EventHubs.EventHubQueueCache
Public Sub New (partition As String, defaultMaxAddCount As Integer, bufferPool As IObjectPool(Of FixedSizeBuffer), dataAdapter As IEventHubDataAdapter, evictionStrategy As IEvictionStrategy, checkpointer As IStreamQueueCheckpointer(Of String), logger As ILogger, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan), metadataMinTimeInCache As Nullable(Of TimeSpan))

Parameters

partition
String

Partition this instance is caching.

defaultMaxAddCount
Int32

Default max number of items that can be added to the cache between purge calls.

bufferPool
IObjectPool<FixedSizeBuffer>

raw data block pool.

dataAdapter
IEventHubDataAdapter

Adapts EventData to cached.

evictionStrategy
IEvictionStrategy

Eviction strategy manage purge related events

checkpointer
IStreamQueueCheckpointer<String>

Logic used to store queue position.

logger
ILogger
cacheMonitor
ICacheMonitor
cacheMonitorWriteInterval
Nullable<TimeSpan>
metadataMinTimeInCache
Nullable<TimeSpan>

Applies to