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

wp_connector_api/
lib.rs
