EventHubDataAdapter Classe

Referência

Definição

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Pacote:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Pacote:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Pacote:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Origem:: EventHubDataAdapter.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

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<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)

Herança: Object
EventHubDataAdapter

Implementações: ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Construtores

EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Adaptador de dados de cache que adapta EventData do EventHub para CachedEventHubMessage usado no cache
EventHubDataAdapter(SerializationManager)	Adaptador de dados de cache que adapta EventData do EventHub para CachedEventHubMessage usado no cache

Propriedades

OnBlockAllocated

Deve ser definido como o método OnBlockAllocated da EvicationStrategy do 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(CachedEventHubMessage)	Converte uma mensagem armazenada em cache em um contêiner em lote para entrega
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
GetMessageDequeueTimeUtc(CachedEventHubMessage)	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.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	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.
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(Guid, String)	Obtenha a chave de partição do Hub de Eventos a ser usada para um fluxo.
GetSequenceToken(CachedEventHubMessage)	Obtém o token de sequência de fluxo de uma mensagem armazenada em cache.
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(EventData)	Obtém a posição do fluxo de uma mensagem de fila
GetStreamPosition(EventData)	Obtém a posição do fluxo de uma mensagem de fila
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.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Converte uma mensagem TQueueMessage da fila em uma estrutura cachável TCachedMessage.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Converte uma mensagem TQueueMessage da fila em uma estrutura cachável TCachedMessage.
ToQueueMessage<T>(Guid, String, 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.

Aplica-se a

Compartilhar via