wp_connector_api/
lib.rs

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

wp_connector_api/
lib.rs
