GeneratorAdapterFactory Classe

Definizione

Spazio dei nomi:

Orleans.Providers.Streams.Generator

Assembly:

Orleans.Streaming.dll

Pacchetto:

Microsoft.Orleans.Streaming v8.2.0

Factory dell'adattatore per il provider di flusso del generatore di flusso. Questa factory funge da adattatore e dalla factory dell'adattatore. Crea ricevitori che usano un generatore configurabile per generare flussi di eventi, anziché leggerli dall'archiviazione.

public class GeneratorAdapterFactory : Orleans.Providers.IControllable, Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type GeneratorAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache
    interface IControllable

Public Class GeneratorAdapterFactory
Implements IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Ereditarietà

Object

GeneratorAdapterFactory

Implementazioni

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Costruttori

GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

Factory dell'adattatore per il provider di flusso del generatore di flusso. Questa factory funge da adattatore e dalla factory dell'adattatore. Crea ricevitori che usano un generatore configurabile per generare flussi di eventi, anziché leggerli dall'archiviazione.

Campi

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

Proprietà

Direction	Direzione dell'adapter della coda: lettura, scrittura o letturaWrite.
IsRewindable	Determina se si tratta di un adattatore di flusso riavvolgibile: supporta la sottoscrizione dal momento precedente.
Name	Nome dell'adapter. Da IQueueAdapter.

Metodi

Create(IServiceProvider, String)	Crea una nuova istanza di GeneratorAdapterFactory.
CreateAdapter()	Creare un adattatore
CreateQueueCache(QueueId)	Creare una cache per un ID della coda specificato
CreateReceiver(QueueId)	Crea un ricevitore della coda per l'id coda specificato
ExecuteCommand(Int32, Object)	Funzione per eseguire un comando di controllo.
GetDeliveryFailureHandler(QueueId)	Ottenere il gestore degli errori di recapito
GetQueueAdapterCache()	Ottenere l'adapter della cache
GetStreamQueueMapper()	Ottenere il mapper della coda di flusso
Init()	Inizializza la factory.
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.