Crate oversync 

oversync — a lightweight data sync engine: poll, delta, sink.

Quick Start (embedded)

use oversync::OversyncEngine;

let engine = OversyncEngine::builder("mem://")
    .skip_schema(true)
    .build()
    .await?;
engine.start_from_toml(std::path::Path::new("oversync.toml")).await?;
// engine.shutdown().await;

Re-exports

pub use config::SyncConfig;

pub use config_db::load_config_from_db;

pub use cycle::CycleConfig;

pub use cycle::CycleRunner;

pub use embedded::EmbeddedSync;

pub use embedded::EmbeddedSyncBuilder;

pub use engine::OversyncEngine;

pub use lifecycle::LifecycleManager;

pub use registry::PluginRegistry;

pub use scheduler::Scheduler;

Modules

alerting

config

config_db

config_version

credential

cycle

distributed_lock

dlq

dry_run

embedded

engine

error

lifecycle

metrics

model

pipe_status

rate_limit

registry

resilient_db

Dual-connection SurrealDB wrapper with proactive health checking.

scheduler

table_names

Per-pipeline SurrealDB table names.

traits

Structs

DeltaEvent

DeltaResult

EventEnvelope

Wire format for sink delivery. Each event is one message.

EventMeta

KafkaAuth

OversyncConfig

RawRow

TableNames

Table names for a sync pipeline’s internal state.

TransformPipeline

Chain multiple TransformHooks into a sequential pipeline.

Enums

AuthConfig

CycleStatus

OpType

OversyncError

Traits

OriginConnector

An origin connector fetches rows from an external data source.

OriginFactory

Factory for creating OriginConnectors from a JSON config object.

Sink

A target connector delivers delta events to a destination.

TargetFactory

Factory for creating Sink target connectors from a JSON config object.

TransformHook

Rust-native event transform hook. Consumers implement this to modify EventEnvelopes in-flight before they reach sinks. Takes precedence over SurrealQL fn::* transforms when set on a [CycleRunner].

Functions

compute_diff