Expand description
Feedback Collector
This crate provides comprehensive feedback collection using OpenTelemetry for observability and Kafka for event streaming. It supports async collection, batching, buffering, resilient event processing, circuit breaker pattern, and backpressure handling for production reliability.
Re-exports§
pub use backpressure::BackpressureConfig;pub use backpressure::BackpressureError;pub use backpressure::BackpressureHandler;pub use backpressure::BackpressureStats;pub use backpressure::BufferLevel;pub use backpressure::OverflowStrategy;pub use circuit_breaker::CircuitBreaker;pub use circuit_breaker::CircuitBreakerConfig;pub use circuit_breaker::CircuitBreakerStats;pub use circuit_breaker::CircuitState;pub use dead_letter_queue::DLQConfig;pub use dead_letter_queue::DLQEntry;pub use dead_letter_queue::DLQError;pub use dead_letter_queue::DLQManager;pub use dead_letter_queue::DLQStats;pub use dead_letter_queue::DLQType;pub use dead_letter_queue::DeadLetterQueue;pub use dead_letter_queue::FileDLQ;pub use dead_letter_queue::HybridDLQ;pub use dead_letter_queue::KafkaDLQ;pub use feedback_collector::CollectorStats;pub use feedback_collector::FeedbackCollector;pub use feedback_collector::FeedbackCollectorBuilder;pub use feedback_collector::FeedbackCollectorConfig;pub use feedback_collector::SubmitError;pub use feedback_collector::TrySubmitError;pub use feedback_events::ExperimentResultEvent;pub use feedback_events::FeedbackEvent;pub use feedback_events::FeedbackEventBatch;pub use feedback_events::HealthStatus;pub use feedback_events::ModelResponseEvent;pub use feedback_events::PerformanceMetricsEvent;pub use feedback_events::SystemHealthEvent;pub use feedback_events::UserFeedbackEvent;pub use health::ComponentHealth;pub use health::HealthChecker;pub use health::HealthReport;pub use health::HealthStatus as HealthCheckStatus;pub use kafka_client::FeedbackEventHandler;pub use kafka_client::FeedbackProducer;pub use kafka_client::KafkaError;pub use kafka_client::KafkaProducerConfig;pub use kafka_producer_with_dlq::KafkaProducerWithDLQ;pub use kafka_producer_with_dlq::ProducerWithDLQError;pub use rate_limiter::RateLimitConfig;pub use rate_limiter::RateLimitError;pub use rate_limiter::RateLimitStats;pub use rate_limiter::RateLimiter;pub use rate_limiter::SourceIdentifier;pub use rate_limiter::SourceIdentifierStrategy;pub use telemetry::TelemetryConfig;pub use telemetry::TelemetryError;pub use telemetry::TelemetryMetrics;pub use telemetry::TelemetryProvider;
Modules§
- backpressure
- Backpressure Handling
- circuit_
breaker - Circuit Breaker Pattern
- dead_
letter_ queue - Dead Letter Queue (DLQ) System
- feedback_
collector - Feedback Collector
- feedback_
events - Feedback Event Types and Schemas
- health
- Health Check Module
- kafka_
client - Kafka Client
- kafka_
producer_ with_ dlq - Kafka Producer with DLQ Integration
- rate_
limiter - Rate Limiting
- telemetry
- OpenTelemetry Integration