85
86
// add applies sizeDiff to stats.HistorySize and remembers it so it can be reverted.
87
>
func (r *historySizeRollback) add(stats *persistencespb.ExecutionStats, sizeDiff int) {
execution_manager.go
88
>
delta := int64(sizeDiff)
89
>
stats.HistorySize += delta
90
>
r.applied = append(r.applied, appliedHistorySize{stats: stats, delta: delta})
91
>
}
92
93
// revertOnError undoes every applied increment if *err is non-nil. Intended to be deferred
94
// against a function's named return error.
96
>
if *err == nil {
97
return
98
}