List of all items
Structs
- amqp_handler::AmqpConnection
- auth::audit::AuditConfig
- auth::audit::AuditEvent
- auth::audit::AuditLogger
- auth::audit::AuditQuery
- auth::audit::AuditStatistics
- auth::authentication::BasicAuthenticator
- auth::authentication::UserInfo
- auth::authorization::AccessPolicy
- auth::authorization::AuthDecision
- auth::authorization::AuthorizationConfig
- auth::authorization::AuthorizationContext
- auth::authorization::AuthorizationManager
- auth::authorization::PolicyCondition
- auth::authorization::Role
- auth::authorization::RoleBasedAccessControl
- auth::authorization::UserRoleAssignment
- auth::cli_auth::CliAuthManager
- auth::cli_auth::CliSession
- auth::cred_store::PersistedCreds
- auth::jwt_auth::AuthenticationResult
- auth::jwt_auth::BrokerClaims
- auth::jwt_auth::ClientClaims
- auth::jwt_auth::DistributedAuthenticator
- auth::jwt_auth::ValidationResult
- auth::token::Claims
- auth::token::TokenManager
- auth::web_middleware::JwtAuth
- auth::web_middleware::JwtAuthMiddleware
- broker::Broker
- broker::TopicConfig
- broker::cluster::Cluster
- broker::consensus::ConsensusConfig
- broker::consensus::ConsensusMetrics
- broker::consensus::RaftConsensus
- broker::consensus::RaftHeartbeatHandler
- broker::consensus::RaftVoteHandler
- broker::consumer::group::ConsumerGroup
- broker::consumer::group::GroupMember
- broker::data_replication::ReplicaState
- broker::data_replication::ReplicationConfig
- broker::data_replication::ReplicationLogEntry
- broker::data_replication::ReplicationManager
- broker::data_replication::ReplicationStats
- broker::disaster_recovery::BackupMetadata
- broker::disaster_recovery::BackupVerification
- broker::disaster_recovery::DisasterRecoveryManager
- broker::disaster_recovery::RecoveryOptions
- broker::disaster_recovery::RecoveryState
- broker::distributed::DistributedBroker
- broker::distributed::DistributedBrokerConfig
- broker::distributed::DistributedBrokerConfigBuilder
- broker::distributed::ReplicationHandler
- broker::distributed_storage::BackupConfig
- broker::distributed_storage::BackupData
- broker::distributed_storage::ClusterHealth
- broker::distributed_storage::ConsensusState
- broker::distributed_storage::DataPartition
- broker::distributed_storage::DistributedResult
- broker::distributed_storage::DistributedStats
- broker::distributed_storage::DistributedStorage
- broker::distributed_storage::DistributedTransaction
- broker::distributed_storage::ReplicatedEntry
- broker::distributed_storage::ReplicationConfig
- broker::distributed_storage::StorageNode
- broker::distributed_storage::VectorClock
- broker::dynamic_scaling::DynamicScalingConfig
- broker::dynamic_scaling::DynamicScalingManager
- broker::dynamic_scaling::DynamicScalingStats
- broker::dynamic_scaling::MetricsSnapshot
- broker::dynamic_scaling::NodeHealth
- broker::dynamic_scaling::PredictionModel
- broker::dynamic_scaling::ScalingDecision
- broker::dynamic_scaling::ScalingEvent
- broker::dynamic_scaling::ScalingImpact
- broker::leader::LeaderElection
- broker::leader::election::LeaderElection
- broker::leader::heartbeat::Heartbeat
- broker::leader::state::Term
- broker::log_compression::AdvancedLogCompression
- broker::log_compression::CompactionResult
- broker::log_compression::CompressionConfig
- broker::log_compression::CompressionStats
- broker::log_compression::IndexEntry
- broker::log_compression::LogCompressor
- broker::log_compression::SegmentMetadata
- broker::message_queue::MessageQueue
- broker::metrics::DistributedMetrics
- broker::metrics::SystemMetrics
- broker::node::Node
- broker::performance_optimizer::BatchProcessor
- broker::performance_optimizer::BatchProcessorStats
- broker::performance_optimizer::MemoryPool
- broker::performance_optimizer::MemoryPoolStats
- broker::performance_optimizer::MessageBatch
- broker::performance_optimizer::MessageMetadata
- broker::performance_optimizer::PerformanceConfig
- broker::performance_optimizer::PerformanceOptimizer
- broker::performance_optimizer::PerformanceStats
- broker::performance_optimizer::ZeroCopyBuffer
- broker::performance_optimizer::ZeroCopyMessage
- broker::pid_manager::PidManager
- broker::replication::ReplicationManager
- broker::replication::ReplicationState
- broker::scaling::ScalingConfig
- broker::scaling::ScalingManager
- broker::shutdown::GracefulShutdown
- broker::shutdown::ResourceManager
- broker::shutdown::TaskHandle
- broker::shutdown::TaskManager
- broker::split_brain::ClusterHealth
- broker::split_brain::QuorumHandler
- broker::split_brain::SplitBrainPrevention
- broker::split_brain_prevention::NodeConnectivity
- broker::split_brain_prevention::QuorumDecision
- broker::split_brain_prevention::RecoveryPlan
- broker::split_brain_prevention::SplitBrainConfig
- broker::split_brain_prevention::SplitBrainDetector
- broker::split_brain_prevention::SplitBrainStats
- broker::storage::ReplicationEntry
- broker::storage::Storage
- broker::storage::StorageStats
- broker::topic::Topic
- config::ConfigChangeEvent
- config::ConfigDiff
- config::ConfigManager
- config::ConfigReloader
- config::HotReloadMetrics
- config::LoggingConfig
- config::MonitoringConfig
- config::NetworkConfig
- config::PerformanceConfig
- config::ProductionConfig
- config::SecurityConfig
- config::StorageConfig
- crypto::Encryptor
- message::ack::MessageAck
- message::message::Message
- message::metadata::MessageMetadata
- monitoring::advanced_metrics::AdvancedMetricsSystem
- monitoring::advanced_metrics::Alert
- monitoring::advanced_metrics::AlertManager
- monitoring::advanced_metrics::AlertThresholds
- monitoring::advanced_metrics::ApplicationMetrics
- monitoring::advanced_metrics::ExportConfig
- monitoring::advanced_metrics::MetricsCollector
- monitoring::advanced_metrics::MetricsConfig
- monitoring::advanced_metrics::MetricsExport
- monitoring::advanced_metrics::MetricsSummary
- monitoring::advanced_metrics::NetworkIO
- monitoring::advanced_metrics::SystemMetrics
- monitoring::advanced_metrics::SystemSnapshot
- network::async_safe::AsyncSafeConnectionManager
- network::async_safe::AsyncSafeMetrics
- network::async_safe::AsyncSafeResourcePool
- network::connection::Connection
- network::connection::ConnectionManager
- network::discovery::NodeDiscovery
- network::discovery::NodeInfo
- network::enhanced_config::EnhancedNetworkConfig
- network::enhanced_config::FlowControlConfig
- network::enhanced_config::KeepAliveConfig
- network::enhanced_config::RetryPolicy
- network::enhanced_config::TimeoutConfig
- network::enhanced_config::TlsConfig
- network::enhanced_connection::ConnectionInfo
- network::enhanced_connection::ConnectionStats
- network::enhanced_connection::DefaultMessageHandler
- network::enhanced_connection::EnhancedConnectionManager
- network::enhanced_protocol::EnhancedCodec
- network::enhanced_protocol::EnhancedMessage
- network::enhanced_protocol::HandshakeManager
- network::enhanced_protocol::NodeDiscoveryInfo
- network::flow_control::BackpressureDetector
- network::flow_control::ConnectionFlowControl
- network::flow_control::FlowControlConfig
- network::flow_control::FlowWindow
- network::flow_control::OutstandingMessage
- network::flow_control::RateLimiter
- network::observability::ConnectionHealth
- network::observability::DiagnosticsReport
- network::observability::HealthCheckConfig
- network::observability::HealthChecker
- network::observability::NetworkDiagnostics
- network::observability::NetworkMetrics
- network::production::HeartbeatHandler
- network::production::NetworkStats
- network::production::ProductionNetworkBuilder
- network::production::ProductionNetworkConfig
- network::production::ProductionNetworkLayer
- network::protocol::DistributedMessage
- network::protocol::LogEntry
- network::protocol_v2::BinaryProtocolCodec
- network::protocol_v2::DistributedMessageV2
- network::protocol_v2::LogEntryData
- network::protocol_v2::NodeInfo
- network::protocol_v2::ProtocolNegotiator
- network::protocol_v2::TransactionOperation
- network::reconnection::ReconnectionConfig
- network::reconnection::ReconnectionManager
- network::reconnection::ReconnectionStats
- network::reliability::ReliabilityConfig
- network::reliability::ReliabilityManager
- network::reliability::ReliabilityStats
- network::reliability::TimeoutWrapper
- network::secure_protocol::ProtocolVersion
- network::secure_protocol::SecureFrame
- network::secure_protocol::SecureProtocol
- network::security::IntrusionDetectionConfig
- network::security::IntrusionDetectionSystem
- network::security::IpRateLimiter
- network::security::RateLimitConfig
- network::security::SecurityConfig
- network::security::SecurityManager
- network::security::SecurityStats
- network::security::SecurityToken
- network::security::SuspiciousActivity
- network::tls::CertificateInfo
- network::tls::SecurityInfo
- network::tls::TlsConfig
- network::tls::TlsManager
- network::transport::HeartbeatHandler
- network::transport::NetworkTransport
- network::transport::VoteHandler
- schema::message_schema::MessageSchema
- schema::registry::Schema
- schema::registry::SchemaRegistry
- schema::version::SchemaVersion
- security::AuditLogConfig
- security::AuditLogEntry
- security::AuditStats
- security::SecurityAuditLogger
- security::SecurityConfig
- security::SecurityManager
- security::SecurityStats
- security::SecurityValidationResult
- security::User
- security::authorization::AuthorizationContext
- security::authorization::AuthorizationResult
- security::authorization::EnhancedAuthorizationManager
- security::authorization::Permission
- security::authorization::Resource
- security::authorization::Role
- security::modern_tls::CertRotationConfig
- security::modern_tls::CertValidationConfig
- security::modern_tls::ClientCertVerificationResult
- security::modern_tls::ModernTlsConfig
- security::modern_tls::ModernTlsManager
- security::modern_tls::MutualTlsStatus
- security::modern_tls::TlsConnectionInfo
- security::tls_manager::CertRotationConfig
- security::tls_manager::CertValidationConfig
- security::tls_manager::ClientCertVerificationResult
- security::tls_manager::EnhancedTlsConfig
- security::tls_manager::EnhancedTlsManager
- security::tls_manager::MutualTlsStatus
- security::tls_manager::TlsConnectionInfo
- subscriber::types::Subscriber
- testing::integration::IntegrationTestSuite
- testing::integration::TestResult
- testing::integration::TestResults
- testing::load_test::LoadOperationResult
- testing::load_test::LoadTestConfig
- testing::load_test::LoadTestMetrics
- testing::load_test::LoadTestReport
- testing::load_test::LoadTester
- testing::load_test::StressTestConfig
- testing::load_test::StressTestReport
- testing::load_test::StressTester
- web_console::AppState
Enums
- auth::audit::AuditEventType
- auth::audit::AuditLogLevel
- auth::audit::EventOutcome
- auth::authorization::ConditionOperator
- auth::authorization::Permission
- auth::authorization::PolicyEffect
- auth::cli_auth::CliAuthError
- auth::web_middleware::WebAuthError
- broker::consensus::ConsensusState
- broker::data_replication::NodeState
- broker::data_replication::ReplicationMessage
- broker::disaster_recovery::BackupType
- broker::distributed::ClusterEvent
- broker::distributed_storage::ClockComparison
- broker::distributed_storage::ConsistencyLevel
- broker::distributed_storage::DistributionStrategy
- broker::distributed_storage::NodeStatus
- broker::distributed_storage::TransactionOperation
- broker::distributed_storage::TransactionState
- broker::dynamic_scaling::LoadBalancingStrategy
- broker::dynamic_scaling::NodeStatus
- broker::dynamic_scaling::ScalingDecisionType
- broker::dynamic_scaling::ScalingPriority
- broker::dynamic_scaling::ScalingResult
- broker::error::BrokerError
- broker::leader::state::BrokerState
- broker::log_compression::CompactionStrategy
- broker::log_compression::CompressionAlgorithm
- broker::replication::ReplicationEvent
- broker::replication::ReplicationStatus
- broker::scaling::ScalingError
- broker::scaling::ScalingEvent
- broker::shutdown::ShutdownResult
- broker::split_brain_prevention::CoordinationMessage
- broker::split_brain_prevention::NodeState
- broker::split_brain_prevention::PartitionState
- broker::split_brain_prevention::QuorumDecisionType
- broker::split_brain_prevention::RecoveryStrategy
- config::ConfigChangeSource
- crypto::CryptoError
- message::ack::AckStatus
- monitoring::advanced_metrics::AlertSeverity
- monitoring::advanced_metrics::AlertType
- network::async_safe::ConcurrencyError
- network::connection::StreamType
- network::discovery::NodeStatus
- network::enhanced_protocol::ConnectionState
- network::enhanced_protocol::EnhancedMessageType
- network::enhanced_protocol::EnhancedPayload
- network::error::NetworkError
- network::protocol::MessagePayload
- network::protocol::MessageType
- network::protocol_v2::MessagePayloadV2
- network::protocol_v2::MessageTypeV2
- network::protocol_v2::NodeStatus
- network::reconnection::ReconnectionError
- network::secure_protocol::MessageType
- network::secure_protocol::ProtocolError
- network::security::CertValidationMode
- network::security::Permission
- network::security::Severity
- network::security::SuspiciousPattern
- network::security::TokenScope
- network::tls::SecureStream
- schema::compatibility::Compatibility
- security::AdminEventType
- security::AuthEventType
- security::AuthzEventType
- security::DataAccessType
- security::EventResult
- security::EventSeverity
- security::SecurityEventType
- security::authorization::Action
- security::authorization::Condition
- security::authorization::ResourceType
- security::modern_tls::TlsVersion
- security::tls_manager::TlsVersion
Traits
- auth::authentication::Authenticator
- network::enhanced_connection::MessageHandler
- network::production::MessageHandler
- network::transport::MessageHandler
Functions
- auth::cred_store::default_security_dir
- auth::cred_store::get_or_create_key
- auth::cred_store::load
- auth::cred_store::save
- auth::web_middleware::get_authenticated_user_claims
- broker::node_management::check_node_health
- broker::node_management::recover_node
- config::load_config_from_path
- testing::integration::run_production_integration_tests
- testing::load_test::run_production_load_tests
- web_console::run_server
Type Aliases
- broker::data_replication::NodeId
- broker::node_management::ConsumerGroups
- broker::split_brain_prevention::NodeId
- network::async_safe::ConcurrencyResult
- network::error::NetworkResult
- network::reconnection::ReconnectionResult
- network::secure_protocol::ProtocolResult