wp-connector-api 0.9.0

Connector runtime traits, config helpers, and errors for WarpParse sinks and sources
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

mod config;
mod errors;
mod runtime;
mod types;
extern crate async_trait;
extern crate serde;
extern crate wp_model_core;
// keep top-level convenient re-exports stable
pub use config::param::{parammap_from_toml_map, parammap_from_toml_table};
pub use errors::{
    ReasonSummary, SinkError, SinkErrorOwe, SinkReason, SinkResult, SourceError, SourceReason,
    SourceResult,
};
// Friendly aliases exposed at crate root
pub use errors::sink::{ReasonSummary as ErrorSummary, SinkErrorOwe as SinkResultExt};

// --- Convenient top-level re-exports for common use cases ---
// Config-time adapter (conn_url -> params)
pub use config::adapter::ConnectorKindAdapter;
pub use runtime::cnn::{ConnectorDef, ConnectorScope, SinkDefProvider, SourceDefProvider};
pub use types::ParamMap;
// Runtime: sink side
pub use runtime::sink::{
    AsyncCtrl, AsyncRawDataSink, AsyncRecordSink, AsyncSink, ResolvedSinkSpec as SinkSpec,
    SinkBuildCtx, SinkFactory, SinkHandle,
};

pub use runtime::source::{
    AcceptorHandle, AckToken, ControlEvent, CtrlRx, DataSource, EventPreHook,
    ResolvedSourceSpec as SourceSpec, SeekPosition, ServiceAcceptor, SourceBatch, SourceBuildCtx,
    SourceCaps, SourceEvent, SourceFactory, SourceHandle, SourceMeta, SourceSvcIns, Tags,
};