[[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]
features = ["macros"]
version = "0.7"
[dependencies.bincode]
version = "1.3"
[dependencies.chrono]
features = ["serde"]
version = "0.4"
[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]
features = ["future"]
version = "0.12"
[dependencies.ndarray]
version = "0.16"
[dependencies.num_cpus]
version = "1.16"
[dependencies.opentelemetry]
features = ["metrics", "trace"]
version = "0.24"
[dependencies.opentelemetry-otlp]
features = ["metrics", "trace", "grpc-tonic"]
version = "0.17"
[dependencies.opentelemetry-semantic-conventions]
version = "0.16"
[dependencies.opentelemetry_sdk]
features = ["rt-tokio", "metrics", "trace"]
version = "0.24"
[dependencies.parking_lot]
version = "0.12"
[dependencies.prometheus-client]
version = "0.22"
[dependencies.r2d2]
version = "0.8"
[dependencies.rand]
version = "0.8"
[dependencies.rdkafka]
features = ["tokio"]
version = "0.36"
[dependencies.redis]
features = ["tokio-comp", "connection-manager", "streams", "cluster", "cluster-async"]
version = "0.27"
[dependencies.rmp-serde]
version = "1.1"
[dependencies.serde]
features = ["derive"]
version = "1.0"
[dependencies.serde_json]
version = "1.0"
[dependencies.sha2]
version = "0.10"
[dependencies.sled]
features = ["compression"]
version = "0.34"
[dependencies.snap]
version = "1.1"
[dependencies.sqlx]
features = ["runtime-tokio", "postgres", "macros", "migrate", "uuid", "chrono"]
version = "0.8"
[dependencies.statrs]
version = "0.17"
[dependencies.thiserror]
version = "1.0"
[dependencies.tokio]
features = ["full"]
version = "1.40"
[dependencies.tokio-stream]
version = "0.1"
[dependencies.tonic]
features = ["tls", "gzip"]
version = "0.12"
[dependencies.tracing]
version = "0.1"
[dependencies.tracing-opentelemetry]
version = "0.25"
[dependencies.uuid]
features = ["v4", "serde"]
version = "1.10"
[dependencies.zstd]
version = "0.5"
[dev-dependencies.criterion]
features = ["async_tokio"]
version = "0.5"
[dev-dependencies.tempfile]
version = "3.8"
[dev-dependencies.tokio]
features = ["full", "test-util"]
version = "1.40"
[dev-dependencies.tracing-subscriber]
features = ["env-filter", "json"]
version = "0.3"
[[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"
[lib]
name = "llm_optimizer_processor"
path = "src/lib.rs"
[package]
authors = ["LLM Auto Optimizer Contributors <noreply@llmdevops.dev>"]
autobenches = false
autobins = false
autoexamples = false
autolib = false
autotests = false
build = false
description = "Data processing and transformation pipeline"
edition = "2021"
homepage = "https://github.com/globalbusinessadvisors/llm-auto-optimizer"
license = "Apache-2.0"
name = "llm-optimizer-processor"
readme = "README.md"
repository = "https://github.com/globalbusinessadvisors/llm-auto-optimizer"
rust-version = "1.75"
version = "0.1.0"
[[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"