EventHubDataAdapter Classe

Riferimento

Definizione

Spazio dei nomi:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Origine:: EventHubDataAdapter.cs

Importante

Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.

Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.

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)

Ereditarietà: Object
EventHubDataAdapter

Implementazioni: ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Costruttori

EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Adattatore dati della cache che adatta EventData di EventHub a CachedEventHubMessage usato nella cache
EventHubDataAdapter(SerializationManager)	Adattatore dati della cache che adatta EventData di EventHub a CachedEventHubMessage usato nella cache

Proprietà

OnBlockAllocated

Deve essere impostato sul metodo OnBlockAllocated della cache EvicationStrategy della cache

Metodi

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.
GetBatchContainer(CachedEventHubMessage)	Converte un messaggio memorizzato nella cache in un contenitore batch per il recapito
GetBatchContainer(CachedMessage)	Converte un messaggio memorizzato nella cache in un contenitore batch per il recapito
GetBatchContainer(EventHubMessage)	Convertire un EventHubMessage in un contenitore batch
GetMessageDequeueTimeUtc(CachedEventHubMessage)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.
GetOffset(CachedMessage)	Ottenere l'offset dal messaggio memorizzato nella cache. Lasciato alla classe derivata, perché solo sa come ottenerlo dal messaggio memorizzato nella cache.
GetPartitionKey(Guid, String)	Ottenere la chiave di partizione dell'hub eventi da usare per un flusso.
GetSequenceToken(CachedEventHubMessage)	Ottiene il token della sequenza di flusso da un messaggio memorizzato nella cache.
GetSequenceToken(CachedMessage)	Ottiene il token della sequenza di flusso da un messaggio memorizzato nella cache.
GetStreamIdentity(EventData)	Ottenere l'oggetto IStreamIdentity per un messaggio di evento.
GetStreamPosition(EventData)	Ottiene la posizione del flusso da un messaggio della coda
GetStreamPosition(EventData)	Ottiene la posizione del flusso da un messaggio della coda
GetStreamPosition(String, EventData)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Converte un messaggio TQueueMessage dalla coda a strutture gestibili TCachedMessage.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Converte un messaggio TQueueMessage dalla coda a strutture gestibili TCachedMessage.
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Adattatore dati dell'hub eventi predefinito. Gli utenti possono eseguire la sottoclasse per eseguire l'override dei dati dell'evento per eseguire il mapping dei flussi.

Si applica a

Condividi tramite