Crate oversync_connectors 

Source connector implementations for oversync.

Each connector implements OriginConnector to fetch rows from an external source.

Re-exports

pub use clickhouse::ClickHouseConnector;

pub use factory::ClickHouseOriginFactory;

pub use factory::FlightSqlOriginFactory;

pub use factory::GraphqlOriginFactory;

pub use factory::HttpOriginFactory;

pub use factory::KafkaOriginFactory;

pub use factory::McpOriginFactory;

pub use factory::MysqlOriginFactory;

pub use factory::PostgresOriginFactory;

pub use factory::SurrealDbOriginFactory;

pub use factory::TrinoOriginFactory;

pub use flight_sql::FlightSqlConnector;

pub use graphql::GraphqlConnector;

pub use http_source::HttpSource;

pub use kafka_source::KafkaSourceConnector;

pub use mcp::McpOriginConnector;

pub use mysql::MysqlConnector;

pub use postgres::PostgresConnector;

pub use surrealdb_source::SurrealDbConnector;

pub use surrealdb_source::SurrealDbLiveConnector;

pub use trino::TrinoConnector;

Modules

clickhouse

factory

flight_sql

graphql

http_common

http_source

kafka_source

mcp

mysql

postgres

surrealdb_source

trino

Traits

OriginConnector

An origin connector fetches rows from an external data source.