Versions in this module Expand all Collapse all v1 v1.2.3 Aug 25, 2022 v1.0.2 Aug 25, 2022 v1.0.1 Aug 25, 2022 Changes in this version + var EnsureTrailingDNsAreDrainedOrBlock = polardbxv1reconcile.NewStepBinder("EnsureTrailingDNsAreDrainedOrRestartRebalance", ...) + var PrepareRebalanceTaskContext = polardbxv1reconcile.NewStepBinder("PrepareRebalanceTaskContext", ...) + var ResetRebalanceTask = polardbxv1reconcile.NewStepBinder("ResetRebalanceTask", ...) + var StartRebalanceTask = polardbxv1reconcile.NewStepBinder("StartRebalanceTask", ...) + func IsTrailingDNsDrained(rc *polardbxv1reconcile.Context, rebalanceTask *DataRebalanceTask) (bool, error) + func WatchRebalanceTaskAntUpdateProgress(interval time.Duration) control.BindFunc + type DataRebalanceTask struct + From int + PlanId *string + To int + func (t *DataRebalanceTask) IsReady(rc *polardbxv1reconcile.Context) (bool, error) + func (t *DataRebalanceTask) Progress(rc *polardbxv1reconcile.Context) (int, error) + func (t *DataRebalanceTask) Skip() bool + func (t *DataRebalanceTask) Start(rc *polardbxv1reconcile.Context) (string, error) + func (t *DataRebalanceTask) Started() bool