EventHubAdapterFactory Classe

Definizione

Spazio dei nomi:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Pacchetto:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Origine:

EventHubAdapterFactory.cs

Factory dell'adapter di accodamento 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

Derivato

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

Implementazioni

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Costruttori

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

Factory dell'adapter di accodamento 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 dell'adattatore di 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. Principalmente a scopo di registrazione
QueueMapperFactory	Creare un mapper della coda per eseguire il mapping delle partizioni di EventHub alle code
ReceiverMonitorFactory	Creare un monitoraggio ricevitore per segnalare le metriche delle prestazioni. Il funciton factory deve restituire un IEventHubReceiverMonitor.
SerializationManager	Ottiene il gestore di serializzazione.
StreamFailureHandlerFactory	Crea un gestore errori per una partizione.

Metodi

Create(IServiceProvider, String)	Factory dell'adapter di accodamento che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
CreateAdapter()	Creare l'adattatore di coda.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Creare un oggetto IEventHubQueueCacheFactory. Creerà un EventHubQueueCacheFactory per impostazione predefinita. L'utente può eseguire l'override di questa funzione per restituire la propria implementazione di IEventHubQueueCacheFactory e altre personalizzazioni di IEventHubQueueCacheFactory, se possibile.
CreateQueueCache(QueueId)	Creare una cache per un ID coda specificato
CreateReceiver(QueueId)	Crea un ricevitore di accodamento per l'id coda specifico
GetDeliveryFailureHandler(QueueId)	Gestore degli errori di recapito di Aquire per una coda
GetPartitionIdsAsync()	Ottenere gli ID partizione da EventHub
GetQueueAdapterCache()	Creare l'adattatore cache dei messaggi della coda
GetStreamQueueMapper()	Creare un mapper della coda
Init()	Factory dell'adapter di accodamento che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
InitEventHubClient()	Factory dell'adapter di accodamento che consente a PersistentStreamProvider di usare EventHub come coda di eventi persistente back-end.
QueueMessageBatchAsync<T>(Guid, String, 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, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

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