EventHubAdapterFactory

class

Namespace: Orleans.Streaming.EventHubs

Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.

public class EventHubAdapterFactory : IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Constructors

CacheFactory Creates a message cache for an eventhub partition.
Direction Direction of this queue adapter: Read, Write or ReadWrite.
IsRewindable Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time.
Name Name of the adapter. Primarily for logging purposes
QueueMapperFactory Create a queue mapper to map EventHub partitions to queues
ReceiverMonitorFactory Create a receiver monitor to report performance metrics. Factory function should return an IEventHubReceiverMonitor.
StreamFailureHandlerFactory Creates a failure handler for a partition.

Create(IServiceProvider, string)
CreateAdapter Create queue adapter.
CreateCacheFactory(EventHubStreamCachePressureOptions) Create a IEventHubQueueCacheFactory. It will create a EventHubQueueCacheFactory by default. User can override this function to return their own implementation of IEventHubQueueCacheFactory, and other customization of IEventHubQueueCacheFactory if they may.
CreateQueueCache(QueueId) Create a cache for a given queue id
CreateReceiver(QueueId) Creates a queue receiver for the specified queueId
GetDeliveryFailureHandler(QueueId) Acquire delivery failure handler for a queue
GetPartitionIdsAsync Get partition Ids from eventhub
GetQueueAdapterCache Create queue message cache adapter
GetStreamQueueMapper Create queue mapper
Init
InitEventHubClient
QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>) Writes a set of events to the queue as a single batch associated with the provided streamId.