GeneratorAdapterFactory Classe

Définition

Espace de noms:

Orleans.Providers.Streams.Generator

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

Fabrique d’adaptateurs pour le fournisseur de flux de générateur de flux. Cette fabrique fait office d’adaptateur et de fabrique d’adaptateur. Il crée des récepteurs qui utilisent un générateur configurable pour générer des flux d’événements, au lieu de les lire à partir du stockage.

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

Héritage

Object

GeneratorAdapterFactory

Implémente

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructeurs

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

Fabrique d’adaptateurs pour le fournisseur de flux de générateur de flux. Cette fabrique fait office d’adaptateur et de fabrique d’adaptateur. Il crée des récepteurs qui utilisent un générateur configurable pour générer des flux d’événements, au lieu de les lire à partir du stockage.

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. À partir de IQueueAdapter.

Méthodes

Create(IServiceProvider, String)	Crée une instance GeneratorAdapterFactory.
CreateAdapter()	Créer un adaptateur
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é
ExecuteCommand(Int32, Object)	Fonction permettant d’exécuter une commande de contrôle.
GetDeliveryFailureHandler(QueueId)	Obtenir le gestionnaire d’échec de remise
GetQueueAdapterCache()	Obtenir l’adaptateur de cache
GetStreamQueueMapper()	Obtenir le mappeur de file d’attente de flux
Init()	Initialise la fabrique.
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.