(key mysql.InstanceKey)
| 896 | } |
| 897 | |
| 898 | func (mctx *MigrationContext) AddThrottleControlReplicaKey(key mysql.InstanceKey) error { |
| 899 | mctx.throttleMutex.Lock() |
| 900 | defer mctx.throttleMutex.Unlock() |
| 901 | |
| 902 | mctx.throttleControlReplicaKeys.AddKey(key) |
| 903 | return nil |
| 904 | } |
| 905 | |
| 906 | // ApplyCredentials sorts out the credentials between the config file and the CLI flags |
| 907 | func (mctx *MigrationContext) ApplyCredentials() { |
no test coverage detected