JournaledGrain<TGrainState> 类

定义

命名空间:

Orleans.EventSourcing

程序集:

Orleans.EventSourcing.dll

包:

Microsoft.Orleans.EventSourcing v8.2.0

使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。

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)

类型参数

TGrainState

粒度状态的类型，即事件日志的聚合视图。

继承

Object

Grain

LogConsistentGrain<TGrainState>

JournaledGrain<TGrainState,Object>

JournaledGrain<TGrainState>

构造函数

JournaledGrain<TGrainState>()

初始化 JournaledGrain<TGrainState> 类的新实例。

属性

DefaultAdaptorFactory	如果没有指定的日志一致性提供程序，请使用默认存储提供程序存储版本控制状态 (继承自 JournaledGrain<TGrainState,TEventBase>)
GrainContext	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 Grain)
GrainFactory	获取可用于访问其他粒度的对象。 如果此粒度未与运行时关联，则为 Null，例如直接为单元测试创建时。 (继承自 Grain)
GrainReference	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 Grain)
IdentityString	粒度的 SiloIdentity 的字符串表示形式，包括类型和主键。 (继承自 Grain)
RuntimeIdentity	当前接收器的唯一标识符。 此字符串没有语义内容，但对日志记录可能很有用。 (继承自 Grain)
ServiceProvider	获取由运行时管理的 IServiceProvider。 如果此粒度未与运行时关联，则为 Null，例如直接为单元测试创建时。 (继承自 Grain)
State	获取当前确认的状态。 仅包括已确认的事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
TentativeState	获取当前暂定状态。 包括已确认和未确认的事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
UnconfirmedEvents	返回未确认事件的当前队列。 (继承自 JournaledGrain<TGrainState,TEventBase>)
UnresolvedConnectionIssues	获取所有当前未解决的连接问题的列表。 (继承自 JournaledGrain<TGrainState,TEventBase>)
Version	获取当前确认状态的版本。 等于已确认事件的总数。 (继承自 JournaledGrain<TGrainState,TEventBase>)

方法

ConfirmEvents()	等待之前引发的所有事件都得到确认。 在引发一个或多个事件后等待此事件，以确保在继续之前保留事件，或保证强一致性（线性化），即使此粒度有多个实例 (继承自 JournaledGrain<TGrainState,TEventBase>)
DeactivateOnIdle()	完成当前粒度方法调用后，停用粒度激活。 此调用将标记当前粒度的激活，以在当前方法末尾停用和删除。 下次调用此粒度将导致使用不同的激活，这通常意味着运行时会自动创建新的激活。 (继承自 Grain)
DelayDeactivation(TimeSpan)	延迟此激活至少在指定的持续时间内停用。 正 timeSpan 值表示“防止 GC 在此时间跨度内激活”。 负 timeSpan 值表示“取消 DelayDeactivation 调用的上一个设置，并根据常规激活垃圾回收设置进行此激活”。 DeactivateOnIdle 方法将撤消/重写任何当前“保持活动状态”设置，使此粒度立即可供停用。 (继承自 Grain)
DisableStatsCollection()	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 JournaledGrain<TGrainState,TEventBase>)
EnableStatsCollection()	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 JournaledGrain<TGrainState,TEventBase>)
GetLogger()	返回此粒度的代码可用于跟踪的记录器对象。 记录器的名称将派生自粒度类名。 (继承自 Grain)
GetLogger(String)	返回此粒度的代码可用于跟踪的记录器对象。 (继承自 Grain)
GetReminder(String)	返回以前注册的提醒。 (继承自 Grain)
GetReminders()	返回由粒度注册的所有提醒的列表。 (继承自 Grain)
GetStats()	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 JournaledGrain<TGrainState,TEventBase>)
GetStreamProvider(String)	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 Grain)
GetStreamProviders()	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 Grain)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	在构造粒度后立即调用，以安装适配器。 日志一致性提供程序包含一个工厂方法，该方法使用为此粒度选择的类型构造适配器 (继承自 JournaledGrain<TGrainState,TEventBase>)
InstallAdaptor(ILogViewAdaptorFactory, Object, String, IGrainStorage, ILogConsistencyProtocolServices)	在构造粒度后立即调用，以安装适配器。 日志一致性提供程序包含一个工厂方法，该方法使用为此粒度选择的类型构造适配器 (继承自 JournaledGrain<TGrainState,TEventBase>)
MigrateOnIdle()	开始尝试将此实例迁移到另一个位置。 迁移捕获当前 RequestContext，使其可供激活的放置控制器使用，以便在选择新位置时可以考虑它。 迁移将异步发生，如果未执行任何请求，并且如果激活的放置控制器未选择备用位置，则不会发生迁移。 (继承自 Grain)
OnActivateAsync()	默认情况下，激活后，日记粒度会等待，直到从存储加载最新视图。 子类可以重写此行为，并根据需要跳过等待。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnActivateAsync(CancellationToken)	默认情况下，激活后，日记粒度会等待，直到从存储加载最新视图。 子类可以重写此行为，并根据需要跳过等待。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssue(ConnectionIssue)	当基础持久性或复制协议遇到某种连接问题时调用。 重写此选项以监视日志一致性协议的运行状况和/或自定义重试延迟。 ILogViewAdaptorFactory捕获并记录引发的任何异常。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssue(ConnectionIssue)	当基础持久性或复制协议遇到某种连接问题时调用。 重写此选项以监视日志一致性协议的运行状况和/或自定义重试延迟。 ILogConsistencyProvider捕获并记录引发的任何异常。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssueResolved(ConnectionIssue)	解决以前报告的连接问题时调用。 重写此项以监视日志一致性协议的运行状况。 ILogConsistencyProvider捕获并记录引发的任何异常。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnConnectionIssueResolved(ConnectionIssue)	解决以前报告的连接问题时调用。 重写此项以监视日志一致性协议的运行状况。 ILogViewAdaptorFactory捕获并记录引发的任何异常。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnDeactivateAsync()	此方法在停用粒度的过程开始时调用。 (继承自 Grain)
OnDeactivateAsync(DeactivationReason, CancellationToken)	此方法在停用粒度的过程开始时调用。 (继承自 Grain)
OnStateChanged()	在确认状态可能已更改后调用（即确认的版本号更大）。 重写此项以响应已确认状态的更改。 (继承自 JournaledGrain<TGrainState,TEventBase>)
OnTentativeStateChanged()	每当暂定状态因本地或远程事件而更改时调用。 重写此项以响应状态的更改。 (继承自 JournaledGrain<TGrainState,TEventBase>)
Participate(IGrainLifecycle)	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。 (继承自 LogConsistentGrain<TView>)
RaiseConditionalEvent<TEvent>(TEvent)	有条件地引发事件。 仅当没有冲突时，才会成功，也就是说，在此期间不会引发其他事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
RaiseConditionalEvents<TEvent>(IEnumerable<TEvent>)	有条件地以原子序列的形式引发多个事件。 仅当没有冲突时，才会成功，也就是说，在此期间不会引发其他事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
RaiseEvent<TEvent>(TEvent)	引发事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
RaiseEvents<TEvent>(IEnumerable<TEvent>)	以原子序列的形式引发多个事件。 (继承自 JournaledGrain<TGrainState,TEventBase>)
RefreshNow()	立即检索最新状态，并确认以前引发的所有事件。 实际上，这会强制实现与全局状态的同步。 在读取状态之前等待此状态，以确保强一致性（线性化），即使有此粒度的多个实例 (继承自 JournaledGrain<TGrainState,TEventBase>)
RegisterOrUpdateReminder(String, TimeSpan, TimeSpan)	注册持久可靠的提醒，以将常规通知（提醒）发送到粒度。 粒度必须实现 Orleans.IRemindable 接口，并且此粒度的提醒将发送到 ReceiveReminder 回调方法。 如果在计时器触发时停用当前粒度，则会创建此粒度的新激活来接收此提醒。 如果现有提醒已存在同名，则会用此新提醒覆盖该提醒。 即使此粒度存在多个激活，也始终会收到一次此粒度激活的提醒。 (继承自 Grain)
RegisterTimer(Func<Object,Task>, Object, TimeSpan, TimeSpan)	已过时. 注册计时器以向此粒度发送定期回调。 (继承自 Grain)
RetrieveConfirmedEvents(Int32, Int32)	从存储中检索确认事件序列的段。 如果事件无法读取，则引发 NotSupportedException。 事件是否可用，以及事件的时间长度取决于使用的提供程序以及它们的配置方式。 (继承自 JournaledGrain<TGrainState,TEventBase>)
TransitionState(TGrainState, TEventBase)	定义如何将事件应用于状态。 除非在子类中重写该函数，否则它将对状态调用动态“Apply”函数，并将事件作为参数。 此方法引发的所有异常均由日志视图提供程序捕获和记录。 重写此选项以自定义如何转换给定事件的状态。 (继承自 JournaledGrain<TGrainState,TEventBase>)
UnregisterReminder(IGrainReminder)	取消注册以前注册的提醒。 (继承自 Grain)

显式接口实现

IConnectionIssueListener.OnConnectionIssue(ConnectionIssue)	由适配器在连接问题上调用。 (继承自 JournaledGrain<TGrainState,TEventBase>)
IConnectionIssueListener.OnConnectionIssueResolved(ConnectionIssue)	解决连接问题时由适配器调用。 (继承自 JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.DeactivateProtocolParticipant()	通知日志视图停用适配器 (继承自 JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PostActivateProtocolParticipant()	通知日志视图激活适配器（在用户级别 OnActivate 后调用） (继承自 JournaledGrain<TGrainState,TEventBase>)
ILogConsistencyProtocolParticipant.PreActivateProtocolParticipant()	通知日志视图激活适配器（在用户级别 OnActivate 之前调用） (继承自 JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.OnViewChanged(Boolean, Boolean)	由适配器在状态更改时调用。 (继承自 JournaledGrain<TGrainState,TEventBase>)
ILogViewAdaptorHost<TGrainState,TEventBase>.UpdateView(TGrainState, TEventBase)	通过适配器调用，以便在追加条目时更新视图。 (继承自 JournaledGrain<TGrainState,TEventBase>)

扩展方法

DeactivateOnIdle(IGrainBase)	完成当前粒度方法调用后，停用此粒度激活。 此调用将标记当前粒度的激活，以在当前方法末尾停用和删除。 下次调用此粒度将导致使用不同的激活，这通常意味着运行时会自动创建新的激活。
MigrateOnIdle(IGrainBase)	开始尝试将此实例迁移到另一个位置。 迁移捕获当前 RequestContext，使其可供激活的放置控制器使用，以便在选择新位置时可以考虑它。 迁移将异步发生，如果未执行任何请求，并且如果激活的放置控制器未选择备用位置，则不会发生迁移。
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, GrainTimerCreationOptions)	创建粒度计时器。
RegisterGrainTimer(IGrainBase, Func<CancellationToken,Task>, TimeSpan, TimeSpan)	创建粒度计时器。
RegisterGrainTimer(IGrainBase, Func<Task>, GrainTimerCreationOptions)	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。
RegisterGrainTimer(IGrainBase, Func<Task>, TimeSpan, TimeSpan)	创建粒度计时器。
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, GrainTimerCreationOptions)	创建粒度计时器。
RegisterGrainTimer<TState>(IGrainBase, Func<TState,CancellationToken,Task>, TState, TimeSpan, TimeSpan)	创建粒度计时器。
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, GrainTimerCreationOptions)	使用标准事件溯源术语的日志一致性粒度的基类。 所有操作都重新进入安全。
RegisterGrainTimer<TState>(IGrainBase, Func<TState,Task>, TState, TimeSpan, TimeSpan)	创建粒度计时器。
AsReference(IAddressable, Type)	返回对提供的粒度的类型化引用。
AsReference<TGrainInterface>(IAddressable)	返回对提供的粒度的类型化引用。
Cast(IAddressable, Type)	返回对提供的粒度的类型化引用。
Cast<TGrainInterface>(IAddressable)	返回对提供的粒度的类型化引用。
GetGrainId(IAddressable)	返回与提供的粒度对应的粒度 ID。
GetPrimaryKey(IAddressable)	返回粒度主键的 Guid 表示形式。
GetPrimaryKey(IAddressable, String)	返回粒度主键的 Guid 表示形式。
GetPrimaryKeyLong(IAddressable)	返回粒度主键的 long 表示形式。
GetPrimaryKeyLong(IAddressable, String)	返回粒度主键的 long 表示形式。
GetPrimaryKeyString(IAddressable)	返回粒度 string 主键。
IsPrimaryKeyBasedOnLong(IAddressable)	返回主键的一部分是否为类型 long。
GetReminder(Grain, String)	返回以前注册的提醒。
GetReminder(IGrainBase, String)	返回以前注册的提醒。
GetReminders(Grain)	返回由粒度注册的所有提醒的列表。
GetReminders(IGrainBase)	返回由粒度注册的所有提醒的列表。
RegisterOrUpdateReminder(Grain, String, TimeSpan, TimeSpan)	注册持久可靠的提醒，以将常规通知（提醒）发送到粒度。 粒度必须实现 Orleans.IRemindable 接口，并且此粒度的提醒将发送到 ReceiveReminder 回调方法。 如果在计时器触发时停用当前粒度，则会创建此粒度的新激活来接收此提醒。 如果现有提醒已存在同名，则会用此新提醒覆盖该提醒。 即使此粒度存在多个激活，也始终会收到一次此粒度激活的提醒。
RegisterOrUpdateReminder(IGrainBase, String, TimeSpan, TimeSpan)	注册持久可靠的提醒，以将常规通知（提醒）发送到粒度。 粒度必须实现 Orleans.IRemindable 接口，并且此粒度的提醒将发送到 ReceiveReminder 回调方法。 如果在计时器触发时停用当前粒度，则会创建此粒度的新激活来接收此提醒。 如果现有提醒已存在同名，则会用此新提醒覆盖该提醒。 即使此粒度存在多个激活，也始终会收到一次此粒度激活的提醒。
UnregisterReminder(Grain, IGrainReminder)	取消注册以前注册的提醒。
UnregisterReminder(IGrainBase, IGrainReminder)	取消注册以前注册的提醒。
GetStreamProvider(Grain, String)	获取具有指定 name的流提供程序。
GetStreamProvider(IGrainBase, String)	获取具有指定 name的流提供程序。