JournaledGrain<TGrainState,TEventBase> Classe

Définition

Espace de noms:

Orleans.EventSourcing

Assembly:

Orleans.EventSourcing.dll

Paquet:

Microsoft.Orleans.EventSourcing v8.2.0

Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.

public abstract class JournaledGrain<TGrainState,TEventBase> : Orleans.EventSourcing.LogConsistentGrain<TGrainState>, Orleans.EventSourcing.ILogConsistencyProtocolParticipant, Orleans.EventSourcing.ILogViewAdaptorHost<TGrainState,TEventBase>, Orleans.IGrain where TGrainState : class, new() where TEventBase : class

type JournaledGrain<'GrainState, 'EventBase (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState) and 'EventBase : null)> = class
    inherit LogConsistentGrain<'GrainState (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState))>
    interface ILogConsistencyProtocolParticipant
    interface IGrain
    interface IAddressable
    interface ILogViewAdaptorHost<'GrainState, 'EventBase (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState) and 'EventBase : null)>
    interface IConnectionIssueListener

Public MustInherit Class JournaledGrain(Of TGrainState, TEventBase)
Inherits LogConsistentGrain(Of TGrainState)
Implements IGrain, ILogConsistencyProtocolParticipant, ILogViewAdaptorHost(Of TGrainState, TEventBase)

Paramètres de type

TGrainState

Type de l’état du grain, c’est-à-dire l’affichage agrégé du journal des événements.

TEventBase

Classe de base commune pour les événements

Héritage

Object

Grain

LogConsistentGrain<TGrainState>

JournaledGrain<TGrainState,TEventBase>

Dérivé

Orleans.EventSourcing.JournaledGrain<TGrainState>

Implémente

IGrain IAddressable IConnectionIssueListener ILogConsistencyProtocolParticipant ILogViewAdaptorHost<TGrainState,TEventBase>

Constructeurs

JournaledGrain<TGrainState,TEventBase>()

Initialise une nouvelle instance de la classe JournaledGrain<TGrainState,TEventBase>.

Propriétés

DefaultAdaptorFactory	S’il n’existe aucun fournisseur de cohérence des journaux spécifié, stockez l’état avec version à l’aide du fournisseur de stockage par défaut
GrainContext	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance. (Hérité de Grain)
GrainFactory	Obtient un objet qui peut être utilisé pour accéder à d’autres grains. Null si ce grain n’est pas associé à un runtime, par exemple lorsqu’il est créé directement pour les tests unitaires. (Hérité de Grain)
GrainReference	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance. (Hérité de Grain)
IdentityString	Représentation sous forme de chaîne du SiloIdentity du grain, y compris le type et la clé primaire. (Hérité de Grain)
RuntimeIdentity	Identificateur unique du silo actuel. Il n’existe aucun contenu sémantique pour cette chaîne, mais il peut être utile pour la journalisation. (Hérité de Grain)
ServiceProvider	Obtient l’IServiceProvider géré par le runtime. Null si ce grain n’est pas associé à un runtime, par exemple lorsqu’il est créé directement pour les tests unitaires. (Hérité de Grain)
State	Obtient l’état confirmé actuel. Inclut uniquement les événements confirmés.
TentativeState	Obtient l’état provisoire actuel. Inclut les événements confirmés et non confirmés.
UnconfirmedEvents	Retourne la file d’attente actuelle des événements non confirmés.
Version	Obtient la version de l’état confirmé actuel. Est égal au nombre total d’événements confirmés.

Méthodes

ConfirmEvents()	Attend que tous les événements précédemment déclenchés aient été confirmés. attendez cela après avoir déclenché un ou plusieurs événements, pour vous assurer que les événements sont conservés avant de continuer, ou pour garantir une cohérence forte (linéarisation) même s’il existe plusieurs instances de ce grain
DeactivateOnIdle()	Désactivez cette activation du grain une fois l’appel de la méthode graine en cours terminé. Cet appel marque cette activation du grain actuel à désactiver et à supprimer à la fin de la méthode actuelle. L’appel suivant à ce grain entraînera une activation différente à utiliser, ce qui signifie généralement qu’une nouvelle activation sera créée automatiquement par le runtime. (Hérité de Grain)
DelayDeactivation(TimeSpan)	Retarder la désactivation de cette activation au moins pendant la durée spécifiée. Une valeur timeSpan positive signifie « empêcher gc de cette activation pour cette période ». Une valeur timeSpan négative signifie « annuler le paramètre précédent de l’appel DelayDeactivation et faire en sorte que cette activation se comporte en fonction des paramètres de garbage collection d’activation standard ». La méthode DeactivateOnIdle annule / remplace tout paramètre actuel « conserver actif », ce qui rend ce grain immédiatement disponible pour la désactivation. (Hérité de Grain)
DisableStatsCollection()	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.
EnableStatsCollection()	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.
GetLogger()	Retourne un objet enregistreur d’événements que le code de ce grain peut utiliser pour le suivi. Le nom de l’enregistreur d’événements est dérivé du nom de la classe de grain. (Hérité de Grain)
GetLogger(String)	Retourne un objet enregistreur d’événements que le code de ce grain peut utiliser pour le suivi. (Hérité de Grain)
GetReminder(String)	Retourne un rappel précédemment inscrit. (Hérité de Grain)
GetReminders()	Retourne la liste de tous les rappels inscrits par le grain. (Hérité de Grain)
GetStats()	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.
GetStreamProvider(String)	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance. (Hérité de Grain)
GetStreamProviders()	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance. (Hérité de Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	Appelé juste après la construction du grain, pour installer l’adaptateur. Le fournisseur de cohérence des journaux contient une méthode de fabrique qui construit l’adaptateur avec des types choisis pour ce grain
MigrateOnIdle()	Démarre une tentative de migration de cette instance vers un autre emplacement. La migration capture le RequestContextactuel, le rendant disponible pour le directeur de placement de l’activation afin qu’il puisse le prendre en compte lors de la sélection d’un nouvel emplacement. La migration se produit de manière asynchrone, quand aucune demande n’est en cours d’exécution et ne se produit pas si le directeur de placement de l’activation ne sélectionne pas d’autre emplacement. (Hérité de Grain)
OnActivateAsync()	Cette méthode est appelée à la fin du processus d’activation d’un grain. Il est appelé avant que les messages aient été envoyés au grain. Pour les grains avec un état persistant déclaré, cette méthode est appelée après le remplissage de la propriété State. (Hérité de Grain)
OnActivateAsync(CancellationToken)	Par défaut, lors de l’activation, le grain journalisé attend qu’il ait chargé la vue la plus récente à partir du stockage. Les sous-classes peuvent remplacer ce comportement et ignorer l’attente si vous le souhaitez.
OnConnectionIssue(ConnectionIssue)	Appelé lorsque le protocole de persistance ou de réplication sous-jacent est en cours d’exécution dans une sorte de problème de connexion. Remplacez cette option pour surveiller l’intégrité du protocole de cohérence des journaux et/ou pour personnaliser les délais de nouvelle tentative. Toutes les exceptions levées sont interceptées et journalisées par le ILogViewAdaptorFactory.
OnConnectionIssueResolved(ConnectionIssue)	Appelé lorsqu’un problème de connexion signalé précédemment a été résolu. Remplacez cette option pour surveiller l’intégrité du protocole de cohérence des journaux. Toutes les exceptions levées sont interceptées et journalisées par le ILogViewAdaptorFactory.
OnDeactivateAsync()	Cette méthode est appelée au début du processus de désactivation d’un grain. (Hérité de Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	Cette méthode est appelée au début du processus de désactivation d’un grain. (Hérité de Grain)
OnStateChanged()	Appelé après la modification de l’état confirmé (c’est-à-dire que le numéro de version confirmé est plus grand). Remplacez cette option pour réagir aux modifications de l’état confirmé.
OnTentativeStateChanged()	Appelé chaque fois que l’état provisoire peut avoir changé en raison d’événements locaux ou distants. Remplacez cette option pour réagir aux modifications de l’état.
Participate(IGrainLifecycle)	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance. (Hérité de LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)	Déclenchez un événement de manière conditionnelle. Réussit uniquement s’il n’y a pas de conflit, autrement dit, aucun autre événement n’a été déclenché en attendant.
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)	Déclenchez plusieurs événements, sous la forme d’une séquence atomique, de manière conditionnelle. Réussit uniquement s’il n’y a pas de conflit, autrement dit, aucun autre événement n’a été déclenché en attendant.
RaiseEvent<TEvent>(TEvent)	Déclenche un événement.
RaiseEvents<TEvent>(IEnumerable<TEvent>)	Déclenchez plusieurs événements, sous la forme d’une séquence atomique.
RefreshNow()	Récupère l’état le plus récent maintenant et confirme tous les événements déclenchés précédemment. En fait, cela applique la synchronisation avec l’état global. Attendez cela avant de lire l’état pour garantir une cohérence forte (linéinéalisabilité) même s’il existe plusieurs instances de ce grain
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	Inscrit un rappel persistant et fiable pour envoyer des notifications régulières (rappels) au grain. Le grain doit implémenter l’interface Orleans.IRemindable, et les rappels pour ce grain seront envoyés à la méthode de rappel ReceiveReminder. Si le grain actuel est désactivé lorsque le minuteur se déclenche, une nouvelle activation de ce grain est créée pour recevoir ce rappel. Si un rappel existant portant le même nom existe déjà, ce rappel sera remplacé par ce nouveau rappel. Les rappels seront toujours reçus par une activation de ce grain, même si plusieurs activations existent pour ce grain. (Hérité de Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	Obsolète. Inscrit un minuteur pour envoyer des rappels périodiques à ce grain. (Hérité de Grain)
RetrieveConfirmedEvents(Int32, Int32)	Récupère un segment de la séquence d’événements confirmée, éventuellement à partir du stockage. Lève NotSupportedException si les événements ne sont pas disponibles en lecture. Indique si les événements sont disponibles et, pendant combien de temps, dépendent des fournisseurs utilisés et de la façon dont ils sont configurés.
TransitionState(TGrainState, TEventBase)	Définit comment appliquer des événements à l’état. À moins qu’elle ne soit remplacée dans la sous-classe, elle appelle une fonction dynamique « Apply » sur l’état, avec l’événement en tant que paramètre. Toutes les exceptions levées par cette méthode sont interceptées et journalisées par le fournisseur d’affichage des journaux. Remplacez cette option pour personnaliser la transition de l’état d’un événement donné.
UnregisterReminder(IGrainReminder)	Annule l’inscription d’un rappel précédemment inscrit. (Hérité de Grain)

Implémentations d’interfaces explicites

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)	appelé par l’adaptateur sur les problèmes de connexion.
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)	Appelé par l’adaptateur lorsqu’un problème de connexion est résolu.
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()	Notifier l’adaptateur de vue de journal de désactivation
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()	Notifier l’adaptateur de vue de journal de l’activation (appelé après onActivate au niveau de l’utilisateur)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()	Notifier l’adaptateur de vue de journal d’activation (appelé avant onActivate au niveau de l’utilisateur)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)	Appelé par l’adaptateur lors du changement d’état.
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)	Appelé par l’adaptateur pour mettre à jour la vue lorsque les entrées sont ajoutées.

Méthodes d’extension

DeactivateOnIdle(IGrainBase)	Désactivez cette activation de grain une fois l’appel de la méthode graine en cours terminé. Cet appel marque cette activation du grain actuel à désactiver et à supprimer à la fin de la méthode actuelle. L’appel suivant à ce grain entraînera une activation différente à utiliser, ce qui signifie généralement qu’une nouvelle activation sera créée automatiquement par le runtime.
MigrateOnIdle(IGrainBase)	Démarre une tentative de migration de cette instance vers un autre emplacement. La migration capture le RequestContextactuel, le rendant disponible pour le directeur de placement de l’activation afin qu’il puisse le prendre en compte lors de la sélection d’un nouvel emplacement. La migration se produit de manière asynchrone, quand aucune demande n’est en cours d’exécution et ne se produit pas si le directeur de placement de l’activation ne sélectionne pas d’autre emplacement.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, GrainTimerCreationOptions)	Crée un minuteur de grain.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, TimeSpan, TimeSpan)	Crée un minuteur de grain.
RegisterGrainTimer(IGrainBase, Func<Task>, GrainTimerCreationOptions)	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.
RegisterGrainTimer(IGrainBase, Func<Task>, TimeSpan, TimeSpan)	Crée un minuteur de grain.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, GrainTimerCreationOptions)	Crée un minuteur de grain.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, TimeSpan, TimeSpan)	Crée un minuteur de grain.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, GrainTimerCreationOptions)	Classe de base pour les grains cohérents dans les journaux à l’aide de la terminologie standard de l’approvisionnement en événements. Toutes les opérations sont sécurisées par la réentrance.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, TimeSpan, TimeSpan)	Crée un minuteur de grain.
AsReference(IAddressable, Type)	Retourne une référence typée au grain fourni.
AsReference<TGrainInterface>(IAddressable)	Retourne une référence typée au grain fourni.
Cast(IAddressable, Type)	Retourne une référence typée au grain fourni.
Cast<TGrainInterface>(IAddressable)	Retourne une référence typée au grain fourni.
GetGrainId(IAddressable)	Retourne l’ID de grain correspondant au grain fourni.
GetPrimaryKey(IAddressable)	Retourne la représentation Guid d’une clé primaire de grain.
GetPrimaryKey(IAddressable, String)	Retourne la représentation Guid d’une clé primaire de grain.
GetPrimaryKeyLong(IAddressable)	Retourne la représentation long d’une clé primaire de grain.
GetPrimaryKeyLong(IAddressable, String)	Retourne la représentation long d’une clé primaire de grain.
GetPrimaryKeyString(IAddressable)	Retourne la string clé primaire du grain.
IsPrimaryKeyBasedOnLong(IAddressable)	Retourne si une partie de la clé primaire est de type long.
GetReminder(Grain, String)	Retourne un rappel précédemment inscrit.
GetReminder(IGrainBase, String)	Retourne un rappel précédemment inscrit.
GetReminders(Grain)	Retourne la liste de tous les rappels inscrits par le grain.
GetReminders(IGrainBase)	Retourne la liste de tous les rappels inscrits par le grain.
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	Inscrit un rappel persistant et fiable pour envoyer des notifications régulières (rappels) au grain. Le grain doit implémenter l’interface Orleans.IRemindable, et les rappels pour ce grain seront envoyés à la méthode de rappel ReceiveReminder. Si le grain actuel est désactivé lorsque le minuteur se déclenche, une nouvelle activation de ce grain est créée pour recevoir ce rappel. Si un rappel existant portant le même nom existe déjà, ce rappel sera remplacé par ce nouveau rappel. Les rappels seront toujours reçus par une activation de ce grain, même si plusieurs activations existent pour ce grain.
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	Inscrit un rappel persistant et fiable pour envoyer des notifications régulières (rappels) au grain. Le grain doit implémenter l’interface Orleans.IRemindable, et les rappels pour ce grain seront envoyés à la méthode de rappel ReceiveReminder. Si le grain actuel est désactivé lorsque le minuteur se déclenche, une nouvelle activation de ce grain est créée pour recevoir ce rappel. Si un rappel existant portant le même nom existe déjà, ce rappel sera remplacé par ce nouveau rappel. Les rappels seront toujours reçus par une activation de ce grain, même si plusieurs activations existent pour ce grain.
UnregisterReminder(Grain, IGrainReminder)	Annule l’inscription d’un rappel précédemment inscrit.
UnregisterReminder(IGrainBase, IGrainReminder)	Annule l’inscription d’un rappel précédemment inscrit.
GetStreamProvider(Grain, String)	Obtient le fournisseur de flux avec le namespécifié.
GetStreamProvider(IGrainBase, String)	Obtient le fournisseur de flux avec le namespécifié.