Method GetThrottleQuery

go/base/context.go:744–750

()

}

func (mctx *MigrationContext) GetThrottleQuery() string {
	mctx.throttleMutex.Lock()
	defer mctx.throttleMutex.Unlock()

	var query = mctx.throttleQuery
	return query
}

func (mctx *MigrationContext) SetThrottleQuery(newQuery string) {
	mctx.throttleMutex.Lock()