Freigeben über


Azure.Messaging.EventHubs.Primitives Namespace

Klassen

BlobCheckpointStore

Ermöglicht die Interaktion mit Prüfpunkt- und Besitzdaten, die für den Ereignisprozessorbetrieb erforderlich sind, wobei Azure Storage-Blobs für die Persistenz verwendet werden.

CheckpointStore

Ermöglicht die Interaktion mit Prüfpunkt- und Besitzdaten, die für den Ereignisprozessorbetrieb erforderlich sind.

EventProcessor<TPartition>

Bietet eine Basis zum Erstellen eines benutzerdefinierten Prozessors, der Ereignisse für alle Partitionen eines bestimmten Event Hubs für eine bestimmte Consumergruppe nutzt. Der Prozessor ist in der Lage, mit anderen Instanzen für dieselbe Event Hub- und Consumergruppenpaarung zusammenzuarbeiten, um Die Arbeit über eine gemeinsame Speicherplattform für die Kommunikation zu teilen. Fehlertoleranz ist ebenfalls integriert, sodass der Prozessor bei Fehlern widerstandsfähig ist.

EventProcessorCheckpoint

Enthält die Informationen, die den Status der Ereignisverarbeitung für eine bestimmte Event Hub-Partition widerspiegeln.

EventProcessorOptions

Der Satz von Optionen, die beim Erstellen eines EventProcessor<TPartition> angegeben werden können, um sein Verhalten zu konfigurieren.

EventProcessorPartition

Eine Reihe von Kontextinformationen zu einer Event Hub-Partition, für die ein EventProcessor<TPartition> Vorgang ausgeführt wird.

EventProcessorPartitionOwnership

Der Satz von Informationen zum Beschreiben der status des Partitionsbesitzes zwischen EventProcessor<TPartition> Instanzen, die für die Verteilung der Verarbeitung für einen bestimmten Event Hub zusammenarbeiten.

PartitionReceiver

Ermöglicht das Lesen von Ereignissen aus einer bestimmten Partition eines Event Hubs und im Kontext einer bestimmten Consumergruppe mit einer größeren Kontrolle über die Kommunikation mit dem Event Hubs-Dienst als von anderen Ereigniskonsumenten angeboten wird.

PartitionReceiverOptions

Der Satz von Optionen, die beim Erstellen eines PartitionReceiver angegeben werden können, um sein Verhalten zu konfigurieren.

PluggableCheckpointStoreEventProcessor<TPartition>

Stellt eine Basis zum Erstellen eines Ereignisprozessors mit benutzerdefinierter Verarbeitungslogik bereit, die Ereignisse für alle Partitionen eines bestimmten Event Hubs für eine bestimmte Consumergruppe nutzt. Der Prozessor ist in der Lage, mit anderen Instanzen für dieselbe Event Hub- und Consumergruppenpaarung zusammenzuarbeiten, um Die Arbeit über eine gemeinsame Speicherplattform für die Kommunikation zu teilen. Fehlertoleranz ist ebenfalls integriert, sodass der Prozessor bei Fehlern widerstandsfähig ist.