List of all items
Structs
- OtelContext
- OtelKeyValue
- actuator::canary::CanaryDeploymentEngine
- actuator::config::ActuatorConfig
- actuator::config::ConfigurationManagementConfig
- actuator::config::HealthMonitoringConfig
- actuator::config::RollbackConfig
- actuator::configuration::AuditLogEntry
- actuator::configuration::ConfigurationDiff
- actuator::configuration::ConfigurationManagerImpl
- actuator::configuration::InMemoryBackend
- actuator::coordinator::ActuatorCoordinator
- actuator::health::HealthMonitorConfig
- actuator::health::ProductionHealthMonitor
- actuator::rollback::RollbackEngine
- actuator::rollback::RollbackHistoryEntry
- actuator::rollback::RollbackNotification
- actuator::rollback::RollbackPhase
- actuator::rollback::RollbackStats
- actuator::rollback::RollbackStatus
- actuator::rollback::RollbackTrigger
- actuator::rollback::ThresholdViolation
- actuator::types::ActuatorStats
- actuator::types::CanaryConfig
- actuator::types::CanaryPhase
- actuator::types::ConfigurationSnapshot
- actuator::types::DeploymentMetrics
- actuator::types::DeploymentRequest
- actuator::types::DeploymentStatus
- actuator::types::HealthCheckResult
- actuator::types::HealthStatus
- actuator::types::RollbackRequest
- actuator::types::RollbackResult
- actuator::types::StatisticalAnalysis
- actuator::types::SuccessCriteria
- aggregation::AggregationResult
- aggregation::AverageAccumulator
- aggregation::AverageAggregator
- aggregation::CompositeAggregator
- aggregation::CountAccumulator
- aggregation::CountAggregator
- aggregation::MaxAccumulator
- aggregation::MaxAggregator
- aggregation::MinAccumulator
- aggregation::MinAggregator
- aggregation::PercentileAccumulator
- aggregation::PercentileAggregator
- aggregation::StandardDeviationAggregator
- aggregation::StdDevAccumulator
- aggregation::SumAccumulator
- aggregation::SumAggregator
- aggregation::statistics::ExponentialMovingAverage
- aggregation::statistics::OnlineVariance
- aggregation::statistics::RateCalculator
- aggregation::statistics::SlidingWindowStats
- aggregation::statistics::ZScoreAnomalyDetector
- analyzer::anomaly_analyzer::AnomalyAnalyzer
- analyzer::anomaly_analyzer::AnomalyAnalyzerConfig
- analyzer::cost_analyzer::CostAnalyzer
- analyzer::cost_analyzer::CostAnalyzerConfig
- analyzer::cost_analyzer::ModelPricing
- analyzer::pattern_analyzer::PatternAnalyzer
- analyzer::pattern_analyzer::PatternAnalyzerConfig
- analyzer::performance_analyzer::PerformanceAnalyzer
- analyzer::performance_analyzer::PerformanceAnalyzerConfig
- analyzer::quality_analyzer::QualityAnalyzer
- analyzer::quality_analyzer::QualityAnalyzerConfig
- analyzer::stats::CircularBuffer
- analyzer::stats::ExponentialMovingAverage
- analyzer::stats::LinearTrend
- analyzer::stats::SimpleMovingAverage
- analyzer::traits::AnalyzerConfig
- analyzer::traits::AnalyzerConfigBuilder
- analyzer::types::Action
- analyzer::types::Alert
- analyzer::types::AnalysisReport
- analyzer::types::AnalyzerStats
- analyzer::types::Confidence
- analyzer::types::Evidence
- analyzer::types::Impact
- analyzer::types::ImpactMetric
- analyzer::types::Insight
- analyzer::types::Recommendation
- analyzer::types::ReportSummary
- analyzer::types::Threshold
- config::AggregationConfig
- config::DeduplicationConfig
- config::NormalizationConfig
- config::ProcessorConfig
- config::StateConfig
- config::WatermarkConfig
- config::WindowConfig
- core::CloudEventKeyExtractor
- core::CloudEventTimeExtractor
- core::FeedbackEventKeyExtractor
- core::FeedbackEventTimeExtractor
- core::MetricPointKeyExtractor
- core::MetricPointTimeExtractor
- core::ProcessorEvent
- decision::batching::BatchingStrategy
- decision::caching::CachingStrategy
- decision::config::BatchingConfig
- decision::config::CachingConfig
- decision::config::DecisionEngineConfig
- decision::config::ModelSelectionConfig
- decision::config::MonitoringConfig
- decision::config::PromptOptimizationConfig
- decision::config::RateLimitingConfig
- decision::config::SafetyConfig
- decision::config::StrategyConfigs
- decision::coordinator::DecisionCoordinator
- decision::model_selection::ModelSelectionStrategy
- decision::prompt_optimization::PromptOptimizationStrategy
- decision::rate_limiting::RateLimitingStrategy
- decision::types::ActualImpact
- decision::types::ConfigChange
- decision::types::Decision
- decision::types::DecisionCriteria
- decision::types::DecisionInput
- decision::types::DecisionOutcome
- decision::types::DecisionStats
- decision::types::ExpectedImpact
- decision::types::RollbackCondition
- decision::types::RollbackPlan
- decision::types::SafetyCheck
- decision::types::SystemMetrics
- deduplication::DeduplicationConfig
- deduplication::DeduplicationConfigBuilder
- deduplication::DeduplicationStats
- deduplication::EventDeduplicator
- kafka::config::KafkaSinkConfig
- kafka::config::KafkaSinkConfigBuilder
- kafka::config::KafkaSourceConfig
- kafka::config::KafkaSourceConfigBuilder
- kafka::config::SslConfig
- kafka::integration::KafkaStreamConfig
- kafka::integration::KafkaStreamPipeline
- kafka::integration::KafkaStreamSink
- kafka::integration::KafkaStreamSource
- kafka::integration::KafkaStreamStats
- kafka::integration::OffsetManager
- kafka::offset_manager::InMemoryOffsetStore
- kafka::offset_manager::OffsetInfo
- kafka::offset_manager::OffsetManager
- kafka::offset_manager::OffsetStats
- kafka::offset_manager::StateBackendOffsetStore
- kafka::offset_manager::TopicPartition
- kafka::sink::BincodeSerializer
- kafka::sink::JsonSerializer
- kafka::sink::KafkaMessage
- kafka::sink::KafkaSink
- kafka::sink::KafkaSinkConfig
- kafka::sink::SinkMetrics
- kafka::source::KafkaMessage
- kafka::source::KafkaSource
- kafka::source::KafkaSourceConfig
- kafka::source::KafkaSourceMetrics
- metrics::HealthStatus
- metrics::LabelSet
- metrics::MetricsRegistry
- metrics::MetricsServer
- metrics::MetricsServerConfig
- metrics::MetricsSnapshot
- metrics::ProcessorMetrics
- normalization::NormalizationConfig
- normalization::NormalizationStats
- normalization::NormalizerBuilder
- normalization::TimeSeriesEvent
- normalization::TimeSeriesNormalizer
- otel_global::BoxedSpan
- otel_global::BoxedTracer
- otel_global::GlobalMeterProvider
- otel_global::GlobalTracerProvider
- pipeline::builder::PipelineConfig
- pipeline::builder::StreamPipeline
- pipeline::builder::StreamPipelineBuilder
- pipeline::executor::ExecutorStats
- pipeline::executor::StreamExecutor
- pipeline::normalization_operator::NormalizationOperator
- pipeline::normalization_operator::NormalizationStats
- pipeline::normalization_operator::TimestampedEvent
- pipeline::operator::AggregateOperator
- pipeline::operator::DeduplicationOperator
- pipeline::operator::DeduplicationStats
- pipeline::operator::FilterOperator
- pipeline::operator::FlatMapOperator
- pipeline::operator::KeyByOperator
- pipeline::operator::MapOperator
- pipeline::operator::OperatorChain
- pipeline::operator::OperatorContext
- pipeline::operator::WindowOperator
- state::cached_backend::CacheConfig
- state::cached_backend::CacheStats
- state::cached_backend::CachedStateBackend
- state::checkpoint::Checkpoint
- state::checkpoint::CheckpointCoordinator
- state::checkpoint::CheckpointMetadata
- state::checkpoint::CheckpointOptions
- state::checkpoint::CheckpointStats
- state::compression::CompressionConfig
- state::compression::CompressionStats
- state::distributed_lock::LockGuard
- state::distributed_lock::LockToken
- state::memory::MemoryBackendStats
- state::memory::MemoryStateBackend
- state::postgres_backend::CheckpointInfo
- state::postgres_backend::PostgresConfig
- state::postgres_backend::PostgresStateBackend
- state::postgres_backend::PostgresStats
- state::postgres_backend_enhanced::EnhancedPostgresBackend
- state::postgres_backend_enhanced::EnhancedPostgresConfig
- state::postgres_backend_enhanced::EnhancedPostgresStats
- state::postgres_backend_enhanced::PoolStatistics
- state::postgres_backend_enhanced::PostgresListener
- state::postgres_backend_enhanced::PostgresLockGuard
- state::postgres_backend_enhanced::PostgresPoolConfig
- state::postgres_backend_enhanced::PostgresReplicaConfig
- state::postgres_backend_enhanced::PostgresSslConfig
- state::postgres_backend_enhanced::PostgresStatsSnapshot
- state::postgres_backend_enhanced::PostgresTransaction
- state::postgres_backend_enhanced::ReplicationStatus
- state::postgres_backend_enhanced::RetentionPolicy
- state::postgres_backend_enhanced::TableStatistics
- state::postgres_lock::PostgresDistributedLock
- state::redis_backend::RedisConfig
- state::redis_backend::RedisConfigBuilder
- state::redis_backend::RedisStateBackend
- state::redis_backend::RedisStats
- state::redis_backend_enterprise::BackendStats
- state::redis_backend_enterprise::EnterpriseRedisBackend
- state::redis_backend_enterprise::EnterpriseRedisConfig
- state::redis_backend_enterprise::EnterpriseRedisConfigBuilder
- state::redis_backend_enterprise::RedisMetrics
- state::redis_backend_enterprise::RedlockGuard
- state::redis_lock::RedisDistributedLock
- state::redis_lock::RetryConfig
- state::sled_backend::SledBackendStats
- state::sled_backend::SledConfig
- state::sled_backend::SledStateBackend
- storage::config::MonitoringConfig
- storage::config::PoolConfig
- storage::config::PostgreSQLConfig
- storage::config::RedisConfig
- storage::config::RetryConfig
- storage::config::SledConfig
- storage::config::StorageConfig
- storage::manager::ManagerStats
- storage::manager::StorageManager
- storage::postgresql::PostgreSQLStorage
- storage::redis::RedisStorage
- storage::sled_backend::SledStorage
- storage::traits::BackupMetadata
- storage::traits::CacheStats
- storage::traits::Migration
- storage::traits::SqlResult
- storage::types::Batch
- storage::types::EntryMetadata
- storage::types::Filter
- storage::types::Query
- storage::types::Sort
- storage::types::StorageEntry
- storage::types::StorageMetadata
- storage::types::StorageStats
- storage::types::Transaction
- stream_processor::ProcessorStats
- stream_processor::StreamProcessor
- stream_processor::StreamProcessorBuilder
- stream_processor::StreamProcessorConfig
- stream_processor::WindowResult
- telemetry::Context
- telemetry::KeyValue
- telemetry::TelemetryConfig
- telemetry::TelemetryProviders
- telemetry::context::BaggageItem
- telemetry::context::HeaderCarrier
- telemetry::global::BoxedSpan
- telemetry::global::BoxedTracer
- telemetry::global::GlobalMeterProvider
- telemetry::global::GlobalTracerProvider
- telemetry::metrics::ExportConfig
- telemetry::metrics::MetricsConfig
- telemetry::metrics::MetricsRecorder
- telemetry::resource::ResourceBuilder
- telemetry::tracing::BatchConfiguration
- telemetry::tracing::SpanBuilder
- telemetry::tracing::TraceConfig
- watermark::BoundedOutOfOrdernessConfig
- watermark::BoundedOutOfOrdernessWatermark
- watermark::LateEventConfig
- watermark::LateEventHandler
- watermark::LateEventStats
- watermark::PeriodicWatermark
- watermark::PeriodicWatermarkConfig
- watermark::PunctuatedWatermark
- watermark::Watermark
- window::WindowMerger
- window::assigner::SessionWindowAssigner
- window::assigner::SlidingWindowAssigner
- window::assigner::TumblingWindowAssigner
- window::manager::WindowManager
- window::manager::WindowMetadata
- window::manager::WindowStats
- window::trigger::CompositeTrigger
- window::trigger::CountTrigger
- window::trigger::ImmediateTrigger
- window::trigger::NeverTrigger
- window::trigger::OnWatermarkTrigger
- window::trigger::ProcessingTimeTrigger
- window::trigger::TriggerContext
- window::types::Window
- window::types::WindowBounds
Enums
- OtelStatus
- SpanKind
- actuator::configuration::DiffType
- actuator::error::ActuatorError
- actuator::error::ActuatorState
- actuator::error::DeploymentState
- actuator::health::HealthCheckType
- actuator::rollback::NotificationSeverity
- actuator::rollback::RollbackMode
- actuator::types::DeploymentStrategy
- actuator::types::RollbackReason
- actuator::types::TrafficSplitStrategy
- analyzer::anomaly_analyzer::AnomalyType
- analyzer::pattern_analyzer::PatternType
- analyzer::traits::AnalyzerError
- analyzer::traits::AnalyzerState
- analyzer::types::ActionType
- analyzer::types::AlertStatus
- analyzer::types::AnalyzerEvent
- analyzer::types::EvidenceType
- analyzer::types::FeedbackType
- analyzer::types::InsightCategory
- analyzer::types::Priority
- analyzer::types::RiskLevel
- analyzer::types::Severity
- analyzer::types::ThresholdOperator
- config::AggregationType
- config::AlignmentStrategy
- config::DeduplicationStrategy
- config::FillStrategy
- config::StateBackend
- config::WatermarkStrategy
- config::WindowType
- core::EventKey
- decision::error::DecisionError
- decision::error::DecisionState
- decision::types::ComparisonOperator
- decision::types::ConfigType
- decision::types::DecisionType
- deduplication::EventIdExtractor
- error::AggregationError
- error::ProcessorError
- error::StateError
- error::WatermarkError
- error::WindowError
- kafka::config::CompressionType
- kafka::config::SaslMechanism
- kafka::config::SecurityProtocol
- kafka::error::ErrorSeverity
- kafka::error::KafkaError
- kafka::offset_manager::OffsetCommitStrategy
- kafka::offset_manager::OffsetResetStrategy
- kafka::sink::DeliveryGuarantee
- kafka::sink::PartitionStrategy
- kafka::source::CommitStrategy
- metrics::LabelValue
- metrics::MetricsError
- normalization::FillStrategy
- normalization::NormalizationError
- otel_global::Error
- state::cached_backend::EvictionPolicy
- state::cached_backend::WriteStrategy
- state::compression::CompressionAlgorithm
- state::compression::CompressionError
- state::postgres_backend_enhanced::IsolationLevel
- state::postgres_backend_enhanced::PartitionStrategy
- state::redis_backend_enterprise::CompressionAlgorithm
- state::redis_backend_enterprise::RedisMode
- state::redis_backend_enterprise::SerializationFormat
- storage::AnyStorage
- storage::config::SSLMode
- storage::config::SledMode
- storage::error::ErrorCategory
- storage::error::StorageError
- storage::manager::ManagerState
- storage::manager::RoutingStrategy
- storage::traits::SqlParam
- storage::types::Operation
- storage::types::Operator
- storage::types::SortDirection
- storage::types::StorageBackend
- storage::types::StorageHealth
- storage::types::TransactionState
- storage::types::Value
- telemetry::SpanKind
- telemetry::Status
- telemetry::global::Error
- telemetry::metrics::Temporality
- telemetry::tracing::OtlpProtocol
- telemetry::tracing::SamplingStrategy
- window::trigger::CompositeMode
- window::trigger::TriggerResult
- window::types::WindowType
Traits
- OtelSpan
- OtelTracer
- actuator::configuration::ConfigurationBackend
- actuator::rollback::NotificationHandler
- actuator::traits::Actuator
- actuator::traits::CanaryDeployment
- actuator::traits::ConfigurationManager
- actuator::traits::HealthMonitor
- actuator::traits::TrafficSplitter
- aggregation::Aggregator
- aggregation::ToF64
- analyzer::traits::Analyzer
- core::EventTimeExtractor
- core::KeyExtractor
- decision::traits::DecisionEngine
- decision::traits::DecisionExecutor
- decision::traits::DecisionValidator
- decision::traits::OptimizationStrategy
- kafka::offset_manager::OffsetStore
- kafka::sink::MessageSerializer
- metrics::MetricLabels
- otel_global::ObjectSafeMeterProvider
- otel_global::ObjectSafeSpan
- otel_global::ObjectSafeTracer
- otel_global::ObjectSafeTracerProvider
- pipeline::operator::StreamOperator
- state::backend::StateBackend
- state::distributed_lock::DistributedLock
- storage::traits::Backup
- storage::traits::CacheStorage
- storage::traits::KeyValueStorage
- storage::traits::Migrator
- storage::traits::PubSubStorage
- storage::traits::RelationalStorage
- storage::traits::Storage
- storage::traits::Subscriber
- telemetry::Span
- telemetry::Tracer
- telemetry::global::ObjectSafeMeterProvider
- telemetry::global::ObjectSafeSpan
- telemetry::global::ObjectSafeTracer
- telemetry::global::ObjectSafeTracerProvider
- watermark::WatermarkGenerator
- window::assigner::WindowAssigner
- window::trigger::WindowTrigger
Macros
Functions
- analyzer::stats::calculate_iqr
- analyzer::stats::calculate_linear_trend
- analyzer::stats::calculate_percentiles
- analyzer::stats::calculate_rate
- analyzer::stats::is_outlier_iqr
- analyzer::stats::is_outlier_zscore
- analyzer::stats::mean
- analyzer::stats::percentage_change
- analyzer::stats::std_dev
- analyzer::stats::z_score
- otel_global::get_text_map_propagator
- otel_global::handle_error
- otel_global::meter
- otel_global::meter_provider
- otel_global::meter_with_version
- otel_global::set_error_handler
- otel_global::set_meter_provider
- otel_global::set_text_map_propagator
- otel_global::set_tracer_provider
- otel_global::shutdown_tracer_provider
- otel_global::tracer
- otel_global::tracer_provider
- state::compression::compress
- state::compression::decompress
- telemetry::context::context_with_span
- telemetry::context::extract_context
- telemetry::context::extract_from_headers
- telemetry::context::get_baggage
- telemetry::context::inject_context
- telemetry::context::inject_into_headers
- telemetry::context::propagate_context
- telemetry::context::with_baggage
- telemetry::context::with_context
- telemetry::global::get_text_map_propagator
- telemetry::global::handle_error
- telemetry::global::meter
- telemetry::global::meter_provider
- telemetry::global::meter_with_version
- telemetry::global::set_error_handler
- telemetry::global::set_meter_provider
- telemetry::global::set_text_map_propagator
- telemetry::global::set_tracer_provider
- telemetry::global::shutdown_tracer_provider
- telemetry::global::tracer
- telemetry::global::tracer_provider
- telemetry::init_telemetry
- telemetry::metrics::init_meter_provider
- telemetry::metrics::shutdown_meter_provider
- telemetry::resource::create_processor_resource
- telemetry::tracing::init_tracer_provider
- telemetry::tracing::record_exception
- telemetry::tracing::shutdown_tracer_provider
Type Aliases
- actuator::error::ActuatorResult
- analyzer::traits::AnalyzerResult
- decision::error::DecisionResult
- error::AggregationResult
- error::Result
- error::StateResult
- error::WatermarkResult
- error::WindowResult
- kafka::error::Result
- metrics::Result
- normalization::NormalizationResult
- state::StateResult
- state::compression::CompressionResult
- storage::error::StorageResult
Statics
Constants
- telemetry::metrics::metric_attributes::AGGREGATION_TYPE
- telemetry::metrics::metric_attributes::ERROR_TYPE
- telemetry::metrics::metric_attributes::EVENT_TYPE
- telemetry::metrics::metric_attributes::OPERATION_TYPE
- telemetry::metrics::metric_attributes::PARTITION_ID
- telemetry::metrics::metric_attributes::STATE_BACKEND
- telemetry::metrics::metric_attributes::WINDOW_TYPE
- telemetry::metrics::metric_names::AGGREGATION_DURATION
- telemetry::metrics::metric_names::DEDUPLICATION_COUNT
- telemetry::metrics::metric_names::EVENTS_DROPPED
- telemetry::metrics::metric_names::EVENTS_PROCESSED
- telemetry::metrics::metric_names::PROCESSING_DURATION
- telemetry::metrics::metric_names::STATE_OPERATION_DURATION
- telemetry::metrics::metric_names::WATERMARK_LAG
- telemetry::metrics::metric_names::WINDOW_TRIGGER_COUNT