Struct ReplicationInfo 

pub struct ReplicationInfo { /* private fields */ }

Implementação thread-safe da interface ReplicationInfo. Utiliza um RwLock para garantir acesso seguro de múltiplas threads.

Esta implementação fornece:

• Acesso thread-safe através de RwLock
• Operações atômicas para get/set de progresso e máximo
• Métodos de conveniência para operações comuns

Implementations

impl ReplicationInfo

pub async fn clone_with_values(&self) -> Self

Cria um clone que preserva os valores atuais. Esta é uma operação assíncrona pois precisa ler o estado atual.

impl ReplicationInfo

pub fn new() -> Self

Cria uma nova instância de ReplicationInfo.

pub fn with_values(progress: usize, max: usize) -> Self

Cria uma nova instância com valores iniciais.

pub async fn increment_progress(&self)

Incrementa o progresso em 1. Conveniência para operações de incremento simples.

pub async fn increment_progress_by(&self, amount: usize)

Incrementa o progresso por um valor específico. Usa saturating_add para evitar overflow.

pub async fn is_complete(&self) -> bool

Retorna se a replicação está completa (progress >= max).

pub async fn progress_ratio(&self) -> f64

Retorna o percentual de progresso (0.0 a 1.0). Retorna 0.0 se max for 0.

pub async fn progress_percentage(&self) -> u8

Retorna o percentual de progresso (0 a 100). Retorna 0 se max for 0.

pub async fn get_progress_and_max(&self) -> (usize, usize)

Obtém tanto o progresso quanto o máximo em uma única operação. Mais eficiente que chamadas separadas quando ambos os valores são necessários.

pub async fn set_progress_and_max(&self, progress: usize, max: usize)

Define tanto o progresso quanto o máximo em uma única operação atômica. Mais eficiente que chamadas separadas.

pub async fn increment_max(&self, amount: usize)

Aplica um incremento ao máximo, usado quando novos itens são descobertos.

pub async fn to_string(&self) -> String

Retorna uma representação em string do progresso atual.

pub async fn is_valid(&self) -> bool

Verifica se os valores são válidos (progress <= max).

Trait Implementations

impl Clone for ReplicationInfo

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplicationInfo

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

Formats the value using the given formatter.

impl Default for ReplicationInfo

fn default() -> ReplicationInfo

Returns the “default value” for a type.

impl ReplicationInfo for ReplicationInfo

async fn get_progress(&self) -> usize

Retorna o progresso atual (número de entradas processadas).

async fn get_max(&self) -> usize

Retorna o número máximo de entradas a serem processadas.

async fn set_progress(&self, i: usize)

Define o progresso atual.

async fn set_max(&self, i: usize)

Define o número máximo de entradas.

async fn reset(&self)

Reinicia todos os valores para 0.