EventHubAdapterFactory Class

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

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

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Inheritance

Object

EventHubAdapterFactory

Implements

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructors

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

Fields

dataAdapter	Data adapter
EventHubReceiverFactory	Factory to create a IEventHubReceiver
logger	Orleans logging
serviceProvider	Framework service provider

Properties

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.

Methods

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<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.

Extension Methods

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.