PrimaryBasedLogViewAdaptor<TLogView,TLogEntry,TSubmissionEntry> Clase

Definición

Espacio de nombres:

Orleans.EventSourcing.Common

Ensamblado:

Orleans.EventSourcing.dll

Paquete:

Microsoft.Orleans.EventSourcing v9.0.0

Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir).

Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto).

Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.

C#

public abstract class PrimaryBasedLogViewAdaptor<TLogView,TLogEntry,TSubmissionEntry> : Orleans.EventSourcing.ILogViewAdaptor<TLogView,TLogEntry>, Orleans.EventSourcing.ILogViewRead<TLogView,TLogEntry>, Orleans.EventSourcing.ILogViewUpdate<TLogEntry> where TLogView : class, new() where TLogEntry : class where TSubmissionEntry : SubmissionEntry<TLogEntry>

Parámetros de tipo

TLogView

Vista definida por el usuario del registro

TLogEntry

Tipo de las entradas de registro

TSubmissionEntry

Tipo de entradas de envío almacenadas en la cola pendiente

Herencia

Object

PrimaryBasedLogViewAdaptor<TLogView,TLogEntry,TSubmissionEntry>

Implementaciones

ILogConsistencyDiagnostics ILogViewAdaptor<TLogView,TLogEntry> ILogViewRead<TLogView,TLogEntry> ILogViewUpdate<TLogEntry>

Constructores

PrimaryBasedLogViewAdaptor<TLogView,TLogEntry,TSubmissionEntry>(ILogViewAdaptorHost<TLogView,TLogEntry>, TLogView, ILogConsistencyProtocolServices)

Construya una instancia de para los parámetros especificados.

Campos

LastPrimaryIssue

Almacene el último problema que se produjo al leer o actualizar el principal. Es null si se ejecuta correctamente.

stats

Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.

Propiedades

ConfirmedVersion	Longitud del prefijo confirmado del registro
ConfirmedView	Vista confirmada del registro (que refleja solo las entradas confirmadas)
Host	El grano que usa este adaptador.
Services	Los servicios en tiempo de ejecución necesarios para implementar notificaciones entre instancias específicas en un clúster diferente.
SupportSubmissions	Si este clúster admite el envío de actualizaciones
TentativeView	Vista local y provisional del registro (que refleja las entradas confirmadas y no confirmadas)
UnconfirmedSuffix	Lista de las entradas enviadas que aún no aparecen en el prefijo confirmado.

Métodos

ConfirmSubmittedEntries()	Confirme todas las entradas enviadas. Espera hasta que todas las entradas enviadas previamente aparezcan en el prefijo confirmado del registro.
CopyTentativeState()	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
DisableStatsCollection()	Deshabilitación de la colección de estadísticas
EnableStatsCollection()	method es virtual, por lo que las subclases pueden agregar sus propios eventos
EnsureClusterJoinedAsync()	Bloquee hasta que este clúster esté unido al clúster múltiple.
GetConfirmedVersion()	Lee la versión del estado global almacenado en caché.
GetCurrentBatchOfUpdates()	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
GetNumberPendingUpdates()	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
GetStats()	Obtener estados
InitializeConfirmedView(TLogView)	Establecer la vista confirmada del valor inicial (una vista del registro vacío)
IsMyClusterJoined()	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
LastConfirmedView()	Lee el estado global almacenado en caché.
MakeSubmissionEntry(TLogEntry)	Cree una entrada de envío para la entrada de registro enviada. Usar un parámetro de tipo para poder agregar información específica del protocolo a esta clase.
Merge(INotificationMessage, INotificationMessage)	Combine dos mensajes de notificación para el procesamiento por lotes. Invalide para controlar los subtipos de notificación.
NotifyPromises(Int32, Boolean)	envío de notificaciones de error
OnMessageReceived(ILogConsistencyProtocolMessage)	Controle los mensajes de protocolo.
OnNotificationReceived(INotificationMessage)	Controle los mensajes de notificación. Invalide esto para controlar los subtipos de notificación.
OnProtocolMessageReceived(ILogConsistencyProtocolMessage)	Se llama desde la red
PostOnActivate()	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
PostOnDeactivate()	Se llama durante la desactivación, justo después de la definida por OnDeactivateAsync()el usuario.
PreOnActivate()	Se llama durante la activación, justo antes de la definida por OnActivateAsync()el usuario.
ProcessNotifications()	Procesar las notificaciones almacenadas durante el ciclo de trabajo. Invalide para controlar los subtipos de notificación.
ReadAsync()	Lea el estado principal más reciente. Debe bloquear o reintentar hasta que se realice correctamente. No debe producir excepciones, pero registrarlas en LastPrimaryIssue
RemoveStaleConditionalUpdates()	pasar por las actualizaciones y quitar todas las actualizaciones condicionales que ya han fallado
RetrieveLogSegment(Int32, Int32)	Plantilla general para construir adaptadores de vista de registro basados en una principal de lectura y escritura secuencial. Esto se usa para construir una variedad de proveedores de coherencia de registros diferentes, todos siguiendo el mismo patrón básico (lectura y escritura de la vista más reciente de /a la principal y envío de notificaciones después de escribir). Tenga en cuenta que el propio registro es transitorio, es decir, no se guarda realmente en el almacenamiento, solo la vista más reciente y algunos metadatos (la posición del registro y las marcas de escritura) se almacenan en la principal. Es seguro intercalar llamadas a este adaptador (usando solo programador de granos, por supuesto). Las subclases invalidan ReadAsync y WriteAsync para leer de o escribir en principal. Las llamadas a la principal se serializan, es decir, nunca intercalar.
Submit(TLogEntry)	Envíe una entrada de registro única para anexarse al registro global, ya sea en la posición actual o en cualquier posición posterior.
SubmitRange(IEnumerable<TLogEntry>)	Envíe un intervalo de entradas de registro que se van a anexar atómicamente al registro global, ya sea en la posición actual o en cualquier posición posterior.
Synchronize()	Obtenga la vista de registro más reciente y confirme todas las entradas enviadas. Espera hasta que todas las entradas enviadas previamente aparezcan en el prefijo confirmado del registro y fuerza una actualización del prefijo confirmado.
TryAppend(TLogEntry)	Intente anexar una sola entrada de registro en la posición actual del registro.
TryAppendRange(IEnumerable<TLogEntry>)	Intente anexar un intervalo de entradas de registro de forma atómica en la posición actual del registro.
WriteAsync()	Aplique entradas pendientes al servidor principal. Debe bloquear o reintentar hasta que se realice correctamente. No debe producir excepciones, pero registrarlas en LastPrimaryIssue

Se aplica a