EventHubQueueCache<TCachedMessage> 클래스
정의
중요
일부 정보는 릴리스되기 전에 상당 부분 수정될 수 있는 시험판 제품과 관련이 있습니다. Microsoft는 여기에 제공된 정보에 대해 어떠한 명시적이거나 묵시적인 보증도 하지 않습니다.
개발자가 자체 캐시된 데이터 구조를 제공할 수 있도록 하는 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>
- 파생
- 구현
생성자
필드
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 사이의 이중이어야 합니다. 위험 없음을 나타내는 0, 제거가 임박했음을 나타내는 1입니다. |
TryGetNextMessage(Object, IBatchContainer) |
제공된 커서에 대한 캐시의 다음 메시지를 가져옵니다. |