EventHubQueueCache 类

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubQueueCache.cs

将 EventData 作为 CachedEventHubMessage 存储在共用消息缓存中的消息缓存

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

继承

Object

EventHubQueueCache

实现

IEventHubQueueCache IQueueFlowController IDisposable

构造函数

EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

EventHub 队列缓存。

字段

cache

基础消息缓存实现 出于测试目的受保护

属性

Partition

将 EventData 作为 CachedEventHubMessage 存储在共用消息缓存中的消息缓存

方法

Add(List<EventData>, DateTime)	将 EventHub EventData 列表添加到缓存。
AddCachePressureMonitor(ICachePressureMonitor)	将缓存压力监视器添加到缓存的背压算法
Dispose()	执行与释放或重置非托管资源关联的应用程序定义的任务。
GetCursor(IStreamIdentity, StreamSequenceToken)	将游标获取到缓存中，以从流中读取事件。
GetMaxAddCount()	可添加的最大项数的限制
SignalPurge()	向缓存发送清除信号，缓存将对其缓存的消息执行基于时间的清除
TryGetNextMessage(Object, IBatchContainer)	尝试在缓存中获取提供的游标的下一条消息。