[[bench]]
harness = false
name = "concurrency_bench"
path = "benches/concurrency_bench.rs"
[[bench]]
harness = false
name = "memory_bench"
path = "benches/memory_bench.rs"
[[bench]]
harness = false
name = "parser_bench"
path = "benches/parser_bench.rs"
[[bench]]
harness = false
name = "profile_bench"
path = "benches/profile_bench.rs"
[[bench]]
harness = false
name = "real_world_bench"
path = "benches/real_world_bench.rs"
[dependencies.async-stream]
version = "0.3"
[dependencies.async-trait]
optional = true
version = "0.1.77"
[dependencies.bytes]
version = "1.5.0"
[dependencies.config]
optional = true
version = "0.13"
[dependencies.dashmap]
optional = true
version = "6.1.0"
[dependencies.futures]
version = "0.3.30"
[dependencies.governor]
optional = true
version = "0.4"
[dependencies.json5]
optional = true
version = "0.4.1"
[dependencies.lazy_static]
version = "1.4.0"
[dependencies.oauth2]
optional = true
version = "4.2.0"
[dependencies.prometheus]
optional = true
version = "0.13.3"
[dependencies.reqwest]
features = ["json", "stream"]
optional = true
version = "0.11.22"
[dependencies.schemars]
version = "0.8.15"
[dependencies.serde]
features = ["derive"]
version = "1.0.217"
[dependencies.simd-json]
features = ["serde_impl"]
version = "0.13.8"
[dependencies.tch]
optional = true
version = "0.19.0"
[dependencies.thiserror]
version = "2.0.11"
[dependencies.tokio]
features = ["full", "time", "rt-multi-thread"]
version = "1.43.0"
[dependencies.tokio-retry]
optional = true
version = "0.3"
[dependencies.tokio-stream]
version = "0.1.14"
[dependencies.tokio-tungstenite]
features = ["rustls-tls-webpki-roots"]
optional = true
version = "0.20.1"
[dependencies.tokio-util]
features = ["codec", "compat"]
optional = true
version = "0.7.10"
[dependencies.tracing]
version = "0.1.40"
[dependencies.validator]
version = "0.16.1"
[dev-dependencies.criterion]
features = ["html_reports", "async", "async_futures"]
version = "0.5.1"
[dev-dependencies.rand]
version = "0.8.5"
[dev-dependencies.tokio]
features = ["full", "test-util", "rt-multi-thread"]
version = "1.43.0"
[[example]]
name = "ai_agent"
path = "examples/ai_agent.rs"
[[example]]
name = "batch"
path = "examples/batch.rs"
[[example]]
name = "batch_ws"
path = "examples/batch_ws.rs"
[[example]]
name = "full_demo"
path = "examples/full_demo.rs"
[[example]]
name = "parser"
path = "examples/parser.rs"
[[example]]
name = "stream_batch"
path = "examples/stream_batch.rs"
[[example]]
name = "stream_transformer"
path = "examples/stream_transformer.rs"
[[example]]
name = "tcp_server"
path = "examples/tcp_server.rs"
[[example]]
name = "transform_auto"
path = "examples/transform_auto.rs"
[[example]]
name = "transformer"
path = "examples/transformer.rs"
[[example]]
name = "ws_connector"
path = "examples/ws_connector.rs"
[[example]]
name = "ws_server"
path = "examples/ws_server.rs"
[features]
advanced_agents = ["ml", "auth"]
auth = ["oauth2"]
basic_agents = ["dashmap"]
circuit-breaker = ["tokio-retry"]
configs = ["config"]
connectors = ["http", "websocket", "async-trait", "tokio-util"]
default = ["http", "connectors", "metrics", "basic_agents", "auth"]
http = ["reqwest"]
metrics = ["prometheus"]
ml = ["tch"]
rate-limiting = ["governor"]
relaxed = ["json5"]
websocket = ["tokio-tungstenite"]
[lib]
name = "prk_async_dataflow"
path = "src/lib.rs"
[package]
autobenches = false
autobins = false
autoexamples = false
autolib = false
autotests = false
build = false
categories = ["asynchronous", "parsing"]
description = "An asynchronous dataflow processing library for Rust with SIMD-accelerated JSON parsing and AI agent capabilities."
edition = "2021"
keywords = ["async", "json", "simd", "ai", "agent"]
license = "MIT"
name = "prk_async_dataflow"
readme = "README.md"
repository = "https://github.com/prk-Jr/prk_async_dataflow"
version = "0.2.3"