Struct SyncEngine 

pub struct SyncEngine { /* private fields */ }

Implementations

impl SyncEngine

pub fn new(redis: Arc<RedisClient>) -> Self

pub async fn publish_event<T: Serialize + Send + Sync>( &self, stream_key: &str, event: SyncEvent<T>, ) -> Result<(), AppError>

Publishes a Sync Event to the Redis Pub/Sub stream so a background worker can pick it up. Used by the primary database controller (e.g. Mongo).

pub async fn start_worker<T, U, M>(&self, stream_key: String, mapper: M)

where T: for<'de> Deserialize<'de> + Send + Sync + 'static, U: Send + Sync + 'static, M: SyncMap<T, U> + Send + Sync + 'static,

Starts a background worker that listens to a Redis stream, maps the incoming data, and writes it to the target database (Polyglot Sync).