Skip to content

Commit 0550286

Browse files
authored
feat(databend sink): service use databend-client (vectordotdev#20244)
* feat(databend sink): service use databend-client * fix: better docs for config * fix: update stage attachment ref in docs * chore: add changelog file * chore: update license file
1 parent 9080d05 commit 0550286

File tree

13 files changed

+181
-504
lines changed

13 files changed

+181
-504
lines changed

Cargo.lock

+25-11
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

+2-1
Original file line numberDiff line numberDiff line change
@@ -267,6 +267,7 @@ chrono-tz = { version = "0.8.6", default-features = false }
267267
cidr-utils = { version = "0.6.1", default-features = false }
268268
colored = { version = "2.1.0", default-features = false }
269269
csv = { version = "1.3", default-features = false }
270+
databend-client ={ version = "0.16.1", default-features = false, features = ["rustls"], optional = true }
270271
derivative = { version = "2.2.0", default-features = false }
271272
dirs-next = { version = "2.0.0", default-features = false, optional = true }
272273
dyn-clone = { version = "1.0.17", default-features = false }
@@ -719,7 +720,7 @@ sinks-blackhole = []
719720
sinks-chronicle = []
720721
sinks-clickhouse = []
721722
sinks-console = []
722-
sinks-databend = []
723+
sinks-databend = ["dep:databend-client"]
723724
sinks-datadog_events = []
724725
sinks-datadog_logs = []
725726
sinks-datadog_metrics = ["protobuf-build", "dep:prost-reflect"]

LICENSE-3rdparty.csv

+1
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ dary_heap,https://github.com/hanmertens/dary_heap,MIT OR Apache-2.0,Han Mertens
160160
dashmap,https://github.com/xacrimon/dashmap,MIT,Acrimon <[email protected]>
161161
data-encoding,https://github.com/ia0/data-encoding,MIT,Julien Cretin <[email protected]>
162162
data-url,https://github.com/servo/rust-url,MIT OR Apache-2.0,Simon Sapin <[email protected]>
163+
databend-client,https://github.com/datafuselabs/bendsql,Apache-2.0,Databend Authors <[email protected]>
163164
debug-helper,https://github.com/magiclen/debug-helper,MIT,Magic Len <[email protected]>
164165
der,https://github.com/RustCrypto/formats/tree/master/der,Apache-2.0 OR MIT,RustCrypto Developers
165166
deranged,https://github.com/jhpratt/deranged,MIT OR Apache-2.0,Jacob Pratt <[email protected]>
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
Changed the previous inner databend client to client provided by databend rust driver in https://github.com/datafuselabs/bendsql/. With the new client, the `endpoint` config supports both HTTP URI like `http://localhost:8000` as well as DSN like `databend://root:@localhost:8000/mydatabase?sslmode=disable&arg=value` which could provide more customization for the inner client.
2+
3+
authors: everpcpc

scripts/integration/databend/test.yaml

+1-3
Original file line numberDiff line numberDiff line change
@@ -5,9 +5,7 @@ test_filter: '::databend::'
55

66
runner:
77
env:
8-
DATABEND_ENDPOINT: http://databend:8000
9-
DATABEND_USER: vector
10-
DATABEND_PASSWORD: vector
8+
DATABEND_ENDPOINT: databend://vector:vector@databend:8000?sslmode=disable&presign=detect
119

1210
matrix:
1311
version: ['latest']

src/sinks/databend/api.rs

-218
This file was deleted.

0 commit comments

Comments
 (0)