llm-optimizer-processor 0.1.0

Data processing and transformation pipeline
Documentation
[[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"