Method SetETADuration

go/base/context.go:609–611

(etaDuration time.Duration)

}

func (mctx *MigrationContext) SetETADuration(etaDuration time.Duration) {
	atomic.StoreInt64(&mctx.etaNanoseonds, etaDuration.Nanoseconds())
}

func (mctx *MigrationContext) GetETASeconds() int64 {
	nano := atomic.LoadInt64(&mctx.etaNanoseonds)