EventHubQueueCache クラス

リファレンス

定義

名前空間:: Orleans.ServiceBus.Providers

アセンブリ:: OrleansServiceBus.dll

アセンブリ:: Orleans.Streaming.EventHubs.dll

パッケージ:: Microsoft.Orleans.OrleansServiceBus v1.5.10

パッケージ:: Microsoft.Orleans.OrleansServiceBus v2.4.5

パッケージ:: Microsoft.Orleans.OrleansServiceBus v3.6.5

ソース:: EventHubQueueCache.cs

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

EventData を CachedEventHubMessage としてプールされたメッセージキャッシュに格納するメッセージキャッシュ

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

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

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

継承: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

継承: Object
EventHubQueueCache

実装: IEventHubQueueCache IQueueFlowController IDisposable

コンストラクター

EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	カスタムデータアダプターを指定してキャッシュを構築します。
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	カスタムデータアダプターを指定してキャッシュを構築します。
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	カスタムデータアダプターを指定してキャッシュを構築します。
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	カスタムデータアダプターを指定してキャッシュを構築します。
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	バッファープールを指定してキャッシュを構築します。既定のデータアダプターを使用します
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	バッファープールを指定してキャッシュを構築します。既定のデータアダプターを使用します
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)	EventHub キューキャッシュ。

フィールド

cache	基になるメッセージキャッシュの実装テスト目的で保護
cache	基になるメッセージキャッシュの実装 (継承元 EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	消去呼び出しの間にキャッシュに追加できる項目の既定の最大数 (継承元 EventHubQueueCache<TCachedMessage>)

プロパティ

Checkpointer	キューの位置を格納するために使用されるロジック (継承元 EventHubQueueCache<TCachedMessage>)
Partition	EventData を CachedEventHubMessage としてプールされたメッセージキャッシュに格納するメッセージキャッシュ

メソッド

Add(List<EventData>, DateTime)	EventHub EventData の一覧をキャッシュに追加します。
Add(List<EventData>, DateTime)	EventHub EventData の一覧をキャッシュに追加します。 (継承元 EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)	EventHub EventData の一覧をキャッシュに追加します。 (継承元 EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)	キャッシュの背圧アルゴリズムにキャッシュ圧力モニターを追加する
AddCachePressureMonitor(ICachePressureMonitor)	キャッシュの背圧アルゴリズムにキャッシュ圧力モニターを追加する (継承元 EventHubQueueCache<TCachedMessage>)
Dispose()	アンマネージリソースの解放またはリセットに関連付けられているアプリケーション定義のタスクを実行します。
Dispose()	アンマネージリソースの解放またはリセットに関連付けられているアプリケーション定義のタスクを実行します。 (継承元 EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)	ストリームからイベントを読み取るために、キャッシュにカーソルを取得します。
GetCursor(IStreamIdentity, StreamSequenceToken)	ストリームからイベントを読み取るために、キャッシュにカーソルを取得します。 (継承元 EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()	追加できるアイテムの最大数の制限
GetMaxAddCount()	追加できるアイテムの最大数の制限 (継承元 EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)	キャッシュされたメッセージからのオフセットを取得します。キャッシュされたメッセージからこれを取得する方法のみが認識されるため、派生クラスに任されます。
GetOffset(TCachedMessage)	キャッシュされたメッセージからのオフセットを取得します。キャッシュされたメッセージからこれを取得する方法のみが認識されるため、派生クラスに任されます。 (継承元 EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)	キャッシュ消去シグナルを処理します
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	キャッシュ消去シグナルを処理します (継承元 EventHubQueueCache<TCachedMessage>)
SignalPurge()	キャッシュに消去シグナルを送信すると、キャッシュはキャッシュされたメッセージに基づいて時間ベースの消去を実行します
SignalPurge()	キャッシュに消去シグナルを送信すると、キャッシュはキャッシュされたメッセージに基づいて時間ベースの消去を実行します (継承元 EventHubQueueCache<TCachedMessage>)
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution は、アイテムがキャッシュから削除される危険性を示す、0 から 1 の間の double にする必要があります。 0は危険がないことを示し、1は除去が差し迫っているを示す。
TryGetNextMessage(Object, IBatchContainer)	指定されたカーソルの次のメッセージをキャッシュに取得してみてください。
TryGetNextMessage(Object, IBatchContainer)	指定されたカーソルの次のメッセージをキャッシュに取得してみてください。 (継承元 EventHubQueueCache<TCachedMessage>)

適用対象

次の方法で共有

EventHubQueueCache クラス

定義

コンストラクター

フィールド

プロパティ

メソッド

適用対象

その他のリソース