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) Creates and initializes an Event Hubs adapter factory.
CreateAdapter Creates the queue adapter and initializes its partition mapping.
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) Creates a cache for the specified queue.
CreateReceiver(QueueId) Creates a queue receiver for the specified queue.
GetDeliveryFailureHandler(QueueId) Gets the delivery failure handler for a queue.
GetPartitionIdsAsync Gets the partition identifiers from Event Hubs.
GetQueueAdapterCache Gets the queue cache factory implemented by this instance.
GetStreamQueueMapper Gets the mapper between Orleans stream queues and Event Hub partitions.
Init Initializes the adapter factory and its Event Hub client, cache, queue mapping, and monitoring components.
InitEventHubClient Initializes the Event Hub producer client.
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.