EventHubQueueCache クラス

定義

名前空間:

Orleans.Streaming.EventHubs

アセンブリ:

Orleans.Streaming.EventHubs.dll

パッケージ:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

EventHub キュー キャッシュ

public class EventHubQueueCache : IDisposable, Orleans.Streaming.EventHubs.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

EventHub キュー キャッシュ

メソッド

Add(List<EventData>, DateTime)	EventHub EventData の一覧をキャッシュに追加します。
AddCachePressureMonitor(ICachePressureMonitor)	キャッシュの背圧アルゴリズムにキャッシュ圧力モニターを追加する
Dispose()	アンマネージ リソースの解放またはリセットに関連付けられているアプリケーション定義のタスクを実行します。
GetCursor(StreamId, StreamSequenceToken)	ストリームからイベントを読み取るために、キャッシュにカーソルを取得します。
GetMaxAddCount()	追加できるアイテムの最大数の制限
SignalPurge()	キャッシュに消去シグナルを送信すると、キャッシュはキャッシュされたメッセージに基づいて時間ベースの消去を実行します
TryGetNextMessage(Object, IBatchContainer)	指定されたカーソルの次のメッセージをキャッシュに取得してみてください。