MemoryAdapterFactory<TSerializer> 클래스

정의

네임스페이스:

Orleans.Providers

어셈블리:

Orleans.Streaming.dll

패키지:

Microsoft.Orleans.Streaming v8.2.0

메모리 스트림 공급자에 대한 어댑터 팩터리입니다. 이 팩터리는 어댑터 및 어댑터 팩터리 역할을 합니다. 이벤트는 이벤트 큐로 작동하는 메모리 내 조직에 저장되며, 이 공급자 어댑터는 주로 테스트에 사용됩니다.

public class MemoryAdapterFactory<TSerializer> : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory where TSerializer : class, IMemoryMessageBodySerializer

type MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

형식 매개 변수

TSerializer

상속

Object

MemoryAdapterFactory<TSerializer>

구현

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

생성자

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)

메모리 스트림 공급자에 대한 어댑터 팩터리입니다. 이 팩터리는 어댑터 및 어댑터 팩터리 역할을 합니다. 이벤트는 이벤트 큐로 작동하는 메모리 내 조직에 저장되며, 이 공급자 어댑터는 주로 테스트에 사용됩니다.

필드

BlockPoolMonitorFactory	블록 풀 관련 메트릭을 모니터링하는 블록 풀 모니터 만들기 IBlockPoolMonitor 반환
CacheMonitorFactory	캐시 관련 메트릭을 보고하는 캐시 모니터 만들기 ICacheMonitor 반환
ReceiverMonitorFactory	QueueAdapterReceiver 관련 메트릭을 모니터링하는 모니터 만들기 IQueueAdapterReceiverMonitor 반환

속성

Direction	이 큐 어댑터의 방향: 읽기, 쓰기 또는 읽기Write.
IsRewindable	되감기 가능한 스트림 어댑터인지 여부를 확인합니다. 이전 시점의 구독을 지원합니다.
Name	어댑터 이름입니다. 주로 로깅용
StreamFailureHandlerFactory	파티션에 대한 오류 처리기를 만듭니다.

메서드

Create(IServiceProvider, String)	새 MemoryAdapterFactory<TSerializer> 인스턴스를 만듭니다.
CreateAdapter()	큐 어댑터를 만듭니다.
CreateQueueCache(QueueId)	지정된 큐 ID에 대한 캐시 만들기
CreateReceiver(QueueId)	지정된 queueId에 대한 큐 수신기를 만듭니다.
GetDeliveryFailureHandler(QueueId)	큐에 대한 배달 실패 처리기 획득
GetQueueAdapterCache()	큐 메시지 캐시 어댑터 만들기
GetStreamQueueMapper()	큐 매퍼 만들기
Init()	인스턴스를 초기화합니다.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	제공된 streamId와 연결된 단일 일괄 처리로 이벤트 집합을 큐에 씁니다.

확장 메서드

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

제공 streamId된 와 연결된 단일 일괄 처리로 이벤트 집합을 큐에 씁니다.