EventHubDataAdapter Classe

Definição

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Adaptador de dados padrão do hub de eventos. Os usuários podem subclasse para substituir os dados de evento para o mapeamento de fluxo.

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)

Herança

Object

EventHubDataAdapter

Implementações

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Construtores

EventHubDataAdapter(Serializer)

Adaptador de dados de cache que adapta EventData do EventHub para CachedEventHubMessage usado no cache

Métodos

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Adaptador de dados padrão do hub de eventos. Os usuários podem subclasse para substituir os dados de evento para o mapeamento de fluxo.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Adaptador de dados padrão do hub de eventos. Os usuários podem subclasse para substituir os dados de evento para o mapeamento de fluxo.
GetBatchContainer(CachedMessage)	Converte uma mensagem armazenada em cache em um contêiner em lote para entrega
GetBatchContainer(EventHubMessage)	Converter um EventHubMessage em um contêiner de lote
GetOffset(CachedMessage)	Obter deslocamento da mensagem armazenada em cache. Deixado para a classe derivada, pois só ele sabe como obter isso da mensagem armazenada em cache.
GetPartitionKey(StreamId)	Obtenha a chave de partição do Hub de Eventos a ser usada para um fluxo.
GetSequenceToken(CachedMessage)	Obtém o token de sequência de fluxo de uma mensagem armazenada em cache.
GetStreamIdentity(EventData)	Obtenha o IStreamIdentity para uma mensagem de evento.
GetStreamPosition(String, EventData)	Adaptador de dados padrão do hub de eventos. Os usuários podem subclasse para substituir os dados de evento para o mapeamento de fluxo.
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Adaptador de dados padrão do hub de eventos. Os usuários podem subclasse para substituir os dados de evento para o mapeamento de fluxo.