EventHubQueueCache<TCachedMessage> 类

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v2.4.5

EventHub 队列缓存，允许开发人员提供自己的缓存数据结构。

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

类型参数

TCachedMessage

继承

Object

EventHubQueueCache<TCachedMessage>

派生

Orleans.ServiceBus.Providers.EventHubQueueCache

实现

IEventHubQueueCache IQueueFlowController IDisposable

构造函数

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

构造 EventHub 队列缓存。

字段

cache	基础消息缓存实现
defaultMaxAddCount	在清除调用之间可以添加到缓存的默认最大项数

属性

Checkpointer

用于存储队列位置的逻辑

方法

Add(List<EventData>, DateTime)	将 EventHub EventData 列表添加到缓存。
AddCachePressureMonitor(ICachePressureMonitor)	将缓存压力监视器添加到缓存的背压算法
Dispose()	执行与释放或重置非托管资源关联的应用程序定义的任务。
GetCursor(IStreamIdentity, StreamSequenceToken)	将游标获取到缓存中，以从流中读取事件。
GetMaxAddCount()	可添加的最大项数限制
GetOffset(TCachedMessage)	获取缓存消息的偏移量。 留给派生类，因为只有它知道如何从缓存的消息中获取此内容。
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	处理缓存清除信号
SignalPurge()	向缓存发送清除信号，缓存将对其缓存的消息执行基于时间的清除
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution 应为介于 0-1 之间的双精度值，指示从缓存中删除项的危险程度。 0 表示没有危险，1 表示即将移除。
TryGetNextMessage(Object, IBatchContainer)	尝试获取所提供游标的缓存中的下一条消息。