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>,
    /* private fields */
}

Fields

frames_sender: Sender<Frames>

current_frame_no_notifier: Receiver<FrameNo>

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

injector: FrameInjector<'static>

Implementations

impl Replicator

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

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

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