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 の間の double にする必要があります。 0は危険がないことを示し、1は除去が差し迫っているを示す。
TryGetNextMessage(Object, IBatchContainer)	指定されたカーソルの次のメッセージをキャッシュに取得してみてください。