Edytuj

Udostępnij za pośrednictwem


EventHubAdapterFactory Class

Definition

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
EventHubAdapterFactory
Implements

Constructors

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

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.

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

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

Applies to