oversync-connectors 0.6.3

Source connector implementations for oversync.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33

//! Source connector implementations for oversync.
//!
//! Each connector implements [`OriginConnector`] to fetch rows from an external source.

pub mod clickhouse;
pub mod factory;
pub mod flight_sql;
pub mod graphql;
pub mod http_common;
pub mod http_source;
pub mod kafka_source;
pub mod mcp;
pub mod mysql;
pub mod postgres;
pub mod surrealdb_source;
pub mod trino;

pub use clickhouse::ClickHouseConnector;
pub use factory::{
	ClickHouseOriginFactory, FlightSqlOriginFactory, GraphqlOriginFactory, HttpOriginFactory,
	KafkaOriginFactory, McpOriginFactory, MysqlOriginFactory, PostgresOriginFactory,
	SurrealDbOriginFactory, 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 oversync_core::traits::OriginConnector;
pub use postgres::PostgresConnector;
pub use surrealdb_source::{SurrealDbConnector, SurrealDbLiveConnector};
pub use trino::TrinoConnector;