[package]
edition = "2021"
rust-version = "1.75"
name = "llm-optimizer-processor"
version = "0.1.1"
authors = ["LLM Auto Optimizer Contributors <noreply@llmdevops.dev>"]
build = false
autolib = false
autobins = false
autoexamples = false
autotests = false
autobenches = false
description = "Data processing and transformation pipeline"
homepage = "https://github.com/globalbusinessadvisors/llm-auto-optimizer"
readme = "README.md"
license = "Apache-2.0"
repository = "https://github.com/globalbusinessadvisors/llm-auto-optimizer"
[lib]
name = "llm_optimizer_processor"
path = "src/lib.rs"
[[example]]
name = "advanced_deduplication"
path = "examples/advanced_deduplication.rs"
[[example]]
name = "aggregation_demo"
path = "examples/aggregation_demo.rs"
[[example]]
name = "cached_state_demo"
path = "examples/cached_state_demo.rs"
[[example]]
name = "distributed_lock_demo"
path = "examples/distributed_lock_demo.rs"
[[example]]
name = "distributed_state_demo"
path = "examples/distributed_state_demo.rs"
[[example]]
name = "event_deduplication_demo"
path = "examples/event_deduplication_demo.rs"
[[example]]
name = "kafka_pipeline"
path = "examples/kafka_pipeline.rs"
[[example]]
name = "kafka_sink_example"
path = "examples/kafka_sink_example.rs"
[[example]]
name = "kafka_source"
path = "examples/kafka_source.rs"
[[example]]
name = "metrics_example"
path = "examples/metrics_example.rs"
[[example]]
name = "multi_key_sliding_window"
path = "examples/multi_key_sliding_window.rs"
[[example]]
name = "normalization_example"
path = "examples/normalization_example.rs"
[[example]]
name = "pipeline_example"
path = "examples/pipeline_example.rs"
[[example]]
name = "postgres_enhanced_demo"
path = "examples/postgres_enhanced_demo.rs"
[[example]]
name = "postgres_state_backend"
path = "examples/postgres_state_backend.rs"
[[example]]
name = "postgres_state_demo"
path = "examples/postgres_state_demo.rs"
[[example]]
name = "redis_distributed_state"
path = "examples/redis_distributed_state.rs"
[[example]]
name = "redis_state_backend"
path = "examples/redis_state_backend.rs"
[[example]]
name = "redis_state_demo"
path = "examples/redis_state_demo.rs"
[[example]]
name = "state_demo"
path = "examples/state_demo.rs"
[[example]]
name = "state_ha_demo"
path = "examples/state_ha_demo.rs"
[[example]]
name = "stream_processor_demo"
path = "examples/stream_processor_demo.rs"
[[example]]
name = "stream_processor_state_complete"
path = "examples/stream_processor_state_complete.rs"
[[example]]
name = "telemetry_demo"
path = "examples/telemetry_demo.rs"
[[example]]
name = "tiered_cache_demo"
path = "examples/tiered_cache_demo.rs"
[[example]]
name = "watermark_demo"
path = "examples/watermark_demo.rs"
[[test]]
name = "cached_backend_tests"
path = "tests/cached_backend_tests.rs"
[[test]]
name = "deduplication_config_tests"
path = "tests/deduplication_config_tests.rs"
[[test]]
name = "deduplication_tests"
path = "tests/deduplication_tests.rs"
[[test]]
name = "distributed_state_comprehensive_tests"
path = "tests/distributed_state_comprehensive_tests.rs"
[[test]]
name = "distributed_state_tests"
path = "tests/distributed_state_tests.rs"
[[test]]
name = "kafka_sink_tests"
path = "tests/kafka_sink_tests.rs"
[[test]]
name = "kafka_source_integration"
path = "tests/kafka_source_integration.rs"
[[test]]
name = "metrics_integration_test"
path = "tests/metrics_integration_test.rs"
[[test]]
name = "normalization_tests"
path = "tests/normalization_tests.rs"
[[test]]
name = "postgres_integration_test"
path = "tests/postgres_integration_test.rs"
[[test]]
name = "redis_enterprise_integration"
path = "tests/redis_enterprise_integration.rs"
[[test]]
name = "state_integration_tests"
path = "tests/state_integration_tests.rs"
[[test]]
name = "storage_integration_tests"
path = "tests/storage_integration_tests.rs"
[[test]]
name = "stream_processor_state_tests"
path = "tests/stream_processor_state_tests.rs"
[[test]]
name = "stream_processor_tests"
path = "tests/stream_processor_tests.rs"
[[test]]
name = "telemetry_integration_tests"
path = "tests/telemetry_integration_tests.rs"
[[test]]
name = "telemetry_tests"
path = "tests/telemetry_tests.rs"
[[bench]]
name = "cached_backend_bench"
path = "benches/cached_backend_bench.rs"
[[bench]]
name = "kafka_sink_benchmark"
path = "benches/kafka_sink_benchmark.rs"
[[bench]]
name = "postgres_backend_bench"
path = "benches/postgres_backend_bench.rs"
[[bench]]
name = "sled_compression_bench"
path = "benches/sled_compression_bench.rs"
[[bench]]
name = "stream_processor_bench"
path = "benches/stream_processor_bench.rs"
[dependencies.anyhow]
version = "1.0"
[dependencies.async-trait]
version = "0.1"
[dependencies.axum]
version = "0.7"
features = ["macros"]
[dependencies.bincode]
version = "1.3"
[dependencies.chrono]
version = "0.4"
features = ["serde"]
[dependencies.dashmap]
version = "6.0"
[dependencies.deadpool-redis]
version = "0.18"
[dependencies.failsafe]
version = "1.2"
[dependencies.futures]
version = "0.3"
[dependencies.hex]
version = "0.4"
[dependencies.humantime-serde]
version = "1.1"
[dependencies.llm-optimizer-types]
version = "0.1.0"
[dependencies.lz4]
version = "1.24"
[dependencies.moka]
version = "0.12"
features = ["future"]
[dependencies.ndarray]
version = "0.16"
[dependencies.num_cpus]
version = "1.16"
[dependencies.opentelemetry]
version = "0.24"
features = [
"metrics",
"trace",
]
[dependencies.opentelemetry-otlp]
version = "0.17"
features = [
"metrics",
"trace",
"grpc-tonic",
]
[dependencies.opentelemetry-semantic-conventions]
version = "0.16"
[dependencies.opentelemetry_sdk]
version = "0.24"
features = [
"rt-tokio",
"metrics",
"trace",
]
[dependencies.parking_lot]
version = "0.12"
[dependencies.prometheus-client]
version = "0.22"
[dependencies.r2d2]
version = "0.8"
[dependencies.rand]
version = "0.8"
[dependencies.rdkafka]
version = "0.36"
features = ["tokio"]
[dependencies.redis]
version = "0.27"
features = [
"tokio-comp",
"connection-manager",
"streams",
"cluster",
"cluster-async",
]
[dependencies.rmp-serde]
version = "1.1"
[dependencies.serde]
version = "1.0"
features = ["derive"]
[dependencies.serde_json]
version = "1.0"
[dependencies.sha2]
version = "0.10"
[dependencies.sled]
version = "0.34"
features = ["compression"]
[dependencies.snap]
version = "1.1"
[dependencies.sqlx]
version = "0.8"
features = [
"runtime-tokio",
"postgres",
"macros",
"migrate",
"uuid",
"chrono",
]
[dependencies.statrs]
version = "0.17"
[dependencies.thiserror]
version = "1.0"
[dependencies.tokio]
version = "1.40"
features = ["full"]
[dependencies.tokio-stream]
version = "0.1"
[dependencies.tonic]
version = "0.12"
features = [
"tls",
"gzip",
]
[dependencies.tracing]
version = "0.1"
[dependencies.tracing-opentelemetry]
version = "0.25"
[dependencies.uuid]
version = "1.10"
features = [
"v4",
"serde",
]
[dependencies.zstd]
version = "0.5"
[dev-dependencies.criterion]
version = "0.5"
features = ["async_tokio"]
[dev-dependencies.tempfile]
version = "3.8"
[dev-dependencies.tokio]
version = "1.40"
features = [
"full",
"test-util",
]
[dev-dependencies.tracing-subscriber]
version = "0.3"
features = [
"env-filter",
"json",
]