Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
func NewReconciler ¶
func NewReconciler(s *store.Store, k *kernel.Kernel) *Reconciler
NewReconciler seeds its cursor from the durable decision log (Store.MaxDecidedSeq), so a process restart resumes after the last consumed event instead of re-reading the log from 0 and re-deciding already-accepted events (which would pollute pull feedback). The decision log is the cursor.
The liveness-escalation counter (Invariant #10) is NOT kept in memory either — it is derived per event from the durable log (Store.DeferralCount), so escalation survives restart exactly as the cursor does.
Click to show internal directories.
Click to hide internal directories.