EventHubDataAdapter Klasse

Referenz

Definition

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Paket:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paket:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paket:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Quelle:: EventHubDataAdapter.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.

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)

Vererbung: Object
EventHubDataAdapter

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

Konstruktoren

EventHubDataAdapter(SerializationManager)	Cachedatenadapter, der die EventData von EventHub an CachedEventHubMessage angepasst, die im Cache verwendet werden
EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Cachedatenadapter, der die EventData von EventHub an CachedEventHubMessage angepasst, die im Cache verwendet werden

Eigenschaften

OnBlockAllocated

Sollte auf onBlockAllocated-Methode des EvicationStrategy des Caches festgelegt werden.

Methoden

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.
GetBatchContainer(CachedEventHubMessage)	Konvertiert eine zwischengespeicherte Nachricht in einen Batchcontainer für die Übermittlung
GetBatchContainer(CachedMessage)	Konvertiert eine zwischengespeicherte Nachricht in einen Batchcontainer für die Übermittlung
GetBatchContainer(EventHubMessage)	Konvertieren einer EventHubMessage in einen Batchcontainer
GetMessageDequeueTimeUtc(CachedEventHubMessage)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.
GetOffset(CachedMessage)	Abrufen des Offsets aus zwischengespeicherter Nachricht. Links zu abgeleiteter Klasse, da es nur weiß, wie dies aus der zwischengespeicherten Nachricht abgerufen werden kann.
GetPartitionKey(Guid, String)	Rufen Sie den Partitionsschlüssel für den Ereignishub ab, der für einen Stream verwendet werden soll.
GetSequenceToken(CachedEventHubMessage)	Ruft das Streamsequenztoken aus einer zwischengespeicherten Nachricht ab.
GetSequenceToken(CachedMessage)	Ruft das Streamsequenztoken aus einer zwischengespeicherten Nachricht ab.
GetStreamIdentity(EventData)	Rufen Sie die IStreamIdentity Ereignisnachricht ab.
GetStreamPosition(EventData)	Ruft die Streamposition aus einer Warteschlangennachricht ab.
GetStreamPosition(EventData)	Ruft die Streamposition aus einer Warteschlangennachricht ab.
GetStreamPosition(String, EventData)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Konvertiert eine TQueueMessage-Nachricht aus der Warteschlange in eine TCachedMessage-Cachable-Strukturen.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Konvertiert eine TQueueMessage-Nachricht aus der Warteschlange in eine TCachedMessage-Cachable-Strukturen.
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Standardereignishubdatenadapter. Benutzer können Unterklassen zum Außerkraftsetzen von Ereignisdaten zum Streamzuordnung verwenden.

Gilt für:

Freigeben über