EventHubQueueCacheFactory.CreateCache(string, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<string>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, string, TimePurgePredicate, EventHubMonitorAggregationDimensions)

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubQueueCacheFactory
5. Methods
6. CreateCache(string, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<string>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, string, TimePurgePredicate, EventHubMonitorAggregationDimensions)

Markdown

CreateCache(string, IEventHubDataAdapter, StreamStatisticOptions, StreamCacheEvictionOptions, IStreamQueueCheckpointer<string>, ILoggerFactory, IObjectPool<FixedSizeBuffer>, string, TimePurgePredicate, EventHubMonitorAggregationDimensions)

virtual

View source

protected virtual IEventHubQueueCache CreateCache(string partition, IEventHubDataAdapter dataAdatper, StreamStatisticOptions statisticOptions, StreamCacheEvictionOptions streamCacheEvictionOptions, IStreamQueueCheckpointer<string> checkpointer, ILoggerFactory loggerFactory, IObjectPool<FixedSizeBuffer> bufferPool, string blockPoolId, TimePurgePredicate timePurge, EventHubMonitorAggregationDimensions sharedDimensions)

Default function to be called to create an EventhubQueueCache in IEventHubQueueCacheFactory.CreateCache method. User can override this method to add more customization.

Parameters

partitionstring

dataAdatperIEventHubDataAdapter

statisticOptionsStreamStatisticOptions

streamCacheEvictionOptionsStreamCacheEvictionOptions

checkpointerIStreamQueueCheckpointer<string>

loggerFactoryILoggerFactory

bufferPoolIObjectPool<FixedSizeBuffer>

blockPoolIdstring

timePurgeTimePurgePredicate

sharedDimensionsEventHubMonitorAggregationDimensions