CacheFactory
getset
protected Func<string, IStreamQueueCheckpointer<string>, ILoggerFactory, IEventHubQueueCache> CacheFactory Creates a message cache for an eventhub partition.
EventHubAdapterFactory Properties
Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
Direction
getset
public StreamProviderDirection Direction Direction of this queue adapter: Read, Write or ReadWrite.
Returns
The direction in which this adapter provides data.
IsRewindable
get
public bool IsRewindable Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time.
Returns
True if this is a rewindable stream adapter, false otherwise.
Name
get
public string Name Name of the adapter. Primarily for logging purposes
QueueMapperFactory
getset
protected Func<string[], HashRingBasedPartitionedStreamQueueMapper> QueueMapperFactory Create a queue mapper to map EventHub partitions to queues
ReceiverMonitorFactory
getset
protected Func<EventHubReceiverMonitorDimensions, ILoggerFactory, IQueueAdapterReceiverMonitor> ReceiverMonitorFactory Create a receiver monitor to report performance metrics. Factory function should return an IEventHubReceiverMonitor.
StreamFailureHandlerFactory
getset
protected Func<string, Task<IStreamFailureHandler>> StreamFailureHandlerFactory Creates a failure handler for a partition.