IEventHubQueueCache 接口

定义

命名空间:

Orleans.Streaming.EventHubs

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

存储 EventHub EventData 的流消息缓存的接口

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController

type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable

Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController

派生

Orleans.Streaming.EventHubs.EventHubQueueCache

实现

IQueueFlowController IDisposable

方法

Add(List<EventData>, DateTime)	将 EventHub EventData 列表添加到缓存。
AddCachePressureMonitor(ICachePressureMonitor)	将缓存压力监视器添加到缓存的背压算法
GetCursor(StreamId, StreamSequenceToken)	将游标获取到缓存中，以从流中读取事件。
GetMaxAddCount()	获取可添加的最大项数。 (继承自 IQueueFlowController)
SignalPurge()	向缓存发送清除信号，缓存将对其缓存的消息执行基于时间的清除
TryGetNextMessage(Object, IBatchContainer)	尝试在缓存中获取提供的游标的下一条消息。