JournaledGrain<TGrainState,TEventBase> Classe

Definizione

Spazio dei nomi:

Orleans.EventSourcing

Assembly:

Orleans.EventSourcing.dll

Pacchetto:

Microsoft.Orleans.EventSourcing v8.2.0

Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.

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)

Parametri di tipo

TGrainState

Tipo per lo stato di granularità, ovvero la visualizzazione aggregata del registro eventi.

TEventBase

Classe base comune per gli eventi

Ereditarietà

Object

Grain

LogConsistentGrain<TGrainState>

JournaledGrain<TGrainState,TEventBase>

Derivato

Orleans.EventSourcing.JournaledGrain<TGrainState>

Implementazioni

IGrain IAddressable IConnectionIssueListener ILogConsistencyProtocolParticipant ILogViewAdaptorHost<TGrainState,TEventBase>

Costruttori

JournaledGrain<TGrainState,TEventBase>()

Inizializza una nuova istanza della classe JournaledGrain<TGrainState,TEventBase>.

Proprietà

DefaultAdaptorFactory	Se non è specificato alcun provider di coerenza dei log, archiviare lo stato con controllo delle versioni usando il provider di archiviazione predefinito
GrainContext	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy. (Ereditato da Grain)
GrainFactory	Ottiene un oggetto che può essere utilizzato per accedere ad altri grani. Null se questo granularità non è associato a un runtime, ad esempio quando viene creato direttamente per gli unit test. (Ereditato da Grain)
GrainReference	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy. (Ereditato da Grain)
IdentityString	Rappresentazione di stringa della siloIdentity di granularità, inclusi il tipo e la chiave primaria. (Ereditato da Grain)
RuntimeIdentity	Identificatore univoco per il silo corrente. Non esiste contenuto semantico per questa stringa, ma può essere utile per la registrazione. (Ereditato da Grain)
ServiceProvider	Ottiene l'oggetto IServiceProvider gestito dal runtime. Null se questo granularità non è associato a un runtime, ad esempio quando viene creato direttamente per gli unit test. (Ereditato da Grain)
State	Ottiene lo stato confermato corrente. Include solo gli eventi confermati.
TentativeState	Ottiene lo stato provvisorio corrente. Include sia eventi confermati che non confermati.
UnconfirmedEvents	Restituisce la coda corrente di eventi non confermati.
Version	Ottiene la versione dello stato confermato corrente. Uguale al numero totale di eventi confermati.

Metodi

ConfirmEvents()	Attende che tutti gli eventi generati in precedenza non siano stati confermati. attendere questa operazione dopo la generazione di uno o più eventi, per assicurarsi che gli eventi vengano salvati in modo permanente prima di procedere o garantire una coerenza assoluta (linearizzabilità) anche se sono presenti più istanze di questo granulare
DeactivateOnIdle()	Disattivare questa attivazione della granularità dopo il completamento della chiamata al metodo granulare corrente. Questa chiamata contrassegnerà questa attivazione della granularità corrente da disattivare e rimuovere alla fine del metodo corrente. La chiamata successiva a questa granularità comporterà un'attivazione diversa da usare, che in genere significa che una nuova attivazione verrà creata automaticamente dal runtime. (Ereditato da Grain)
DelayDeactivation(TimeSpan)	Disattivazione ritardata dell'attivazione almeno per la durata specificata. Un valore positivo timeSpan significa "impedire il GC di questa attivazione per tale intervallo di tempo". Un valore negativo timeSpan significa "annullare l'impostazione precedente della chiamata DelayDeactivation e fare in modo che l'attivazione si comporti in base alle normali impostazioni di Garbage Collection di attivazione". Il metodo DeactivateOnIdle annulla/esegue l'override di qualsiasi impostazione corrente "keep alive", rendendo immediatamente disponibile questo granulare per la disattivazione. (Ereditato da Grain)
DisableStatsCollection()	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.
EnableStatsCollection()	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.
GetLogger()	Restituisce un oggetto logger che il codice di questa granularità può usare per la traccia. Il nome del logger verrà derivato dal nome della classe granulare. (Ereditato da Grain)
GetLogger(String)	Restituisce un oggetto logger che il codice di questa granularità può usare per la traccia. (Ereditato da Grain)
GetReminder(String)	Restituisce un promemoria registrato in precedenza. (Ereditato da Grain)
GetReminders()	Restituisce un elenco di tutti i promemoria registrati dalla granularità. (Ereditato da Grain)
GetStats()	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.
GetStreamProvider(String)	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy. (Ereditato da Grain)
GetStreamProviders()	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy. (Ereditato da Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	Chiamato subito dopo la costruzione del grano, per installare l'adattatore. Il provider di coerenza log contiene un metodo factory che costruisce l'adattatore con i tipi scelti per questo tipo di granularità
MigrateOnIdle()	Avvia un tentativo di migrazione dell'istanza in un'altra posizione. La migrazione acquisisce l'RequestContextcorrente, rendendola disponibile per la directory di posizionamento dell'attivazione in modo che possa considerarla quando si seleziona una nuova posizione. La migrazione verrà eseguita in modo asincrono, quando non vengono eseguite richieste e non si verificherà se il director di posizionamento dell'attivazione non seleziona una posizione alternativa. (Ereditato da Grain)
OnActivateAsync()	Questo metodo viene chiamato alla fine del processo di attivazione di una granularità. Viene chiamato prima che tutti i messaggi siano stati inviati alla granularità. Per i grani con stato persistente dichiarato, questo metodo viene chiamato dopo che la proprietà State è stata popolata. (Ereditato da Grain)
OnActivateAsync(CancellationToken)	Per impostazione predefinita, all'attivazione, la granularità del journal attende fino a quando non viene caricata la visualizzazione più recente dall'archiviazione. Le sottoclassi possono eseguire l'override di questo comportamento e ignorare l'attesa, se necessario.
OnConnectionIssue(ConnectionIssue)	Chiamato quando il protocollo di persistenza o replica sottostante è in esecuzione in una sorta di problemi di connessione. Eseguire l'override di questa opzione per monitorare l'integrità del protocollo di coerenza dei log e/o per personalizzare i ritardi dei tentativi. Tutte le eccezioni generate vengono intercettate e registrate dal ILogViewAdaptorFactory.
OnConnectionIssueResolved(ConnectionIssue)	Chiamato quando è stato risolto un problema di connessione segnalato in precedenza. Eseguire l'override di questa opzione per monitorare l'integrità del protocollo di coerenza dei log. Tutte le eccezioni generate vengono intercettate e registrate dal ILogViewAdaptorFactory.
OnDeactivateAsync()	Questo metodo viene chiamato all'inizio del processo di disattivazione di una granularità. (Ereditato da Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	Questo metodo viene chiamato all'inizio del processo di disattivazione di una granularità. (Ereditato da Grain)
OnStateChanged()	Chiamato dopo che lo stato confermato può essere cambiato (ad esempio, il numero di versione confermato è maggiore). Eseguire l'override di questa opzione per reagire alle modifiche dello stato confermato.
OnTentativeStateChanged()	Chiamato ogni volta che lo stato provvisorio può essere cambiato a causa di eventi locali o remoti. Eseguire l'override di questa opzione per reagire alle modifiche dello stato.
Participate(IGrainLifecycle)	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy. (Ereditato da LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)	Generare un evento in modo condizionale. Ha esito positivo solo se non sono presenti conflitti, ovvero non sono stati generati altri eventi nel frattempo.
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)	Generare più eventi, come sequenza atomica, in modo condizionale. Ha esito positivo solo se non sono presenti conflitti, ovvero non sono stati generati altri eventi nel frattempo.
RaiseEvent<TEvent>(TEvent)	Genera un evento.
RaiseEvents<TEvent>(IEnumerable<TEvent>)	Generare più eventi, come sequenza atomica.
RefreshNow()	Recupera ora lo stato più recente e conferma tutti gli eventi generati in precedenza. In effetti, viene applicata la sincronizzazione con lo stato globale. Attendere questo aspetto prima di leggere lo stato per garantire una coerenza assoluta (linearizzabilità) anche se sono presenti più istanze di questo granulare
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	Registra un promemoria permanente e affidabile per inviare notifiche regolari (promemoria) alla granularità. La granularità deve implementare l'interfaccia Orleans.IRemindable e i promemoria per questo granularità verranno inviati al metodo di callback ReceiveReminder. Se la granularità corrente viene disattivata quando il timer viene attivato, verrà creata una nuova attivazione di questo granulare per ricevere questo promemoria. Se esiste già un promemoria esistente con lo stesso nome, il promemoria verrà sovrascritto con questo nuovo promemoria. I promemoria verranno sempre ricevuti da un'attivazione di questo granularità, anche se esistono più attivazioni per questo granularità. (Ereditato da Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	Obsoleti. Registra un timer per inviare callback periodici a questa granularità. (Ereditato da Grain)
RetrieveConfirmedEvents(Int32, Int32)	Recupera un segmento della sequenza di eventi confermata, possibilmente dalla risorsa di archiviazione. Genera NotSupportedException se gli eventi non sono disponibili per la lettura. Se gli eventi sono disponibili e per quanto tempo, dipendono dai provider usati e dal modo in cui sono configurati.
TransitionState(TGrainState, TEventBase)	Definisce come applicare gli eventi allo stato. A meno che non venga sottoposto a override nella sottoclasse, chiama una funzione dinamica "Apply" sullo stato, con l'evento come parametro. Tutte le eccezioni generate da questo metodo vengono intercettate e registrate dal provider di visualizzazioni log. Eseguire l'override di questa opzione per personalizzare la transizione dello stato per un determinato evento.
UnregisterReminder(IGrainReminder)	Annulla la registrazione di un promemoria registrato in precedenza. (Ereditato da Grain)

Implementazioni dell'interfaccia esplicita

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)	chiamato dall'adattatore in caso di problemi di connessione.
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)	Chiamato dall'adattatore quando viene risolto un problema di connessione.
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()	Notifica all'adattatore della visualizzazione log di disattivazione
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()	Notifica all'adattatore della visualizzazione log dell'attivazione (chiamato dopo OnActivate a livello di utente)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()	Notifica all'adattatore di visualizzazione log dell'attivazione (chiamato prima di OnActivate a livello di utente)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)	Chiamato dall'adattatore in caso di modifica dello stato.
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)	Chiamato dall'adattatore per aggiornare la visualizzazione quando vengono aggiunte voci.

Metodi di estensione

DeactivateOnIdle(IGrainBase)	Disattivare questa attivazione granulare dopo il completamento della chiamata al metodo granulare corrente. Questa chiamata contrassegnerà questa attivazione della granularità corrente da disattivare e rimuovere alla fine del metodo corrente. La chiamata successiva a questa granularità comporterà un'attivazione diversa da usare, che in genere significa che una nuova attivazione verrà creata automaticamente dal runtime.
MigrateOnIdle(IGrainBase)	Avvia un tentativo di migrazione dell'istanza in un'altra posizione. La migrazione acquisisce l'RequestContextcorrente, rendendola disponibile per la directory di posizionamento dell'attivazione in modo che possa considerarla quando si seleziona una nuova posizione. La migrazione verrà eseguita in modo asincrono, quando non vengono eseguite richieste e non si verificherà se il director di posizionamento dell'attivazione non seleziona una posizione alternativa.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, GrainTimerCreationOptions)	Crea un timer di granularità.
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, TimeSpan, TimeSpan)	Crea un timer di granularità.
RegisterGrainTimer(IGrainBase, Func<Task>, GrainTimerCreationOptions)	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.
RegisterGrainTimer(IGrainBase, Func<Task>, TimeSpan, TimeSpan)	Crea un timer di granularità.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, GrainTimerCreationOptions)	Crea un timer di granularità.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, TimeSpan, TimeSpan)	Crea un timer di granularità.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, GrainTimerCreationOptions)	Classe di base per grani coerenti con i log che usano la terminologia standard relativa all'origine degli eventi. Tutte le operazioni sono sicure per la reentrancy.
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, TimeSpan, TimeSpan)	Crea un timer di granularità.
AsReference(IAddressable, Type)	Restituisce un riferimento tipizzato alla granularità specificata.
AsReference<TGrainInterface>(IAddressable)	Restituisce un riferimento tipizzato alla granularità specificata.
Cast(IAddressable, Type)	Restituisce un riferimento tipizzato alla granularità specificata.
Cast<TGrainInterface>(IAddressable)	Restituisce un riferimento tipizzato alla granularità specificata.
GetGrainId(IAddressable)	Restituisce l'ID granulare corrispondente alla granularità specificata.
GetPrimaryKey(IAddressable)	Restituisce la rappresentazione Guid di una chiave primaria granulare.
GetPrimaryKey(IAddressable, String)	Restituisce la rappresentazione Guid di una chiave primaria granulare.
GetPrimaryKeyLong(IAddressable)	Restituisce la rappresentazione long di una chiave primaria granulare.
GetPrimaryKeyLong(IAddressable, String)	Restituisce la rappresentazione long di una chiave primaria granulare.
GetPrimaryKeyString(IAddressable)	Restituisce l'string chiave primaria della granularità.
IsPrimaryKeyBasedOnLong(IAddressable)	Restituisce un valore che indica se parte della chiave primaria è di tipo long.
GetReminder(Grain, String)	Restituisce un promemoria registrato in precedenza.
GetReminder(IGrainBase, String)	Restituisce un promemoria registrato in precedenza.
GetReminders(Grain)	Restituisce un elenco di tutti i promemoria registrati dalla granularità.
GetReminders(IGrainBase)	Restituisce un elenco di tutti i promemoria registrati dalla granularità.
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	Registra un promemoria permanente e affidabile per inviare notifiche regolari (promemoria) alla granularità. La granularità deve implementare l'interfaccia Orleans.IRemindable e i promemoria per questo granularità verranno inviati al metodo di callback ReceiveReminder. Se la granularità corrente viene disattivata quando il timer viene attivato, verrà creata una nuova attivazione di questo granulare per ricevere questo promemoria. Se esiste già un promemoria esistente con lo stesso nome, il promemoria verrà sovrascritto con questo nuovo promemoria. I promemoria verranno sempre ricevuti da un'attivazione di questo granularità, anche se esistono più attivazioni per questo granularità.
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	Registra un promemoria permanente e affidabile per inviare notifiche regolari (promemoria) alla granularità. La granularità deve implementare l'interfaccia Orleans.IRemindable e i promemoria per questo granularità verranno inviati al metodo di callback ReceiveReminder. Se la granularità corrente viene disattivata quando il timer viene attivato, verrà creata una nuova attivazione di questo granulare per ricevere questo promemoria. Se esiste già un promemoria esistente con lo stesso nome, il promemoria verrà sovrascritto con questo nuovo promemoria. I promemoria verranno sempre ricevuti da un'attivazione di questo granularità, anche se esistono più attivazioni per questo granularità.
UnregisterReminder(Grain, IGrainReminder)	Annulla la registrazione di un promemoria registrato in precedenza.
UnregisterReminder(IGrainBase, IGrainReminder)	Annulla la registrazione di un promemoria registrato in precedenza.
GetStreamProvider(Grain, String)	Ottiene il provider di flusso con il namespecificato.
GetStreamProvider(IGrainBase, String)	Ottiene il provider di flusso con il namespecificato.