Skip to content

Commit 01c8304

Browse files
committed
feat: Development of UDP sink connector
1 parent 298436c commit 01c8304

3 files changed

Lines changed: 60 additions & 72 deletions

File tree

Cargo.lock

Lines changed: 51 additions & 66 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -199,13 +199,13 @@ wp-proj = { package = "wp-proj", git = "https://github.com/wp-labs/w
199199

200200
wp-self-update = "0.3"
201201
wp-connectors = { git = "https://github.com/wp-labs/wp-connectors", tag = "v0.14.4", optional = true }
202-
wp-connectors-labs = { git = "https://github.com/wp-labs/wp-connectors-labs.git", tag = "v0.1.6", optional = true, features = ["dmdb"] }
203-
# wp-connectors-labs = {package = "wp-connectors-labs", path = "../wp-connectors-exp", optional = true, features = ["dmdb"] }
202+
wp-connectors-labs = { git = "https://github.com/wp-labs/wp-connectors-labs.git", tag = "v0.1.7", optional = true, features = ["dmdb", "udp"] }
203+
# wp-connectors-labs = {package = "wp-connectors-labs", path = "../wp-connectors-exp", optional = true, features = ["dmdb", "udp"] }
204204
# @gxl:block(local_motor)
205-
#wp-engine = { path = "../wp-motor" }
206-
#wp-config = { path = "../wp-motor/crates/wp-config" }
207-
#wp-cli-core = { path = "../wp-motor/crates/wp-cli-core" }
208-
#wp-proj = { path = "../wp-motor/crates/wp-proj" }
205+
# wp-engine = { path = "../wp-motor" }
206+
# wp-config = { path = "../wp-motor/crates/wp-config" }
207+
# wp-cli-core = { path = "../wp-motor/crates/wp-cli-core" }
208+
# wp-proj = { path = "../wp-motor/crates/wp-proj" }
209209
# @gxl:end(local_motor)
210210

211211
# wp-enterprise = { path = "../wp-enterprise" }

src/feats.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,5 +68,8 @@ pub fn register_optional_connectors() {
6868
// Dmdb (达梦数据库, experimental)
6969
register_source_factory(wp_connectors_labs::dmdb::DmdbSourceFactory);
7070
register_sink_factory(wp_connectors_labs::dmdb::DmdbSinkFactory);
71+
72+
// UDP (experimental)
73+
register_sink_factory(wp_connectors_labs::udp::UdpSinkFactory);
7174
}
7275
}

0 commit comments

Comments
 (0)