EventHubDataAdapter Clase

Definición

Espacio de nombres:

Orleans.Streaming.EventHubs

Ensamblado:

Orleans.Streaming.EventHubs.dll

Paquete:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase para invalidar los datos de eventos para la asignación de secuencias.

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)

Herencia

Object

EventHubDataAdapter

Implementaciones

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Constructores

EventHubDataAdapter(Serializer)

Adaptador de datos de caché que adapta EventData de EventHub a CachedEventHubMessage usado en la memoria caché

Métodos

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase para invalidar los datos de eventos para la asignación de secuencias.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase para invalidar los datos de eventos para la asignación de secuencias.
GetBatchContainer(CachedMessage)	Convierte un mensaje almacenado en caché en un contenedor por lotes para la entrega.
GetBatchContainer(EventHubMessage)	Conversión de eventHubMessage en un contenedor por lotes
GetOffset(CachedMessage)	Obtener desplazamiento del mensaje almacenado en caché. De izquierda a clase derivada, ya que solo sabe cómo obtener esto del mensaje almacenado en caché.
GetPartitionKey(StreamId)	Obtenga la clave de partición del centro de eventos que se va a usar para una secuencia.
GetSequenceToken(CachedMessage)	Obtiene el token de secuencia de secuencia de un mensaje almacenado en caché.
GetStreamIdentity(EventData)	Obtiene para IStreamIdentity un mensaje de evento.
GetStreamPosition(String, EventData)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase para invalidar los datos de eventos para la asignación de secuencias.
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase para invalidar los datos de eventos para la asignación de secuencias.