Struct libsql_replication::Replicator

pub struct Replicator {
    pub frames_sender: Sender<Frames>,
    pub current_frame_no_notifier: Receiver<FrameNo>,
    pub meta: Arc<Mutex<Option<WalIndexMeta>>>,
    pub injector: FrameInjector<'static>,
    pub client: Option<Client>,
    pub next_offset: AtomicU64,
    /* private fields */
}

Fields

frames_sender: Sender<Frames>

current_frame_no_notifier: Receiver<FrameNo>

meta: Arc<Mutex<Option<WalIndexMeta>>>

injector: FrameInjector<'static>

client: Option<Client>

next_offset: AtomicU64

Implementations

impl Replicator

pub fn new(path: impl AsRef<Path>) -> Result<Self>

pub async fn init_metadata( &mut self, endpoint: impl AsRef<str>, auth_token: impl AsRef<str> ) -> Result<WalIndexMeta>

pub fn update_metadata_from_snapshot_header( &self, path: impl AsRef<Path> ) -> Result<()>

pub fn writer(&self) -> Result<Writer>

pub fn sync(&self, frames: Frames) -> Result<()>

pub async fn sync_from_http(&self) -> Result<usize>