wp_connector_api/
lib.rs

1mod config;
2mod errors;
3mod runtime;
4mod types;
5extern crate async_trait;
6extern crate serde;
7extern crate thiserror;
8extern crate wp_model_core;
9// keep top-level convenient re-exports stable
10pub use config::param::{parammap_from_toml_map, parammap_from_toml_table};
11pub use errors::{
12    ReasonSummary, SinkError, SinkErrorOwe, SinkReason, SinkResult, SourceError, SourceReason,
13    SourceResult,
14};
15// Friendly aliases exposed at crate root
16pub use errors::sink::{ReasonSummary as ErrorSummary, SinkErrorOwe as SinkResultExt};
17
18// --- Convenient top-level re-exports for common use cases ---
19// Config-time adapter (conn_url -> params)
20pub use config::adapter::ConnectorKindAdapter;
21pub use runtime::cnn::{ConnectorDef, ConnectorScope, SinkDefProvider, SourceDefProvider};
22pub use types::ParamMap;
23// Runtime: sink side
24pub use runtime::sink::{
25    AsyncCtrl, AsyncRawDataSink, AsyncRecordSink, AsyncSink, ResolvedSinkSpec as SinkSpec,
26    SinkBuildCtx, SinkFactory, SinkHandle,
27};
28
29pub use runtime::source::{
30    AcceptorHandle, AckToken, ControlEvent, CtrlRx, DataSource, EventPreHook,
31    ResolvedSourceSpec as SourceSpec, SeekPosition, ServiceAcceptor, SourceBatch, SourceBuildCtx,
32    SourceCaps, SourceEvent, SourceFactory, SourceHandle, SourceMeta, SourceSvcIns, Tags,
33};
wp_connector_api/lib.rs

wp_connector_api/
lib.rs
