MemoryAdapterFactory<TSerializer> Klasse

Definition

Namespace:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Paket:

Microsoft.Orleans.Streaming v8.2.0

Adapter factory for in memory stream provider. Diese Factory fungiert als Adapter und Adapterfactory. Die Ereignisse werden in einem In-Memory-Grain gespeichert, das sich als Ereigniswarteschlange verhält. Dieser Anbieteradapter wird hauptsächlich für Tests verwendet.

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

Typparameter

TSerializer

Vererbung

Object

MemoryAdapterFactory<TSerializer>

Implementiert

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Konstruktoren

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

Adapter factory for in memory stream provider. Diese Factory fungiert als Adapter und Adapterfactory. Die Ereignisse werden in einem In-Memory-Grain gespeichert, das sich als Ereigniswarteschlange verhält. Dieser Anbieteradapter wird hauptsächlich für Tests verwendet.

Felder

BlockPoolMonitorFactory	Erstellen eines Blockpoolmonitors zum Überwachen blockpoolbezogener 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 wieder aufwickelbaren Streamadapter handelt: Unterstützt das Abonnieren von einem vorherigen Zeitpunkt.
Name	Der Name des Adapters. In erster Linie für Protokollierungszwecke
StreamFailureHandlerFactory	Erstellt einen Fehlerhandler für eine Partition.

Methoden

Create(IServiceProvider, String)	Erstellt eine neue MemoryAdapterFactory<TSerializer>-Instanz.
CreateAdapter()	Erstellen Sie einen Warteschlangenadapter.
CreateQueueCache(QueueId)	Erstellen eines Caches für eine bestimmte Warteschlangen-ID
CreateReceiver(QueueId)	Erstellt einen Warteschlangenempfänger für die angegebene queueId
GetDeliveryFailureHandler(QueueId)	Abrufen des Übermittlungsfehlerhandlers für eine Warteschlange
GetQueueAdapterCache()	Erstellen eines Cacheadapters für Warteschlangennachrichten
GetStreamQueueMapper()	Erstellen eines Warteschlangenzuordnungsers
Init()	Initialisiert diese Instanz.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Schreibt einen Satz 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 einen Satz von Ereignissen in die Warteschlange als einzelnen Batch, der dem bereitgestellten streamIdzugeordnet ist.