Crate wp_connector_api

Crate wp_connector_api 

Source

Structs§

AcceptorHandle
包含 acceptor 具体实例及可读名称。
ConnectorDef
Connector definition containing metadata and default configuration.
SinkBuildCtx
Build context passed to sink factories during construction.
SinkHandle
Handle wrapping a boxed async sink instance.
SinkSpec
Resolved sink specification with all parameters flattened.
SourceBuildCtx
SourceCaps
Capability flags for data sources.
SourceEvent
SourceHandle
单个可注册的数据源实例。
SourceMeta
数据源元信息，供 orchestrator/调度层用于统计与展示。
SourceSpec
ResolvedSourceSpec：统一 Factory 构建使用的规格（包含 connector_id，参数一律扁平）。
SourceSvcIns
SourceFactory::build 的统一返回结构。
Tags
A lightweight, sorted collection of key-value string tags.

Enums§

ConnectorScope
Defines whether a connector operates as a data source or sink.
ControlEvent
Control events for managing data source lifecycle.
SinkReason
SourceReason

Traits§

AckToken
Marker trait for acknowledgment tokens.
AsyncCtrl
Runtime control trait for managing sink lifecycle.
AsyncRawDataSink
Trait for sinking raw data (strings and bytes).
AsyncRecordSink
Trait for sinking structured records.
AsyncSink
Combined trait for full-featured async sinks.
ConnectorKindAdapter
Adapter trait for parsing connector URL into flattened params and providing defaults.
DataSource
Core trait for data sources.
ErrorSummary
ReasonSummary
SeekPosition
Marker trait for seek positions.
ServiceAcceptor
SinkDefProvider
Trait for connectors that can act as a data sink.
SinkErrorOwe
SinkFactory
Factory trait for creating sink instances.
SinkResultExt
SourceDefProvider
Trait for connectors that can act as a data source.
SourceFactory

Functions§

parammap_from_toml_map
parammap_from_toml_table

Type Aliases§

CtrlRx
Control channel receiver type.
EventPreHook
Parse 侧预处理钩子
ParamMap
SinkError
SinkResult
SourceBatch
一批源事件，便于批量传输；允许返回空 Vec 代表暂时无数据。 A batch of events for bulk delivery; empty Vec means “no data for now”.
SourceError
SourceResult