(throttleControlReplicas string)
| 883 | } |
| 884 | |
| 885 | func (mctx *MigrationContext) ReadThrottleControlReplicaKeys(throttleControlReplicas string) error { |
| 886 | keys := mysql.NewInstanceKeyMap() |
| 887 | if err := keys.ReadCommaDelimitedList(throttleControlReplicas); err != nil { |
| 888 | return err |
| 889 | } |
| 890 | |
| 891 | mctx.throttleMutex.Lock() |
| 892 | defer mctx.throttleMutex.Unlock() |
| 893 | |
| 894 | mctx.throttleControlReplicaKeys = keys |
| 895 | return nil |
| 896 | } |
| 897 | |
| 898 | func (mctx *MigrationContext) AddThrottleControlReplicaKey(key mysql.InstanceKey) error { |
| 899 | mctx.throttleMutex.Lock() |
no test coverage detected