EventHubAdapterFactory Klasse

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Paket:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Warteschlangenadapterfactory, die es dem PersistentStreamProvider ermöglicht, EventHub als persistente Back-End-Ereigniswarteschlange zu verwenden.

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

Vererbung

Object

EventHubAdapterFactory

Implementiert

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Konstruktoren

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

Warteschlangenadapterfactory, die es dem PersistentStreamProvider ermöglicht, EventHub als persistente Back-End-Ereigniswarteschlange zu verwenden.

Felder

dataAdapter	Datenadapter
EventHubReceiverFactory	Factory zum Erstellen eines IEventHubReceiver
logger	Orleans-Protokollierung
serviceProvider	Framework-Dienstanbieter

Eigenschaften

CacheFactory	Erstellt einen Nachrichtencache für eine Eventhub-Partition.
Direction	Richtung dieses Warteschlangenadapters: Read, Write oder ReadWrite.
IsRewindable	Bestimmt, ob es sich um einen wieder aufwickelbaren Streamadapter handelt. Unterstützt das Abonnieren von einem vorherigen Zeitpunkt.
Name	Der Name des Adapters. In erster Linie für Protokollierungszwecke
QueueMapperFactory	Create einer Warteschlangenzuordnung, um EventHub-Partitionen Warteschlangen zuzuordnen
ReceiverMonitorFactory	Create einen Empfängermonitor, um Leistungsmetriken zu melden. Die Factoryfunktion sollte einen IEventHubReceiverMonitor zurückgeben.
StreamFailureHandlerFactory	Erstellt einen Fehlerhandler für eine Partition.

Methoden

Create(IServiceProvider, String)	Warteschlangenadapterfactory, die es dem PersistentStreamProvider ermöglicht, EventHub als persistente Back-End-Ereigniswarteschlange zu verwenden.
CreateAdapter()	Create Warteschlangenadapter.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create eine IEventHubQueueCacheFactory. Standardmäßig wird eine EventHubQueueCacheFactory erstellt. Benutzer können diese Funktion überschreiben, um ihre eigene Implementierung von IEventHubQueueCacheFactory und andere Anpassungen von IEventHubQueueCacheFactory zurückzugeben, falls möglich.
CreateQueueCache(QueueId)	Create eines Caches für eine bestimmte Warteschlangen-ID
CreateReceiver(QueueId)	Erstellt einen Warteschlangenempfänger für die angegebene queueId
GetDeliveryFailureHandler(QueueId)	Abrufen des Übermittlungsfehlerhandlers für eine Warteschlange
GetPartitionIdsAsync()	Abrufen von Partitions-IDs aus eventhub
GetQueueAdapterCache()	Create Cacheadapter für Warteschlangennachrichten
GetStreamQueueMapper()	Create Warteschlangenzuordnung
Init()	Warteschlangenadapterfactory, die es dem PersistentStreamProvider ermöglicht, EventHub als persistente Back-End-Ereigniswarteschlange zu verwenden.
InitEventHubClient()	Warteschlangenadapterfactory, die es dem PersistentStreamProvider ermöglicht, EventHub als persistente Back-End-Ereigniswarteschlange zu verwenden.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Schreibt einen Satz von Ereignissen in die Warteschlange als einzelnen Batch, der der bereitgestellten streamId zugeordnet ist.

Erweiterungsmethoden

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

Schreibt einen Satz von Ereignissen in die Warteschlange als einzelnen Batch, der dem bereitgestellten streamIdzugeordnet ist.