MemoryAdapterFactory<TSerializer> Classe

Définition

Espace de noms:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

Fabrique d’adaptateurs pour dans le fournisseur de flux de mémoire. Cette fabrique fait office d’adaptateur et de fabrique d’adaptateur. Les événements sont stockés dans un grain en mémoire qui se comporte comme une file d’attente d’événements. Cet adaptateur de fournisseur est principalement utilisé pour les tests

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

Paramètres de type

TSerializer

Héritage

Object

MemoryAdapterFactory<TSerializer>

Implémente

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructeurs

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

Fabrique d’adaptateurs pour dans le fournisseur de flux de mémoire. Cette fabrique fait office d’adaptateur et de fabrique d’adaptateur. Les événements sont stockés dans un grain en mémoire qui se comporte comme une file d’attente d’événements. Cet adaptateur de fournisseur est principalement utilisé pour les tests

Champs

BlockPoolMonitorFactory	Créer un moniteur de pool de blocs pour surveiller les métriques liées au pool de blocs Renvoyer un IBlockPoolMonitor
CacheMonitorFactory	Créer un moniteur de cache pour signaler les métriques liées au cache Renvoyer un ICacheMonitor
ReceiverMonitorFactory	Créer un moniteur pour surveiller les métriques liées à QueueAdapterReceiver Renvoyer un IQueueAdapterReceiverMonitor

Propriétés

Direction	Direction de cet adaptateur de file d’attente : Read, Write ou ReadWrite.
IsRewindable	Détermine s’il s’agit d’un adaptateur de flux rembobinable : prend en charge l’abonnement à partir d’un point précédent dans le temps.
Name	Nom de l'adaptateur. Principalement à des fins de journalisation
StreamFailureHandlerFactory	Crée un gestionnaire d’échecs pour une partition.

Méthodes

Create(IServiceProvider, String)	Crée une instance MemoryAdapterFactory<TSerializer>.
CreateAdapter()	Créez un adaptateur de file d’attente.
CreateQueueCache(QueueId)	Créer un cache pour un ID de file d’attente donné
CreateReceiver(QueueId)	Crée un récepteur de file d’attente pour l’id de file d’attente spécifié
GetDeliveryFailureHandler(QueueId)	Acquérir le gestionnaire d’échec de remise pour une file d’attente
GetQueueAdapterCache()	Créer un adaptateur de cache de messages de file d’attente
GetStreamQueueMapper()	Créer un mappeur de file d’attente
Init()	Initialise cette instance.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Écrit un ensemble d’événements dans la file d’attente sous la forme d’un lot unique associé au streamId fourni.

Méthodes d’extension

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

Écrit un ensemble d’événements dans la file d’attente sous la forme d’un lot unique associé au fourni streamId.