(newQuery string)
| 750 | } |
| 751 | |
| 752 | func (mctx *MigrationContext) SetThrottleQuery(newQuery string) { |
| 753 | mctx.throttleMutex.Lock() |
| 754 | defer mctx.throttleMutex.Unlock() |
| 755 | |
| 756 | mctx.throttleQuery = newQuery |
| 757 | } |
| 758 | |
| 759 | func (mctx *MigrationContext) GetThrottleHTTP() string { |
| 760 | mctx.throttleHTTPMutex.Lock() |
no outgoing calls
no test coverage detected