Partager via


Orleans.EventSourcing.Common Espace de noms

Classes

BatchedNotificationMessage

Message de notification contenant un lot de messages de notification.

NotificationFailed

Décrit un problème de connexion qui s’est produit lors de l’envoi de notifications de mise à jour à des instances distantes.

PrimaryBasedLogViewAdaptor<TLogView,TLogEntry,TSubmissionEntry>

Modèle général pour la construction d’adaptateurs de vue de journal basés sur une source de lecture et d’écriture séquentielle. Nous l’utilisons pour construire différents fournisseurs de cohérence des journaux, tous suivant le même modèle de base (lecture et écriture de la vue la plus récente depuis/vers le serveur principal, et envoi de notifications après l’écriture).

Notez que le journal lui-même est temporaire, c’est-à-dire qu’il n’est pas réellement enregistré dans le stockage : seules la vue la plus récente et certaines métadonnées (la position du journal et les indicateurs d’écriture) sont stockées dans le fichier principal. Il est sûr d’entrelacer les appels à cet adaptateur (à l’aide du planificateur de grain uniquement, bien sûr).

Les sous-classes remplacent ReadAsync et WriteAsync pour lire/écrire vers principal. Les appels au serveur principal sont sérialisés, c’est-à-dire jamais entrelacés.

PrimaryOperationFailed

Décrit un problème de connexion qui s’est produit lors de la communication avec le stockage principal.

StringEncodedWriteVector
SubmissionEntry<TLogEntry>

Classe de base pour les entrées de soumission stockées dans la file d’attente.

VersionNotificationMessage

Message de notification simple contenant uniquement la version.

Structures

RecordedConnectionIssue

Classe utilitaire pour l’enregistrement des problèmes de connexion. Il est public, et non interne, car il s’agit d’un bloc de construction utile pour implémenter d’autres fournisseurs de cohérence.

Interfaces

INotificationMessage

Classe de base pour les messages de notification qui sont envoyés par les adaptateurs de vue de journal à d’autres clusters, après la mise à jour du journal. Toutes les sous-classes doivent être sérialisables.