EventHubDataAdapter 类

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubDataAdapter.cs

默认事件中心数据适配器。 用户可以将事件数据重写到流映射的子类。

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.ServiceBus.Providers.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)

继承

Object

EventHubDataAdapter

实现

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

构造函数

EventHubDataAdapter(SerializationManager)

缓存数据适配器，使 EventHub 的 EventData 适应缓存中使用的 CachedEventHubMessage

方法

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	默认事件中心数据适配器。 用户可以将事件数据重写到流映射的子类。
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	默认事件中心数据适配器。 用户可以将事件数据重写到流映射的子类。
GetBatchContainer(CachedMessage)	将缓存的消息转换为用于传递的批处理容器
GetBatchContainer(EventHubMessage)	将 EventHubMessage 转换为批处理容器
GetOffset(CachedMessage)	获取缓存消息的偏移量。 左到派生类，因为它只知道如何从缓存的消息中获取此消息。
GetPartitionKey(Guid, String)	获取事件中心分区键以用于流。
GetSequenceToken(CachedMessage)	从缓存的消息中获取流序列令牌。
GetStreamIdentity(EventData)	IStreamIdentity获取事件消息。
GetStreamPosition(String, EventData)	默认事件中心数据适配器。 用户可以将事件数据重写到流映射的子类。
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	默认事件中心数据适配器。 用户可以将事件数据重写到流映射的子类。