oversync_connectors/
lib.rs

1//! Source connector implementations for oversync.
2//!
3//! Each connector implements [`OriginConnector`] to fetch rows from an external source.
4
5pub mod clickhouse;
6pub mod factory;
7pub mod flight_sql;
8pub mod graphql;
9pub mod http_common;
10pub mod http_source;
11pub mod kafka_source;
12pub mod mcp;
13pub mod mysql;
14pub mod postgres;
15pub mod surrealdb_source;
16pub mod trino;
17
18pub use clickhouse::ClickHouseConnector;
19pub use factory::{
20	ClickHouseOriginFactory, FlightSqlOriginFactory, GraphqlOriginFactory, HttpOriginFactory,
21	KafkaOriginFactory, McpOriginFactory, MysqlOriginFactory, PostgresOriginFactory,
22	SurrealDbOriginFactory, TrinoOriginFactory,
23};
24pub use flight_sql::FlightSqlConnector;
25pub use graphql::GraphqlConnector;
26pub use http_source::HttpSource;
27pub use kafka_source::KafkaSourceConnector;
28pub use mcp::McpOriginConnector;
29pub use mysql::MysqlConnector;
30pub use oversync_core::traits::OriginConnector;
31pub use postgres::PostgresConnector;
32pub use surrealdb_source::{SurrealDbConnector, SurrealDbLiveConnector};
33pub use trino::TrinoConnector;
oversync_connectors/lib.rs

oversync_connectors/
lib.rs
