MemoryAdapterFactory<TSerializer> Classe

Definizione

Spazio dei nomi:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Adapter factory per nel provider di flusso di memoria. Questa factory funge da adattatore e dalla factory dell'adattatore. Gli eventi vengono archiviati in un granularità in memoria che si comporta come una coda di eventi, questa scheda provider viene usata principalmente per il test

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

Parametri di tipo

TSerializer

Ereditarietà

Object

MemoryAdapterFactory<TSerializer>

Implementazioni

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Costruttori

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

Adapter factory per nel provider di flusso di memoria. Questa factory funge da adattatore e dalla factory dell'adattatore. Gli eventi vengono archiviati in un granularità in memoria che si comporta come una coda di eventi, questa scheda provider viene usata principalmente per il test

Campi

BlockPoolMonitorFactory	Creare un monitoraggio del pool di blocchi per monitorare le metriche correlate al pool di blocchi Restituisce un oggetto IBlockPoolMonitor
CacheMonitorFactory	Creare un monitoraggio della cache per segnalare le metriche correlate alla cache Restituisce un ICacheMonitor
ReceiverMonitorFactory	Creare un monitoraggio per monitorare le metriche correlate a QueueAdapterReceiver Return a IQueueAdapterReceiverMonitor

Proprietà

Direction	Direzione di questa scheda di coda: lettura, scrittura o lettura.
IsRewindable	Determina se si tratta di un adattatore di flusso riavvolgibile: supporta la sottoscrizione dal momento precedente.
Name	Nome dell'adapter. Principalmente per scopi di registrazione
StreamFailureHandlerFactory	Crea un gestore di errori per una partizione.

Metodi

Create(IServiceProvider, String)	Crea una nuova istanza di MemoryAdapterFactory<TSerializer>.
CreateAdapter()	Creare l'adattatore della coda.
CreateQueueCache(QueueId)	Creare una cache per un ID coda specificato
CreateReceiver(QueueId)	Crea un ricevitore della coda per l'id coda specificato
GetDeliveryFailureHandler(QueueId)	Acquisire il gestore degli errori di recapito per una coda
GetQueueAdapterCache()	Creare l'adapter della cache dei messaggi della coda
GetStreamQueueMapper()	Creare il mapper della coda
Init()	Inizializza l'istanza corrente.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Scrive un set di eventi nella coda come singolo batch associato all'oggetto streamId specificato.

Metodi di estensione

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

Scrive un set di eventi nella coda come singolo batch associato all'oggetto specificato streamId.