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)	제공된 커서에 대한 캐시의 다음 메시지를 가져옵니다.