(progressPct float64)
| 599 | } |
| 600 | |
| 601 | func (mctx *MigrationContext) SetProgressPct(progressPct float64) { |
| 602 | atomic.StoreUint64(&mctx.currentProgress, math.Float64bits(progressPct)) |
| 603 | } |
| 604 | |
| 605 | func (mctx *MigrationContext) GetETADuration() time.Duration { |
| 606 | return time.Duration(atomic.LoadInt64(&mctx.etaNanoseonds)) |
no outgoing calls