Struct SyncPlugin 

pub struct SyncPlugin { /* private fields */ }

Plugin that marks auto-sync as active. Sends change notifications to the background push task via an mpsc channel.

Implementations

impl SyncPlugin

pub fn new(tx: UnboundedSender<()>) -> Self

pub fn set_auto(&self, enabled: bool)

Enable or disable auto-sync.

pub fn is_auto(&self) -> bool

Check if auto-sync is enabled.

pub fn pending_lsn(&self) -> u64

pub fn notify_change(&self) -> Result<(), &'static str>

Signal the background push task that a DML change occurred.

pub fn shutdown(&self)

Shutdown: drop the sender to close the channel and stop the background task.

Trait Implementations

impl DatabasePlugin for SyncPlugin

fn post_commit(&self, ws: &WriteSet, source: CommitSource)

fn pre_commit(&self, _ws: &WriteSet, _source: CommitSource) -> Result<(), Error>

fn on_open(&self) -> Result<(), Error>

fn on_close(&self) -> Result<(), Error>

fn on_ddl(&self, _change: &DdlChange) -> Result<(), Error>

fn on_query(&self, _sql: &str) -> Result<(), Error>

fn post_query(&self, _sql: &str, _duration: Duration, _outcome: &QueryOutcome)

fn health(&self) -> PluginHealth

fn describe(&self) -> Value

fn on_sync_push(&self, _changeset: &mut ChangeSet) -> Result<(), Error>

fn on_sync_pull(&self, _changeset: &mut ChangeSet) -> Result<(), Error>