EventHubAdapterFactory Classe

Definizione

Spazio dei nomi:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacchetto:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Factory dell'adapter di coda che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Ereditarietà

Object

EventHubAdapterFactory

Implementazioni

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Costruttori

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

Factory dell'adapter di coda che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.

Campi

dataAdapter	Adattatore dati
EventHubReceiverFactory	Factory per creare un IEventHubReceiver
logger	Registrazione di Orleans
serviceProvider	Provider di servizi framework

Proprietà

CacheFactory	Crea una cache dei messaggi per una partizione eventhub.
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
QueueMapperFactory	Create un mapper della coda per eseguire il mapping delle partizioni di EventHub alle code
ReceiverMonitorFactory	Create un monitoraggio ricevitore per segnalare le metriche delle prestazioni. La funzione Factory deve restituire un oggetto IEventHubReceiverMonitor.
StreamFailureHandlerFactory	Crea un gestore di errori per una partizione.

Metodi

Create(IServiceProvider, String)	Factory dell'adapter di coda che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
CreateAdapter()	Create scheda coda.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create un oggetto IEventHubQueueCacheFactory. Creerà un oggetto EventHubQueueCacheFactory per impostazione predefinita. Se possibile, l'utente può eseguire l'override di questa funzione per restituire la propria implementazione di IEventHubQueueCacheFactory e altre personalizzazioni di IEventHubQueueCacheFactory.
CreateQueueCache(QueueId)	Create 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
GetPartitionIdsAsync()	Ottenere id di partizione da eventhub
GetQueueAdapterCache()	scheda della cache dei messaggi della coda Create
GetStreamQueueMapper()	Create mapper della coda
Init()	Factory dell'adapter di coda che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
InitEventHubClient()	Factory dell'adapter di coda che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
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.