다음을 통해 공유

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
Source:
EventHubQueueCache.cs

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 사이의 이중이어야 합니다. 위험 없음을 나타내는 0, 제거가 임박했음을 나타내는 1입니다.
TryGetNextMessage(Object, IBatchContainer)

제공된 커서에 대한 캐시의 다음 메시지를 가져옵니다.
TryGetNextMessage(Object, IBatchContainer)

제공된 커서에 대한 캐시의 다음 메시지를 가져옵니다.

(다음에서 상속됨 EventHubQueueCache<TCachedMessage>)

적용 대상