EventHubQueueCache<TCachedMessage> クラス

定義

開発者が独自のキャッシュされたデータ構造を提供できるようにする 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
継承
EventHubQueueCache<TCachedMessage>
派生
実装

コンストラクター

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

EventHub キュー キャッシュを構築します。

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

EventHub キュー キャッシュを構築します。

フィールド

cache

基になるメッセージ キャッシュの実装

defaultMaxAddCount

消去呼び出しの間にキャッシュに追加できる項目の既定の最大数

プロパティ

Checkpointer

キューの位置を格納するために使用されるロジック

メソッド

Add(List<EventData>, DateTime)

EventHub EventData の一覧をキャッシュに追加します。

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 の間の double にする必要があります。 0は危険がないことを示し、1は除去が差し迫っているを示す。

TryGetNextMessage(Object, IBatchContainer)

指定されたカーソルの次のメッセージをキャッシュに取得してみてください。

適用対象