EventHubDataAdapter Classe

Référence

Définition

Espace de noms:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paquet:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquet:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquet:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubDataAdapter.cs

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

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<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage>

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

type EventHubDataAdapter = class
    interface ICacheDataAdapter<EventData, CachedEventHubMessage>

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

Public Class EventHubDataAdapter
Implements ICacheDataAdapter(Of EventData, CachedEventHubMessage)

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

Héritage: Object
EventHubDataAdapter

Implémente: ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Constructeurs

EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Adaptateur de données de cache qui adapte EventData d’EventHub à CachedEventHubMessage utilisé dans le cache
EventHubDataAdapter(SerializationManager)	Adaptateur de données de cache qui adapte EventData d’EventHub à CachedEventHubMessage utilisé dans le cache

Propriétés

OnBlockAllocated

Doit être défini sur la méthode OnBlockAllocated de l’EvicationStrategy du 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(CachedEventHubMessage)	Convertit un message mis en cache en conteneur de lots pour la remise
GetBatchContainer(CachedMessage)	Convertit un message mis en cache en conteneur de lots pour la remise
GetBatchContainer(EventHubMessage)	Convertir un EventHubMessage en conteneur de lots
GetMessageDequeueTimeUtc(CachedEventHubMessage)	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.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	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.
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(Guid, String)	Obtenez la clé de partition Event Hub à utiliser pour un flux.
GetSequenceToken(CachedEventHubMessage)	Obtient le jeton de séquence de flux à partir d’un message mis en cache.
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(EventData)	Obtient la position du flux à partir d’un message de file d’attente
GetStreamPosition(EventData)	Obtient la position du flux à partir d’un message de file d’attente
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.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Convertit un message TQueueMessage de la file d’attente en structures cachables TCachedMessage.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Convertit un message TQueueMessage de la file d’attente en structures cachables TCachedMessage.
ToQueueMessage<T>(Guid, String, 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.

S’applique à

Partager via