EventHubDataAdapter Clase

Referencia

Definición

Espacio de nombres:: Orleans.ServiceBus.Providers

Ensamblado:: OrleansServiceBus.dll

Ensamblado:: Orleans.Streaming.EventHubs.dll

Paquete:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquete:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquete:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubDataAdapter.cs

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

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

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)

Herencia: Object
EventHubDataAdapter

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

Constructores

EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Adaptador de datos de caché que adapta EventData de EventHub a CachedEventHubMessage usado en caché
EventHubDataAdapter(SerializationManager)	Adaptador de datos de caché que adapta EventData de EventHub a CachedEventHubMessage usado en caché

Propiedades

OnBlockAllocated

Debe establecerse en el método OnBlockAllocated del EvicationStrategy de la memoria caché.

Métodos

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase 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 invalidar los datos de eventos para la asignación de secuencias.
GetBatchContainer(CachedEventHubMessage)	Convierte un mensaje almacenado en caché en un contenedor por lotes para la entrega.
GetBatchContainer(CachedMessage)	Convierte un mensaje almacenado en caché en un contenedor por lotes para la entrega.
GetBatchContainer(EventHubMessage)	Convertir un EventHubMessage en un contenedor por lotes
GetMessageDequeueTimeUtc(CachedEventHubMessage)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase invalidar los datos de eventos para la asignación de secuencias.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase invalidar los datos de eventos para la asignación de secuencias.
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(Guid, String)	Obtenga la clave de partición del centro de eventos que se va a usar para una secuencia.
GetSequenceToken(CachedEventHubMessage)	Obtiene el token de secuencia de secuencia de un mensaje almacenado en caché.
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(EventData)	Obtiene la posición de la secuencia de un mensaje de cola.
GetStreamPosition(EventData)	Obtiene la posición de la secuencia de un mensaje de cola.
GetStreamPosition(String, EventData)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase invalidar los datos de eventos para la asignación de secuencias.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Convierte un mensaje TQueueMessage de la cola en estructuras Cachable de TCachedMessage.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Convierte un mensaje TQueueMessage de la cola en estructuras Cachable de TCachedMessage.
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Adaptador de datos predeterminado del centro de eventos. Los usuarios pueden subclase invalidar los datos de eventos para la asignación de secuencias.

Se aplica a

Compartir a través de