arkflow-plugin 0.1.0

High-performance Rust flow processing engine
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

[package]
name = "arkflow-plugin"
version.workspace = true
edition.workspace = true
description.workspace = true
authors.workspace = true
repository.workspace = true
homepage.workspace = true
license.workspace = true



[dependencies]
tokio = { workspace = true }
async-trait = { workspace = true }
futures = { workspace = true }
waitgroup = { workspace = true }

serde = { workspace = true }

serde_json = { workspace = true }
serde_yaml = { workspace = true }
humantime = { workspace = true }

thiserror = { workspace = true }
anyhow = { workspace = true }

tracing = { workspace = true }
tracing-subscriber = { workspace = true }
prometheus = { workspace = true }

datafusion = { workspace = true }
arrow-json = { workspace = true }
prost-reflect = { workspace = true }
prost-types = { workspace = true }
protobuf-parse = { workspace = true }
protobuf = { workspace = true }


toml = { workspace = true }
lazy_static = { workspace = true }

axum = { workspace = true }
reqwest = { workspace = true }


clap = { workspace = true }
colored = { workspace = true }

flume = { workspace = true }
rumqttc = { workspace = true }



# Kafka
aws-msk-iam-sasl-signer = { workspace = true }
rdkafka = { workspace = true }
rdkafka-sys = { workspace = true }
sasl2-sys = { workspace = true }

arkflow-core = { workspace = true }

[dev-dependencies]
tempfile = { workspace = true }
mockall = { workspace = true }