Compartir a través de


JournaledGrain<TGrainState> Clase

Definición

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

public abstract class JournaledGrain<TGrainState> : Orleans.EventSourcing.JournaledGrain<TGrainState,object> where TGrainState : class, new()
type JournaledGrain<'GrainState (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState))> = class
    inherit JournaledGrain<'GrainState, obj (requires 'GrainState : null and 'GrainState : (new : unit -> 'GrainState))>
Public MustInherit Class JournaledGrain(Of TGrainState)
Inherits JournaledGrain(Of TGrainState, Object)

Parámetros de tipo

TGrainState

Tipo para el estado de grano, es decir, la vista de agregado del registro de eventos.

Herencia
JournaledGrain<TGrainState,Object>
JournaledGrain<TGrainState>
Herencia
LogConsistentGrain<TGrainState>
JournaledGrain<TGrainState,Object>
JournaledGrain<TGrainState>
Herencia
LogConsistentGrain<TGrainState>
JournaledGrain<TGrainState,Object>
JournaledGrain<TGrainState>

Constructores

JournaledGrain<TGrainState>()

Inicializa una nueva instancia de la clase JournaledGrain<TGrainState>.

JournaledGrain<TGrainState>(IGrainIdentity, IGrainRuntime)

Este constructor es especialmente útil para las pruebas unitarias en las que el código de prueba puede crear un elemento Grain y reemplazar IGrainIdentity, IGrainRuntime y State por dobles de prueba (mocks/stubs).

Propiedades

DefaultAdaptorFactory

Si no se especifica ningún proveedor de coherencia de registro, almacene el estado con versiones mediante el proveedor de almacenamiento predeterminado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
GrainFactory

Obtiene un objeto que se puede usar para tener acceso a otros granos. Null si este grano no está asociado a un runtime, como cuando se crea directamente para las pruebas unitarias.

(Heredado de Grain)
GrainReference

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de Grain)
IdentityString

Representación de cadena de siloIdentity del grano, incluido el tipo y la clave principal.

(Heredado de Grain)
RuntimeIdentity

Identificador único del silo actual. No hay contenido semántico en esta cadena, pero puede ser útil para el registro.

(Heredado de Grain)
ServiceProvider

Obtiene el IServiceProvider administrado por el tiempo de ejecución. Null si este grano no está asociado a un runtime, como cuando se crea directamente para las pruebas unitarias.

(Heredado de Grain)
State

Obtiene el estado confirmado actual. Incluye solo eventos confirmados.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
TentativeState

Obtiene el estado provisional actual. Incluye eventos confirmados y no confirmados.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
UnconfirmedEvents

Devuelve la cola actual de eventos no confirmados.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
UnresolvedConnectionIssues

Obtiene una lista de todos los problemas de conexión sin resolver actualmente.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
Version

Obtiene la versión del estado confirmado actual. Es igual al número total de eventos confirmados.

(Heredado de JournaledGrain<TGrainState,TEventBase>)

Métodos

ConfirmEvents()

Espera hasta que se hayan confirmado todos los eventos generados previamente.

espere esto después de generar uno o varios eventos, para asegurarse de que los eventos se conservan antes de continuar, o para garantizar una coherencia fuerte (linealización) incluso si hay varias instancias de este grano

(Heredado de JournaledGrain<TGrainState,TEventBase>)
DeactivateOnIdle()

Desactive esta activación del grano una vez completada la llamada al método de grano actual. Esta llamada marcará esta activación del grano actual que se va a desactivar y quitar al final del método actual. La siguiente llamada a este grano dará lugar a una activación diferente que se usará, lo que significa que el tiempo de ejecución creará automáticamente una nueva activación.

(Heredado de Grain)
DelayDeactivation(TimeSpan)

Retrasar la desactivación de esta activación al menos durante el tiempo especificado. Un valor positivo timeSpan significa "evitar gc de esta activación durante ese intervalo de tiempo". Un valor negativo timeSpan significa "cancelar la configuración anterior de la llamada DelayDeactivation y hacer que esta activación se comporte en función de la configuración regular de la recolección de elementos no utilizados de activación". El método DeactivateOnIdle deshacería o invalidaría cualquier configuración actual de "mantener activo", lo que hace que este grano esté disponible inmediatamente para la desactivación.

(Heredado de Grain)
DisableStatsCollection()

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
EnableStatsCollection()

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
GetLogger()

Devuelve un objeto registrador que el código de este grano puede usar para el seguimiento. El nombre del registrador se derivará del nombre de la clase de grano.

(Heredado de Grain)
GetLogger(String)

Devuelve un objeto registrador que el código de este grano puede usar para el seguimiento.

(Heredado de Grain)
GetReminder(String)

Devuelve un recordatorio registrado previamente.

(Heredado de Grain)
GetReminders()

Devuelve una lista de todos los avisos registrados por el grano.

(Heredado de Grain)
GetStats()

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
GetStreamProvider(String)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de Grain)
GetStreamProviders()

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)

Se llama justo después de construir el grano, para instalar el adaptador. El proveedor de coherencia de registros contiene un método de fábrica que construye el adaptador con tipos elegidos para este grano

(Heredado de JournaledGrain<TGrainState,TEventBase>)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)

Se llama justo después de construir el grano, para instalar el adaptador. El proveedor de coherencia de registros contiene un método de fábrica que construye el adaptador con tipos elegidos para este grano

(Heredado de JournaledGrain<TGrainState,TEventBase>)
MigrateOnIdle()

Inicia un intento de migrar esta instancia a otra ubicación. La migración captura el actual RequestContext, lo que hace que esté disponible para el director de selección de ubicación de la activación para que pueda considerarlo al seleccionar una nueva ubicación. La migración se producirá de forma asincrónica, cuando no se ejecute ninguna solicitud y no se producirá si el director de selección de ubicación de la activación no selecciona una ubicación alternativa.

(Heredado de Grain)
OnActivateAsync()

De forma predeterminada, tras la activación, el grano en diario espera hasta que haya cargado la vista más reciente desde el almacenamiento. Las subclases pueden invalidar este comportamiento y omitir la espera si lo desea.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnActivateAsync(CancellationToken)

De forma predeterminada, tras la activación, el grano en diario espera hasta que haya cargado la vista más reciente desde el almacenamiento. Las subclases pueden invalidar este comportamiento y omitir la espera si lo desea.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssue(ConnectionIssue)

Se llama cuando la persistencia o el protocolo de replicación subyacentes se están ejecutando en algún tipo de problema de conexión.

Invalide esta opción para supervisar el estado del protocolo de coherencia del registro o para personalizar los retrasos de reintento. Las excepciones iniciadas se detectan y registran mediante ILogViewAdaptorFactory.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssue(ConnectionIssue)

Se llama cuando la persistencia o el protocolo de replicación subyacentes se están ejecutando en algún tipo de problema de conexión.

Invalide esta opción para supervisar el estado del protocolo de coherencia del registro o para personalizar los retrasos de reintento. Las excepciones iniciadas se detectan y registran mediante ILogConsistencyProvider.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssueResolved(ConnectionIssue)

Se llama cuando se ha resuelto un problema de conexión notificado anteriormente.

Invalide esta opción para supervisar el estado del protocolo de coherencia del registro. Las excepciones iniciadas se detectan y registran mediante ILogConsistencyProvider.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssueResolved(ConnectionIssue)

Se llama cuando se ha resuelto un problema de conexión notificado anteriormente.

Invalide esta opción para supervisar el estado del protocolo de coherencia del registro. Las excepciones iniciadas se detectan y registran mediante ILogViewAdaptorFactory.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnDeactivateAsync()

Se llama a este método al principio del proceso de desactivación de un grano.

(Heredado de Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)

Se llama a este método al principio del proceso de desactivación de un grano.

(Heredado de Grain)
OnStateChanged()

Se llama después de que el estado confirmado haya cambiado (es decir, el número de versión confirmado es mayor).

Invalide esto para reaccionar a los cambios del estado confirmado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
OnTentativeStateChanged()

Se llama cada vez que el estado provisional puede haber cambiado debido a eventos locales o remotos.

Invalide esto para reaccionar a los cambios del estado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
Participate(IGrainLifecycle)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de Grain)
Participate(IGrainLifecycle)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de LogConsistentGrain<TView>)
Participate(IGrainLifecycle)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)

Genere un evento condicionalmente. Solo se realiza correctamente si no hay ningún conflicto, es decir, no se generaron otros eventos mientras tanto.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)

Genere varios eventos, como una secuencia atómica, condicionalmente. Solo se realiza correctamente si no hay ningún conflicto, es decir, no se generaron otros eventos mientras tanto.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
RaiseEvent<TEvent>(TEvent)

Genera un evento.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
RaiseEvents<TEvent>(IEnumerable<TEvent>)

Genera varios eventos, como una secuencia atómica.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
RefreshNow()

Recupera el estado más reciente ahora y confirma todos los eventos generados anteriormente. De hecho, esto exige la sincronización con el estado global.

Espere esto antes de leer el estado para garantizar una coherencia fuerte (linealización) incluso si hay varias instancias de este grano

(Heredado de JournaledGrain<TGrainState,TEventBase>)
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)

Registra un recordatorio persistente y confiable para enviar notificaciones periódicas (recordatorios) al grano. El grano debe implementar la Orleans.IRemindable interfaz y los avisos para este grano se enviarán al ReceiveReminder método de devolución de llamada. Si el grano actual se desactiva cuando se activa el temporizador, se creará una nueva activación de este grano para recibir este aviso. Si ya existe un recordatorio con el mismo nombre, ese aviso se sobrescribirá con este nuevo recordatorio. Los avisos siempre serán recibidos por una activación de este grano, incluso si existen varias activaciones para este grano.

(Heredado de Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)

Registra un temporizador para enviar devoluciones de llamada periódicas a este grano.

(Heredado de Grain)
RetrieveConfirmedEvents(Int32, Int32)

Recupera un segmento de la secuencia de eventos confirmada, posiblemente del almacenamiento. NotSupportedException Produce si los eventos no están disponibles para leerse. Si los eventos están disponibles y, durante cuánto tiempo, dependen de los proveedores usados y de cómo están configurados.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
TransitionState(TGrainState, TEventBase)

Define cómo aplicar eventos al estado. A menos que se invalide en la subclase, llama a una función dinámica "Apply" en el estado, con el evento como parámetro. El proveedor de vistas de registro detecta y registra todas las excepciones producidas por este método.

Invalide esto para personalizar cómo realizar la transición del estado de un evento determinado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
UnregisterReminder(IGrainReminder)

Anula el registro de un aviso registrado anteriormente.

(Heredado de Grain)

Implementaciones de interfaz explícitas

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)

llamado por el adaptador en problemas de conexión.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)

llamado por el adaptador en problemas de conexión.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)

Lo llama el adaptador cuando se resuelve un problema de conexión.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)

lo llama el adaptador cuando se resuelve un problema de conexión.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
IGrainBase.GrainContext

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

(Heredado de Grain)
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()

Notificación al adaptador de la vista de registro de desactivación

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()

Notificación al adaptador de la vista de registro de desactivación

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.OnMultiClusterConfigurationChange(MultiClusterConfiguration)

Reciba un cambio de configuración y pase al adaptador de la vista de registro.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.OnProtocolMessageReceived(ILogConsistencyProtocolMessage)

Reciba un mensaje de protocolo de otros clústeres, que se pasa al adaptador de la vista de registro.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()

Notificación al adaptador de la vista de registro de activación (llamado después del nivel de usuario OnActivate)

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()

Notificación al adaptador de la vista de registro de activación (llamado después del nivel de usuario OnActivate)

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()

Notificación al adaptador de vista de registro de activación (llamado antes de onActivate de nivel de usuario)

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()

Notificación al adaptador de vista de registro de activación (llamado antes de onActivate de nivel de usuario)

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistentGrain.DefaultAdaptorFactory

Si no se especifica ningún proveedor de coherencia de registro, almacene el estado con versiones mediante el proveedor de almacenamiento predeterminado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogConsistentGrain.InstallAdaptor(ILogViewAdaptorFactory, Object, String, IStorageProvider, ILogConsistencyProtocolServices)

Se llama justo después de construir el grano, para instalar el adaptador. El proveedor de coherencia de registros contiene un método de fábrica que construye el adaptador con tipos elegidos para este grano

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)

Lo llama el adaptador en el cambio de estado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)

llamado por el adaptador en el cambio de estado.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)

Lo llama el adaptador para actualizar la vista cuando se anexan las entradas.

(Heredado de JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)

lo llama el adaptador para actualizar la vista cuando se anexan las entradas.

(Heredado de JournaledGrain<TGrainState,TEventBase>)

Métodos de extensión

DeactivateOnIdle(IGrainBase)

Desactive esta activación de grano una vez completada la llamada al método de grano actual. Esta llamada marcará esta activación del grano actual que se va a desactivar y quitar al final del método actual. La siguiente llamada a este grano dará lugar a una activación diferente que se usará, lo que normalmente significa que el tiempo de ejecución creará automáticamente una nueva activación.

MigrateOnIdle(IGrainBase)

Inicia un intento de migrar esta instancia a otra ubicación. La migración captura el actual RequestContext, lo que hace que esté disponible para el director de selección de ubicación de la activación para que pueda considerarlo al seleccionar una nueva ubicación. La migración se producirá de forma asincrónica, cuando no se ejecute ninguna solicitud y no se producirá si el director de selección de ubicación de la activación no selecciona una ubicación alternativa.

AsReference(IAddressable, Type)

Devuelve una referencia con tipo al grano proporcionado.

AsReference<TGrainInterface>(IAddressable)

Devuelve una referencia con tipo al grano proporcionado.

BindGrainReference(IAddressable, IGrainFactory)

Enlaza la referencia de grano a la proporcionada IGrainFactory.

Cast(IAddressable, Type)

Devuelve una referencia con tipo al grano proporcionado.

Cast<TGrainInterface>(IAddressable)

Devuelve una referencia con tipo al grano proporcionado.

GetGrainId(IAddressable)

Devuelve el identificador de grano correspondiente al grano proporcionado.

GetGrainIdentity(IGrain)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

GetPrimaryKey(IGrain)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

GetPrimaryKey(IGrain, String)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

GetPrimaryKey(IAddressable)

Devuelve la Guid representación de una clave principal de grano.

GetPrimaryKey(IAddressable, String)

Devuelve la Guid representación de una clave principal de grano.

GetPrimaryKeyLong(IGrain)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

GetPrimaryKeyLong(IGrain, String)

Clase base para granos coherentes con el registro mediante terminología estándar de origen de eventos. Todas las operaciones son seguras para la reentrada.

GetPrimaryKeyLong(IAddressable)

Devuelve la long representación de una clave principal de grano.

GetPrimaryKeyLong(IAddressable, String)

Devuelve la long representación de una clave principal de grano.

GetPrimaryKeyString(IAddressable)

Devuelve la string clave principal del grano.

IsPrimaryKeyBasedOnLong(IAddressable)

Devuelve si parte de la clave principal es de tipo long.

GetReminder(Grain, String)

Devuelve un aviso registrado previamente.

GetReminder(IGrainBase, String)

Devuelve un aviso registrado previamente.

GetReminders(Grain)

Devuelve una lista de todos los avisos registrados por el grano.

GetReminders(IGrainBase)

Devuelve una lista de todos los avisos registrados por el grano.

RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)

Registra un recordatorio persistente y confiable para enviar notificaciones periódicas (recordatorios) al grano. El grano debe implementar la Orleans.IRemindable interfaz y los avisos para este grano se enviarán al ReceiveReminder método de devolución de llamada. Si el grano actual se desactiva cuando se activa el temporizador, se creará una nueva activación de este grano para recibir este aviso. Si ya existe un recordatorio con el mismo nombre, ese aviso se sobrescribirá con este nuevo recordatorio. Los avisos siempre serán recibidos por una activación de este grano, incluso si existen varias activaciones para este grano.

RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)

Registra un recordatorio persistente y confiable para enviar notificaciones periódicas (recordatorios) al grano. El grano debe implementar la Orleans.IRemindable interfaz y los avisos para este grano se enviarán al ReceiveReminder método de devolución de llamada. Si el grano actual se desactiva cuando se activa el temporizador, se creará una nueva activación de este grano para recibir este aviso. Si ya existe un recordatorio con el mismo nombre, ese aviso se sobrescribirá con este nuevo recordatorio. Los avisos siempre serán recibidos por una activación de este grano, incluso si existen varias activaciones para este grano.

UnregisterReminder(Grain, IGrainReminder)

Anula el registro de un aviso registrado anteriormente.

UnregisterReminder(IGrainBase, IGrainReminder)

Anula el registro de un aviso registrado anteriormente.

GetStreamProvider(Grain, String)

Obtiene el proveedor de flujos con el especificado name.

GetStreamProvider(IGrainBase, String)

Obtiene el proveedor de flujos con el especificado name.

GetLogger(Grain)

Devuelve un objeto de registrador que el código de este grano puede usar para el seguimiento. El nombre del registrador se derivará del nombre de la clase de grano.

GetLogger(Grain, String)

Devuelve un objeto de registrador que el código de este grano puede usar para el seguimiento.

GetGrainStorage(Grain, IServiceProvider)

Adquiera el proveedor de almacenamiento asociado al tipo de grano.

Se aplica a