Struct UpgradeCandidateRegion

pub struct UpgradeCandidateRegion {
    pub(crate) optimistic_retry: usize,
    pub(crate) retry_initial_interval: Duration,
    pub(crate) require_ready: bool,
}

Fields

optimistic_retry: usize

retry_initial_interval: Duration

require_ready: bool

Implementations

impl UpgradeCandidateRegion

fn build_upgrade_region_instruction( &self, ctx: &Context, replay_timeout: Duration, ) -> Instruction

Builds upgrade region instruction.

async fn upgrade_region(&self, ctx: &Context) -> Result<()>

Tries to upgrade a candidate region.

Retry:

• If require_ready is true, but the candidate region returns ready is false.
• MailboxTimeout, Timeout.

Abort:

• The candidate region doesn’t exist.
• PusherNotFound, The datanode is unreachable.
• PushMessage, The receiver is dropped.
• MailboxReceiver, The sender is dropped without sending (impossible).
• UnexpectedInstructionReply (impossible).
• ExceededDeadline
• Invalid JSON (impossible).

async fn upgrade_region_with_retry(&self, ctx: &mut Context) -> bool

Upgrades a candidate region.

Returns true if the candidate region is upgraded successfully.

Trait Implementations

impl Debug for UpgradeCandidateRegion

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for UpgradeCandidateRegion

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for UpgradeCandidateRegion

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for UpgradeCandidateRegion

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl State for UpgradeCandidateRegion

fn next<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<(Box<dyn State>, Status)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Yields the next State and Status.

fn as_any(&self) -> &dyn Any

Returns as Any.

fn name(&self) -> &'static str