IEventHubQueueCache 接口

定义

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

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
派生
实现

方法

Add(List<EventData>, DateTime)

将 EventHub EventData 列表添加到缓存。

Add(List<EventData>, DateTime)

将 EventHub EventData 列表添加到缓存。

Add(List<EventData>, DateTime)

将 EventHub EventData 列表添加到缓存。

AddCachePressureMonitor(ICachePressureMonitor)

将缓存压力监视器添加到缓存的背压算法

GetCursor(IStreamIdentity, StreamSequenceToken)

将游标获取到缓存中,以从流中读取事件。

GetMaxAddCount()

获取可添加的最大项数。

(继承自 IQueueFlowController)
SignalPurge()

向缓存发送清除信号,缓存将对其缓存的消息执行基于时间的清除

TryGetNextMessage(Object, IBatchContainer)

尝试获取所提供游标的缓存中的下一条消息。

适用于