EventHubDataAdapter Classe

Définition

Espace de noms:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Paquet:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streaming.EventHubs.IEventHubDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>

type EventHubDataAdapter = class
    interface IEventHubDataAdapter
    interface IQueueDataAdapter<EventData>
    interface ICacheDataAdapter

Public Class EventHubDataAdapter
Implements ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter(Of EventData)

Héritage

Object

EventHubDataAdapter

Implémente

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Constructeurs

EventHubDataAdapter(Serializer)

Adaptateur de données de cache qui adapte EventData d’EventHub à CachedEventHubMessage utilisé dans le cache

Méthodes

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.
GetBatchContainer(CachedMessage)	Convertit un message mis en cache en conteneur de lots pour la remise
GetBatchContainer(EventHubMessage)	Convertir un EventHubMessage en conteneur de lots
GetOffset(CachedMessage)	Obtenez un décalage à partir du message mis en cache. Laissé à la classe dérivée, car seul il sait comment l’obtenir à partir du message mis en cache.
GetPartitionKey(StreamId)	Obtenez la clé de partition Event Hub à utiliser pour un flux.
GetSequenceToken(CachedMessage)	Obtient le jeton de séquence de flux à partir d’un message mis en cache.
GetStreamIdentity(EventData)	Obtenez le IStreamIdentity pour un message d’événement.
GetStreamPosition(String, EventData)	Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Adaptateur de données event hub par défaut. Les utilisateurs peuvent sous-classer pour remplacer les données d’événement pour le mappage de flux.