GeneratorAdapterFactory Klasse

Definition

Namespace:

Orleans.Providers.Streams.Generator

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.1.0

Adapterfactory für stream generator stream provider. Diese Factory fungiert als Adapter und Adapterfactory. Es erstellt Empfänger, die einen konfigurierbaren Generator verwenden, um Ereignisdatenströme zu generieren, anstatt sie aus dem Speicher zu lesen.

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

Vererbung

Object

GeneratorAdapterFactory

Implementiert

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Konstruktoren

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

Adapterfactory für stream generator stream provider. Diese Factory fungiert als Adapter und Adapterfactory. Es erstellt Empfänger, die einen konfigurierbaren Generator verwenden, um Ereignisdatenströme zu generieren, anstatt sie aus dem Speicher zu lesen.

Felder

BlockPoolMonitorFactory	Erstellen eines Blockpoolmonitors zum Überwachen von Blockpool-bezogenen Metriken Zurückgeben eines IBlockPoolMonitors
CacheMonitorFactory	Erstellen eines Cachemonitors zum Melden cachebezogener Metriken Zurückgeben eines ICacheMonitors
ReceiverMonitorFactory	Erstellen eines Monitors zum Überwachen von QueueAdapterReceiver-bezogenen Metriken Zurückgeben eines IQueueAdapterReceiverMonitors

Eigenschaften

Direction	Richtung dieses Warteschlangenadapters: Read, Write oder ReadWrite.
IsRewindable	Bestimmt, ob es sich um einen wiederwickelbaren Streamadapter handelt– unterstützt das Abonnieren vom vorherigen Zeitpunkt.
Name	Der Name des Adapters. Von IQueueAdapter.

Methoden

Create(IServiceProvider, String)	Erstellt eine neue GeneratorAdapterFactory-Instanz.
CreateAdapter()	Erstellen eines Adapters
CreateQueueCache(QueueId)	Erstellen eines Caches für eine angegebene Warteschlangen-ID
CreateReceiver(QueueId)	Erstellt einen Warteschlangenempfänger für die angegebene queueId.
ExecuteCommand(Int32, Object)	Eine Funktion zum Ausführen eines Steuerelementbefehls.
GetDeliveryFailureHandler(QueueId)	Abrufen des Übermittlungsfehlerhandlers
GetQueueAdapterCache()	Abrufen des Cacheadapters
GetStreamQueueMapper()	Abrufen der Streamwarteschlangenzuordnung
Init()	Initialisiert die Factory.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Schreibt eine Reihe von Ereignissen in die Warteschlange als einzelnen Batch, der der bereitgestellten streamId zugeordnet ist.

Erweiterungsmethoden

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

Schreibt eine Reihe von Ereignissen in die Warteschlange als einzelnen Batch, der dem bereitgestellten streamIdzugeordnet ist.