List of all items

Structs

• ChannelPreferences
• build::BuildInfo
• builder::ModuleBuilder
• communication::ChannelCapabilities
• communication::ChannelPreferences
• communication::failover::BatchConfig
• communication::failover::CircuitBreaker
• communication::failover::CircuitBreakerConfig
• communication::failover::CircuitBreakerStats
• communication::failover::ConnectionPool
• communication::failover::FailoverConfig
• communication::failover::FailoverManager
• communication::failover::MessageBatch
• communication::failover::MessageBatcher
• communication::failover::MessageCompressor
• communication::failover::PerformanceConfig
• communication::failover::PoolStats
• communication::failover::PooledConnection
• communication::failover::RetryConfig
• communication::failover::RetryMechanism
• communication::http_ipc::ApiResponse
• communication::http_ipc::HttpIpcMetrics
• communication::http_ipc::HttpIpcRouter
• communication::http_ipc::HttpIpcServerConfig
• communication::http_tcp::ApiResponse
• communication::http_tcp::HttpTcpRequest
• communication::http_tcp::HttpTcpResponse
• communication::http_tcp::client::HttpClientPool
• communication::http_tcp::client::HttpTcpClient
• communication::http_tcp::client::RequestBuilder
• communication::http_tcp::router::HttpReceiver
• communication::http_tcp::router::HttpTcpRouter
• communication::http_tcp::router::Route
• communication::ipc::IpcManager
• communication::ipc_channel::IpcChannel
• communication::ipc_channel::IpcConnectionConfig
• communication::ipc_port_negotiation::PortNegotiationConfig
• communication::ipc_port_negotiation::PortNegotiationManager
• communication::ipc_types::AnnounceBlob
• communication::ipc_types::DiscoverServiceProvidersRequest
• communication::ipc_types::DiscoverServiceProvidersResponse
• communication::ipc_types::EndpointAnnounce
• communication::ipc_types::GetSecretRequest
• communication::ipc_types::InitBlob
• communication::ipc_types::IpcChannelConfig
• communication::ipc_types::IpcHttpRequest
• communication::ipc_types::IpcHttpResponse
• communication::ipc_types::IpcPortNegotiation
• communication::ipc_types::IpcPortNegotiationResponse
• communication::ipc_types::RegisterServiceProviderRequest
• communication::ipc_types::RegisterServiceProviderResponse
• communication::ipc_types::RotatedNotification
• communication::ipc_types::RotationAckRequest
• communication::ipc_types::SecretValueResponse
• communication::ipc_types::ServiceOperation
• communication::ipc_types::ServiceOperationResult
• communication::ipc_types::ServiceProviderInfo
• communication::ipc_types::ServiceRequest
• communication::ipc_types::ServiceResponse
• communication::ipc_types::TcpChannelConfig
• communication::message::EncodedMessage
• communication::message::EncodedStream
• communication::message::Message
• communication::message::MessageMetadata
• communication::metrics::AlertConfig
• communication::metrics::ChannelMetrics
• communication::metrics::ChannelPerformanceTracker
• communication::metrics::ComplianceStatus
• communication::metrics::PerformanceAlert
• communication::metrics::PerformanceComparisonReport
• communication::metrics::PerformanceMonitoringSystem
• communication::metrics::PoolMetrics
• communication::metrics::SlaConfig
• communication::metrics::SlaStatus
• communication::routing::ChannelHealth
• communication::routing::ChannelPreference
• communication::routing::ChannelRouter
• communication::routing::MessageCharacteristics
• communication::routing::RoutingConfig
• communication::routing::RoutingDecision
• communication::routing::RoutingMatrix
• communication::streaming::FlowControlWindow
• communication::streaming::PriorityMessageQueue
• communication::streaming::PubSubMessage
• communication::streaming::RequestMultiplexer
• communication::streaming::StreamAck
• communication::streaming::StreamChunk
• communication::streaming::StreamConfig
• communication::streaming::StreamMetadata
• communication::streaming::StreamReceiver
• communication::streaming::StreamSender
• communication::streaming::Subscription
• communication::tcp_channel::TcpChannel
• communication::tcp_types::ConnectionConfig
• communication::tcp_types::TlsConfig
• core::state::AppConfig
• core::state::AppState
• data::cache::CacheConfig
• data::cache::CacheStats
• data::cache::DefaultPoolConfig
• data::cache::file::FileCache
• data::cache::in_memory::InMemoryCache
• data::cache::patterns::DistributedLock
• data::cache::patterns::EventInvalidationStrategy
• data::cache::patterns::LruInvalidationStrategy
• data::cache::patterns::RetryConfig
• data::cache::patterns::TtlInvalidationStrategy
• data::cache::proxy_service::ProxyCacheService
• data::cache::redis::RedisCache
• data::database::DatabaseConfig
• data::database::PoolConfig
• internal_messaging::InternalMessagingClient
• security::secret_client::client::SecretClient
• security::secret_client::schema::GetSecretResponse
• security::secret_client::stdout::JsonStdout
• security::secret_provider::providers::chained_provider::ChainedProvider
• security::secret_provider::providers::env_provider::EnvProvider
• security::secret_provider::providers::file_provider::FileProvider
• security::secret_provider::providers::memory_provider::MemoryProvider
• security::secrets::typed_secret::Secret
• services::model_manager::ModelBuilder
• services::model_manager::adapters::mysql_adapter::MySqlAdapter
• services::model_manager::adapters::postgres_adapter::PostgresAdapter
• services::model_manager::adapters::sqlite_adapter::SqliteAdapter
• services::model_manager::definitions::ColumnDescriptor
• services::model_manager::definitions::IndexDescriptor
• services::model_manager::definitions::ModelDescriptor
• services::model_manager::generator::ModelGenerator
• services::registration::models::Capabilities
• services::registration::models::CapabilitiesRequest
• services::registration::models::CapabilitiesResponse
• services::registration::models::Endpoint
• services::registration::models::HeartbeatRequest
• services::registration::models::HeartbeatResponse
• services::registration::models::ModuleInfo
• services::registration::models::RegisteredModule
• services::registration::models::RegistrationRequest
• services::registration::models::RegistrationResponse
• services::registration::models::UnregistrationRequest
• services::registration::models::UnregistrationResponse
• services::server::ServeOptions

Enums

• SecurityLevel
• communication::ChannelType
• communication::failover::CircuitBreakerState
• communication::http_ipc::result::HttpIpcError
• communication::http_tcp::client::HttpClientError
• communication::http_tcp::router::HttpTcpError
• communication::ipc_port_negotiation::PortNegotiationResult
• communication::ipc_port_negotiation::SocketAddressError
• communication::ipc_types::ListenAddress
• communication::ipc_types::ModuleToOrchestrator
• communication::ipc_types::OrchestratorToModule
• communication::ipc_types::SecurityLevel
• communication::ipc_types::ServiceType
• communication::message::EncodingFormat
• communication::message::MessageError
• communication::metrics::AlertSeverity
• communication::metrics::AlertType
• communication::routing::MessagePriority
• communication::routing::MessageType
• communication::routing::RoutingCondition
• communication::routing::TargetLocation
• communication::streaming::StreamPriority
• communication::tcp_types::ConnectionState
• communication::tcp_types::NetworkError
• communication::tcp_types::ReconnectPolicy
• core::bootstrap::BootstrapError
• core::error::ConfigError
• core::error::Error
• data::cache::CacheError
• data::cache::CachePolicy
• data::cache::CacheType
• data::cache::patterns::LockError
• data::database::DatabaseError
• data::database::DatabaseType
• data::database::DatabaseValue
• internal_messaging::InternalMessagingError
• security::handshake::InitError
• security::secret_client::client::RequestMode
• security::secret_client::error::SecretClientError
• security::secret_provider::errors::SecretError
• security::secret_provider::events::SecretEvent
• security::secret_provider::providers::file_provider::FileFormat
• security::secrets::typed_secret::TypedSecretError
• services::announce::AnnounceError
• services::model_manager::definitions::Constraint
• services::model_manager::definitions::DataType
• services::model_manager::definitions::IndexType
• services::model_manager::definitions::IntegerSize
• services::model_manager::definitions::ReferentialAction
• services::model_manager::errors::Error
• services::registration::models::HealthStatus
• services::registration::models::RegistrationError
• services::server::Error

Traits

• communication::MessageChannel
• core::bootstrap::AppStateExt
• data::cache::CacheService
• data::cache::patterns::InvalidationStrategy
• data::database::DatabaseConnection
• data::database::DatabaseRow
• data::database::DatabaseTransaction
• ext::ListenExt
• ext::OrchestratorInitExt
• security::secret_provider::SecretProvider
• services::model_manager::adapters::DatabaseAdapter
• services::model_manager::sdk_integration::ModelManager

Macros

• core::logging::safe_log
• instrument_secret_op
• json_println
• safe_log
• stderr

Functions

• build::emit_build_info
• build::get_build_info
• communication::http_ipc::metrics
• communication::http_ipc::result::accepted
• communication::http_ipc::result::bad_request
• communication::http_ipc::result::conflict
• communication::http_ipc::result::created
• communication::http_ipc::result::diagnostic_response
• communication::http_ipc::result::error_response
• communication::http_ipc::result::forbidden
• communication::http_ipc::result::internal_error
• communication::http_ipc::result::json_response
• communication::http_ipc::result::method_not_allowed
• communication::http_ipc::result::not_found
• communication::http_ipc::result::parse_json_body
• communication::http_ipc::result::success
• communication::http_ipc::result::timeout
• communication::http_ipc::result::unauthorized
• communication::http_ipc::send_http_response
• communication::http_ipc::start_http_ipc_server
• communication::http_ipc::subscribe_http_requests
• communication::http_tcp::bad_request
• communication::http_tcp::created
• communication::http_tcp::error_response
• communication::http_tcp::internal_error
• communication::http_tcp::json_response
• communication::http_tcp::not_found
• communication::http_tcp::parse_json_body
• communication::http_tcp::router::start_http_server
• communication::http_tcp::serve
• communication::http_tcp::success
• communication::ipc::process_ipc_messages
• communication::ipc::receive_response
• communication::ipc::send_http_response
• communication::ipc::send_request
• communication::ipc::subscribe_http_requests
• communication::routing::extract_message_characteristics
• core::bootstrap::bootstrap_module
• core::bootstrap::bootstrap_module_legacy
• core::logging::init_module
• data::cache::create_cache_service
• data::cache::patterns::cache_aside
• data::cache::patterns::write_behind
• data::cache::patterns::write_through
• data::database::create_database_connection
• data::database::extensions::mysql_config
• data::database::extensions::postgres_config
• data::database::extensions::sqlite_config
• macros::module
• macros::module_init
• security::handshake::read_init
• security::secret_client::client::get_secret
• security::secret_client::client::print_json
• security::secret_client::client::print_stderr
• security::secret_client::init
• security::secret_client::logging::init_logging
• security::secret_client::logging::redact
• security::secret_client::logging::register_for_redaction
• security::secret_client::logging::register_secret_for_redaction
• security::secret_client::logging::stderr
• security::secret_client::stdout::stderr
• security::secret_client::with_redaction
• security::secret_provider::init
• security::secret_provider::redact_line
• security::secret_provider::tracing::add_hashed_key
• security::secret_provider::tracing::hash_key
• security::secret_provider::tracing::record_error
• security::secret_provider::tracing::record_success
• security::secrets::get_module_secret_client
• security::secrets::get_secret
• security::secrets::get_secrets
• security::secrets::subscribe_secret_rotations
• security::secrets::typed_secret::get_bool_secret
• security::secrets::typed_secret::get_int_secret
• security::secrets::typed_secret::get_string_secret
• security::secrets::typed_secret::get_typed_secret
• services::announce::router_discovery::announce_from_router
• services::announce::router_discovery::discover_endpoints
• services::announce::router_discovery::discover_endpoints_advanced
• services::announce::send_announce
• services::model_manager::create_simple_model
• services::model_manager::errors::adapter_error
• services::model_manager::errors::model_definition_error
• services::model_manager::errors::other_error
• services::model_manager::errors::sql_generation_error
• services::model_manager::errors::unsupported_feature_error
• services::model_manager::get_adapter_for_database_type
• services::model_manager::validate_model
• services::registration::advertise_capabilities
• services::registration::heartbeat
• services::registration::register_module
• services::registration::simple_heartbeat
• services::registration::start_heartbeat_loop
• services::registration::unregister_module
• services::server::get_pre_allocated_port
• services::server::serve_module
• services::server::serve_module_full
• services::server::serve_module_with_lifecycle
• services::server::serve_with_options
• services::server::set_pre_allocated_port
• utils::eprint_json
• utils::eprint_pretty_json
• utils::print_json
• utils::print_pretty_json

Type Aliases

• communication::http_ipc::HandlerFn
• communication::http_ipc::result::HttpResult
• communication::http_tcp::client::HttpClientResult
• communication::http_tcp::client::ResponseCallback
• communication::http_tcp::router::HandlerFn
• communication::http_tcp::router::HttpTcpResult
• communication::ipc_types::Announce
• communication::ipc_types::Endpoint
• communication::ipc_types::Init
• communication::message::MessageResult
• communication::tcp_types::NetworkResult
• core::error::Result
• core::state::ModuleMessageHandler
• data::cache::CacheResult
• data::database::DatabaseResult
• internal_messaging::InternalMessagingResult
• security::secrets::ModuleSecretError
• services::model_manager::errors::Result
• services::registration::Result

Constants

• build::BUILD_TIME_UTC
• build::GIT_HASH
• build::RUSTC_VERSION
• communication::ipc_port_negotiation::MAX_PORT
• communication::ipc_port_negotiation::MIN_DYNAMIC_PORT
• communication::ipc_port_negotiation::NEGOTIATION_PORT