EventHubAdapterFactory Klasse

Referenz

Definition

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paket:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paket:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paket:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Quelle:: EventHubAdapterFactory.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

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

Vererbung: Object
EventHubAdapterFactory

Abgeleitet: Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

Implementiert: IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Konstruktoren

EventHubAdapterFactory()	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.

Felder

adapterSettings	Einstellungen des Streamanbieters
checkpointerSettings	Prüfpunkteinstellungen
dataAdapter	Datenadapter
EventHubReceiverFactory	Factory zum Erstellen eines IEventHubReceivers
hubSettings	Event Hub-Einstellungen
logger	Orleans-Protokollierung
providerConfig	Anbieterkonfiguration
serviceProvider	Framework-Dienstanbieter

Eigenschaften

CacheFactory	Erstellt einen Nachrichtencache für eine Eventhub-Partition.
CheckpointerFactory	Erstellt einen Parition-Prüfpunkter.
Direction	Richtung dieses Warteschlangenadapters: Lesen, Schreiben oder LesenWrite.
IsRewindable	Bestimmt, ob es sich um einen um einen umwindbaren Datenstromadapter handelt– unterstützt das Abonnieren von vorherigen Zeitpunkten.
Name	Name des Adapters. In erster Linie für Protokollierungszwecke
QueueMapperFactory	Erstellen einer Warteschlangenzuordnung zum Zuordnen von EventHub-Partitionen zu Warteschlangen
ReceiverMonitorFactory	Erstellen Sie einen Empfängermonitor, um Leistungsmetriken zu melden. Factory Funciton sollte einen IEventHubReceiverMonitor zurückgeben.
SerializationManager	Ruft den Serialisierungs-Manager ab.
StreamFailureHandlerFactory	Erstellt einen Fehlerhandler für eine Partition.

Methoden

Create(IServiceProvider, String)	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
CreateAdapter()	Erstellen Sie den Warteschlangenadapter.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Erstellen Sie eine IEventHubQueueCacheFactory. Es wird standardmäßig eine EventHubQueueCacheFactory erstellt. Benutzer können diese Funktion außer Kraft setzen, um ihre eigene Implementierung von IEventHubQueueCacheFactory und andere Anpassungen von IEventHubQueueCacheFactory zurückzugeben.
CreateCacheFactory(EventHubStreamProviderSettings)	Erstellen Sie eine IEventHubQueueCacheFactory. Es wird standardmäßig eine EventHubQueueCacheFactory erstellt. Benutzer können diese Funktion außer Kraft setzen, um ihre eigene Implementierung von IEventHubQueueCacheFactory und andere Anpassungen von IEventHubQueueCacheFactory zurückzugeben.
CreateQueueCache(QueueId)	Erstellen eines Caches für eine bestimmte Warteschlangen-ID
CreateReceiver(QueueId)	Erstellt einen Quereempfänger für die spezifische queueId
GetDeliveryFailureHandler(QueueId)	Aquire Delivery Failure Handler für eine Warteschlange
GetPartitionIdsAsync()	Abrufen von Partitions-IDs von eventhub
GetQueueAdapterCache()	Cacheadapter für Warteschlangennachrichten erstellen
GetStreamQueueMapper()	Erstellen eines Warteschlangenzuordnungers
Init()	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Factoryinitialisierung. Die Anbieterkonfiguration muss den Ereignishub-Einstellungstyp oder die Einstellungen selbst enthalten. EventHubSettingsType wird für Verbraucher empfohlen, die keine sicheren Informationen in die Clusterkonfiguration einbeziehen möchten.
InitEventHubClient()	Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Schreibt eine Reihe von Ereignissen in die Warteschlange als einzelner Batch, der der bereitgestellten streamId zugeordnet ist.

Erweiterungsmethoden

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

Schreibt eine Reihe von Ereignissen in die Warteschlange als einzelner Batch, der der bereitgestellten streamId zugeordnet ist.

Gilt für:

Freigeben über