rs2-stream 0.3.0

[dependencies.async-stream]
version = "0.3"

[dependencies.async-trait]
version = "0.1"

[dependencies.base64]
version = "0.21.7"

[dependencies.chrono]
features = ["serde"]
version = "0.4.41"

[dependencies.futures]
version = "0.3"

[dependencies.futures-core]
version = "0.3.31"

[dependencies.futures-util]
version = "0.3.31"

[dependencies.jsonschema]
version = "0.30.0"

[dependencies.lazy_static]
version = "1.4"

[dependencies.log]
version = "0.4.27"

[dependencies.num_cpus]
version = "1.17.0"

[dependencies.quickcheck]
version = "1.0.3"

[dependencies.rand]
version = "0.8.5"

[dependencies.rdkafka]
version = "0.37.0"

[dependencies.serde]
features = ["derive"]
version = "1.0"

[dependencies.serde_json]
version = "1.0"

[dependencies.sha2]
version = "0.10.9"

[dependencies.thiserror]
version = "1.0.69"

[dependencies.tokio]
features = ["full"]
version = "1.0"

[dependencies.tokio-stream]
version = "0.1.17"

[dependencies.uuid]
features = ["v4"]
version = "1.17.0"

[dev-dependencies.criterion]
features = ["html_reports", "async_tokio"]
version = "0.5.1"

[dev-dependencies.once_cell]
version = "1.19.0"

[dev-dependencies.quickcheck]
version = "1.0.3"

[dev-dependencies.rand]
version = "0.8.5"

[dev-dependencies.serial_test]
version = "3.0.0"

[dev-dependencies.testcontainers]
features = ["blocking"]
version = "0.24.0"

[dev-dependencies.testcontainers-modules]
features = ["kafka", "redis"]
version = "0.12.1"

[dev-dependencies.tokio-test]
version = "0.4.4"

[[example]]
name = "accumulating_values"
path = "examples/accumulating_values.rs"

[[example]]
name = "advanced_analytics_example"
path = "examples/advanced_analytics_example.rs"

[[example]]
name = "basic_file_streaming"
path = "examples/basic_file_streaming.rs"

[[example]]
name = "basic_usage"
path = "examples/basic_usage.rs"

[[example]]
name = "batch_process_example"
path = "examples/batch_process_example.rs"

[[example]]
name = "bracket_case_example"
path = "examples/bracket_case_example.rs"

[[example]]
name = "bracket_rs_example"
path = "examples/bracket_rs_example.rs"

[[example]]
name = "chunk_rs2_example"
path = "examples/chunk_rs2_example.rs"

[[example]]
name = "connector_custom"
path = "examples/connector_custom.rs"

[[example]]
name = "connector_kafka"
path = "examples/connector_kafka.rs"

[[example]]
name = "custom_backpressure"
path = "examples/custom_backpressure.rs"

[[example]]
name = "custom_codec"
path = "examples/custom_codec.rs"

[[example]]
name = "custom_state_config_example"
path = "examples/custom_state_config_example.rs"

[[example]]
name = "custom_storage_example"
path = "examples/custom_storage_example.rs"

[[example]]
name = "interleave_example"
path = "examples/interleave_example.rs"

[[example]]
name = "kafka_data_pipeline"
path = "examples/kafka_data_pipeline.rs"

[[example]]
name = "live_streaming"
path = "examples/live_streaming.rs"

[[example]]
name = "parallel_mapping"
path = "examples/parallel_mapping.rs"

[[example]]
name = "parallel_processing_comprehensive"
path = "examples/parallel_processing_comprehensive.rs"

[[example]]
name = "pipe_basic_usage"
path = "examples/pipe_basic_usage.rs"

[[example]]
name = "pipe_composing"
path = "examples/pipe_composing.rs"

[[example]]
name = "pipe_user_data_processing"
path = "examples/pipe_user_data_processing.rs"

[[example]]
name = "processing_elements"
path = "examples/processing_elements.rs"

[[example]]
name = "processing_stream_of_users"
path = "examples/processing_stream_of_users.rs"

[[example]]
name = "queue_basic_usage"
path = "examples/queue_basic_usage.rs"

[[example]]
name = "queue_message_processing"
path = "examples/queue_message_processing.rs"

[[example]]
name = "queue_producer_consumer"
path = "examples/queue_producer_consumer.rs"

[[example]]
name = "rate_limit_backpressure_example"
path = "examples/rate_limit_backpressure_example.rs"

[[example]]
name = "real_time_analytics_pipeline"
path = "examples/real_time_analytics_pipeline.rs"

[[example]]
name = "resource_management_bracket"
path = "examples/resource_management_bracket.rs"

[[example]]
name = "resource_management_example"
path = "examples/resource_management_example.rs"

[[example]]
name = "schema_validation_example"
path = "examples/schema_validation_example.rs"

[[example]]
name = "sliding_window_example"
path = "examples/sliding_window_example.rs"

[[example]]
name = "state_management_example"
path = "examples/state_management_example.rs"

[[example]]
name = "stateful_deduplicate_example"
path = "examples/stateful_deduplicate_example.rs"

[[example]]
name = "stateful_filter_example"
path = "examples/stateful_filter_example.rs"

[[example]]
name = "stateful_group_by_example"
path = "examples/stateful_group_by_example.rs"

[[example]]
name = "stateful_map_example"
path = "examples/stateful_map_example.rs"

[[example]]
name = "stateful_pattern_example"
path = "examples/stateful_pattern_example.rs"

[[example]]
name = "stateful_reduce_example"
path = "examples/stateful_reduce_example.rs"

[[example]]
name = "stateful_session_example"
path = "examples/stateful_session_example.rs"

[[example]]
name = "stateful_throttle_example"
path = "examples/stateful_throttle_example.rs"

[[example]]
name = "stream_creation_async"
path = "examples/stream_creation_async.rs"

[[example]]
name = "stream_creation_basic"
path = "examples/stream_creation_basic.rs"

[[example]]
name = "stream_creation_infinite"
path = "examples/stream_creation_infinite.rs"

[[example]]
name = "stream_events"
path = "examples/stream_events.rs"

[[example]]
name = "tick_rs_example"
path = "examples/tick_rs_example.rs"

[[example]]
name = "timeout_operations"
path = "examples/timeout_operations.rs"

[[example]]
name = "transformations_async"
path = "examples/transformations_async.rs"

[[example]]
name = "transformations_basic"
path = "examples/transformations_basic.rs"

[[example]]
name = "transformations_combining"
path = "examples/transformations_combining.rs"

[[example]]
name = "transformations_grouping"
path = "examples/transformations_grouping.rs"

[[example]]
name = "transformations_slicing"
path = "examples/transformations_slicing.rs"

[[example]]
name = "with_metrics_example"
path = "examples/with_metrics_example.rs"

[lib]
name = "rs2_stream"
path = "src/lib.rs"

[package]
authors = ["Vishnu Raman <vishnu310592@gmail.com>"]
autobenches = false
autobins = false
autoexamples = false
autolib = false
autotests = false
build = false
categories = ["asynchronous", "data-structures", "network-programming", "concurrency"]
description = "A high-performance, production-ready async streaming library for Rust."
documentation = "https://docs.rs/rs2"
edition = "2021"
exclude = ["benches/", "benches/*", "scripts/", "scripts/*", "docs/images/", "docs/images/*", "assets/", "assets/*", "*.png", "*.jpg", "*.jpeg", "*.gif", "*.mp4", "*.svg", ".github/", "screenshots/"]
homepage = "https://github.com/VishnuRaman/rs2"
keywords = ["stream", "async", "pipeline", "analytics", "state-management"]
license = "Apache-2.0"
name = "rs2-stream"
readme = "README.md"
repository = "https://github.com/VishnuRaman/rs2"
version = "0.3.0"

[[test]]
name = "advanced_analytics_tests"
path = "tests/advanced_analytics_tests.rs"

[[test]]
name = "backpressure_tests"
path = "tests/backpressure_tests.rs"

[[test]]
name = "basic_stream_tests"
path = "tests/basic_stream_tests.rs"

[[test]]
name = "chunk_processor_tests"
path = "tests/chunk_processor_tests.rs"

[[test]]
name = "concurrency_tests"
path = "tests/concurrency_tests.rs"

[[test]]
name = "connector_tests"
path = "tests/connector_tests.rs"

[[test]]
name = "error_handling_tests"
path = "tests/error_handling_tests.rs"

[[test]]
name = "extension_trait_tests"
path = "tests/extension_trait_tests.rs"

[[test]]
name = "kafka_integration_tests_simplified"
path = "tests/kafka_integration_tests_simplified.rs"

[[test]]
name = "kafka_test"
path = "tests/kafka_test.rs"

[[test]]
name = "media_comprehensive_tests"
path = "tests/media_comprehensive_tests.rs"

[[test]]
name = "performance_tests"
path = "tests/performance_tests.rs"

[[test]]
name = "pipe_tests"
path = "tests/pipe_tests.rs"

[[test]]
name = "queue_tests"
path = "tests/queue_tests.rs"

[[test]]
name = "resource_management_tests"
path = "tests/resource_management_tests.rs"

[[test]]
name = "resource_manager_tests"
path = "tests/resource_manager_tests.rs"

[[test]]
name = "schema_validation_tests"
path = "tests/schema_validation_tests.rs"

[[test]]
name = "state_config_tests"
path = "tests/state_config_tests.rs"

[[test]]
name = "state_integration_tests"
path = "tests/state_integration_tests.rs"

[[test]]
name = "state_management"
path = "tests/state_management.rs"

[[test]]
name = "state_management_tests"
path = "tests/state_management_tests.rs"

[[test]]
name = "state_storage_tests"
path = "tests/state_storage_tests.rs"

[[test]]
name = "state_stream_ext_advanced"
path = "tests/state_stream_ext_advanced.rs"

[[test]]
name = "state_stream_ext_basic"
path = "tests/state_stream_ext_basic.rs"

[[test]]
name = "state_traits_tests"
path = "tests/state_traits_tests.rs"

[[test]]
name = "stream_performance_metrics_tests"
path = "tests/stream_performance_metrics_tests.rs"

[[test]]
name = "stream_transformation_tests"
path = "tests/stream_transformation_tests.rs"

[[test]]
name = "streaming_tests"
path = "tests/streaming_tests.rs"