GetAbortError retrieves the stored abort error
()
| 1019 | |
| 1020 | // GetAbortError retrieves the stored abort error |
| 1021 | func (mctx *MigrationContext) GetAbortError() error { |
| 1022 | mctx.abortMutex.Lock() |
| 1023 | defer mctx.abortMutex.Unlock() |
| 1024 | return mctx.AbortError |
| 1025 | } |
| 1026 | |
| 1027 | // CancelContext cancels the migration context to signal all goroutines to stop |
| 1028 | // The cancel function is safe to call multiple times and from multiple goroutines. |
no outgoing calls