List of all items

Structs

• cache::Cache
• cache::config::CacheConfig
• cli::CommonArgs
• cli::ServiceRuntime
• cli::VersionInfo
• concurrency::ActorConfig
• concurrency::ActorHandle
• concurrency::ActorJoinHandle
• concurrency::BackgroundSink
• concurrency::BackgroundSinkConfig
• concurrency::BackgroundSinkHandle
• concurrency::PeriodicWorker
• config::Config
• config::ConfigOptions
• config::env_compat::EnvVar
• config::flat_env::EnvVarDoc
• config::registry::ConfigSection
• config::reloader::ConfigReloader
• config::reloader::ReloaderConfig
• config::shared::SharedConfig
• database::ClickHouseUrl
• database::DbConnection
• database::MongoUrl
• database::PostgresUrl
• database::RedisUrl
• deployment::AptRepoContract
• deployment::ContractMismatch
• deployment::DeploymentContract
• deployment::HealthContract
• deployment::KedaConfig
• deployment::KedaContract
• deployment::NativeDepsContract
• deployment::OciLabels
• deployment::PortContract
• deployment::SecretEnvContract
• deployment::SecretGroupContract
• deployment::app_project::AppProjectContract
• deployment::app_project::AppProjectDestination
• deployment::contract_identity::ContractIdentity
• deployment::generate::ArgocdConfig
• directory_config::store::DirectoryConfigStore
• directory_config::types::ChangeEvent
• directory_config::types::DirectoryConfigStoreConfig
• directory_config::types::WriteResult
• dlq::Dlq
• dlq::DlqConfig
• dlq::DlqEntry
• dlq::DlqSource
• dlq::FileDlqConfig
• dlq::HttpDlqConfig
• dlq::RedisDlqConfig
• env::RuntimeContext
• expression::profile::ProfileConfig
• governor::ByteBudgetConfig
• governor::ByteBudgetController
• governor::Hysteresis
• governor::InboundGate
• governor::MemoryPressureSource
• governor::NoopActuator
• governor::ObservingActuator
• governor::Pressure
• governor::SelfRegulationConfig
• governor::SelfRegulationGovernor
• governor::UnifiedPressure
• governor::UnifiedPressureSnapshot
• health::registry::HealthRegistry
• http_client::HttpClient
• http_client::config::HttpClientConfig
• http_server::Extension
• http_server::HttpServer
• http_server::HttpServerConfig
• http_server::Json
• http_server::Path
• http_server::Query
• http_server::Router
• http_server::State
• io::AsyncNdjsonWriter
• io::FileWriterConfig
• io::NdjsonWriter
• kafka_config::DfeSource
• logger::LoggerOptions
• logger::MaskingLayer
• logger::MaskingWriter
• logger::ThrottleConfig
• logger::format::ColouredFormatter
• logger::security::SecurityEvent
• memory::guard::MemoryGuard
• memory::guard::MemoryGuardConfig
• metrics::ContainerMetrics
• metrics::MetricsConfig
• metrics::MetricsManager
• metrics::ProcessMetrics
• metrics::RenderHandle
• metrics::dfe::DfeMetrics
• metrics::dfe_groups::AppMetrics
• metrics::dfe_groups::BackpressureMetrics
• metrics::dfe_groups::BufferMetrics
• metrics::dfe_groups::CircuitBreakerMetrics
• metrics::dfe_groups::ConsumerMetrics
• metrics::dfe_groups::EnrichmentMetrics
• metrics::dfe_groups::SchemaCacheMetrics
• metrics::dfe_groups::SinkMetrics
• metrics::manifest::ManifestResponse
• metrics::manifest::MetricDescriptor
• metrics::manifest::MetricRegistry
• metrics::otel_types::OtelMetricsConfig
• otel_tracing::OtelTracingConfig
• output::FileOutput
• output::FileOutputConfig
• runtime::RuntimePaths
• scaling::ComponentSnapshot
• scaling::PressureSnapshot
• scaling::RateWindow
• scaling::ScalingComponent
• scaling::ScalingPressure
• scaling::ScalingPressureConfig
• secrets::CacheConfig
• secrets::CacheStats
• secrets::FileProvider
• secrets::OpenBaoConfig
• secrets::OpenBaoProvider
• secrets::RotationEvent
• secrets::SecretCache
• secrets::SecretMetadata
• secrets::SecretValue
• secrets::SecretsConfig
• secrets::SecretsManager
• sensitive::SensitiveString
• spool::Spool
• spool::SpoolConfig
• strmatch::Match
• strmatch::SetMatch
• strmatch::StrMatcher
• strmatch::StrMatcherBuilder
• strmatch::StrMatcherSet
• tiered_sink::CircuitBreaker
• tiered_sink::DiskAwareConfig
• tiered_sink::TieredSink
• tiered_sink::TieredSinkConfig
• transport::FormatDetector
• transport::Message
• transport::Record
• transport::RecordMeta
• transport::RecvBatch
• transport::RecvLimits
• transport::TransportConfig
• transport::WorkBatch
• transport::file::FileToken
• transport::file::FileTransport
• transport::file::FileTransportConfig
• transport::filter::FilteredBatch
• transport::filter::FilteredDlqEntry
• transport::filter::TransportFilterEngine
• transport::filter::budget::FilterBudget
• transport::filter::config::FilterRule
• transport::filter::config::TransportFilterTierConfig
• transport::filter::metrics::FilterMetrics
• transport::grpc::GrpcTransport
• transport::grpc::config::GrpcConfig
• transport::grpc::proto::Batch
• transport::grpc::proto::BatchAck
• transport::grpc::proto::Header
• transport::grpc::proto::HealthCheckRequest
• transport::grpc::proto::HealthCheckResponse
• transport::grpc::proto::PushRequest
• transport::grpc::proto::PushResponse
• transport::grpc::proto::Record
• transport::grpc::proto::dfe_transport_client::DfeTransportClient
• transport::grpc::proto::dfe_transport_server::DfeTransportServer
• transport::grpc::token::GrpcToken
• transport::http::HttpToken
• transport::http::HttpTransport
• transport::http::HttpTransportConfig
• transport::memory::MemoryConfig
• transport::memory::MemorySender
• transport::memory::MemoryToken
• transport::memory::MemoryTransport
• transport::pipe::PipeToken
• transport::pipe::PipeTransport
• transport::pipe::PipeTransportConfig
• transport::redis_transport::RedisToken
• transport::redis_transport::RedisTransport
• transport::redis_transport::RedisTransportConfig
• transport::routed::RoutedSender
• version_check::VersionCheck
• version_check::VersionCheckConfig
• version_check::VersionCheckResponse
• worker::AccumulatorConfig
• worker::AccumulatorFull
• worker::AdaptiveWorkerPool
• worker::BatchAccumulator
• worker::BatchDrainer
• worker::BatchPipeline
• worker::FanOutPolicy
• worker::PipelineStats
• worker::PipelineStatsSnapshot
• worker::ScalingDecision
• worker::ScalingInput
• worker::WorkerPoolConfig
• worker::engine::BatchEngine
• worker::engine::config::BatchProcessingConfig
• worker::engine::driver::ParsedBatch
• worker::engine::intern::FieldInterner
• worker::engine::types::MessageMetadata

Enums

• cli::CliError
• cli::StandardCommand
• concurrency::ActorError
• concurrency::DrainError
• concurrency::Overflow
• concurrency::SinkError
• concurrency::TickError
• config::ConfigError
• deployment::DeploymentError
• deployment::ImageProfile
• deployment::contract_identity::IdentityError
• directory_config::error::DirectoryConfigError
• directory_config::types::ChangeOperation
• directory_config::types::WriteMode
• dlq::DlqBackend
• dlq::DlqError
• dlq::DlqMode
• dlq::RotationPeriod
• env::Environment
• expression::error::ExpressionError
• governor::Admit
• governor::SelfRegulationProfile
• health::registry::HealthStatus
• http_client::HttpClientError
• http_server::HttpServerError
• io::RotationPeriod
• kafka_config::KafkaConfigError
• kafka_config::ServiceRole
• logger::LogFormat
• logger::LoggerError
• logger::security::SecurityOutcome
• memory::guard::MemoryPressure
• metrics::MetricsError
• metrics::labels::AuthFailureReason
• metrics::labels::FlushTrigger
• metrics::labels::TransportKind
• metrics::labels::ValidationFailureReason
• metrics::manifest::MetricType
• metrics::otel_types::OtelProtocol
• otel_tracing::OtelTracingError
• otel_tracing::OtelTracingProtocol
• output::OutputError
• scaling::GateType
• secrets::OpenBaoAuth
• secrets::SecretSource
• secrets::SecretsError
• spool::SpoolError
• strmatch::BuildError
• strmatch::MatcherTier
• strmatch::OnBelowMin
• tiered_sink::CircuitState
• tiered_sink::CompressionCodec
• tiered_sink::DrainStrategy
• tiered_sink::OrderingMode
• tiered_sink::SinkError
• tiered_sink::TieredSinkError
• transport::DetectedFormat
• transport::FormatMode
• transport::FramingError
• transport::PayloadFormat
• transport::SendResult
• transport::TransportError
• transport::TransportType
• transport::codec::CodecError
• transport::codec::FieldRef
• transport::codec::ParsedPayload
• transport::factory::AnyReceiver
• transport::factory::AnySender
• transport::factory::AnyToken
• transport::filter::FilterDisposition
• transport::filter::budget::BudgetError
• transport::filter::classify::ClassifyResult
• transport::filter::classify::Tier1Op
• transport::filter::compiled::CompiledFilter
• transport::filter::config::FilterAction
• transport::filter::config::FilterDirection
• transport::filter::config::FilterTier
• transport::grpc::proto::Format
• transport::grpc::proto::ServingStatus
• worker::FanOutResult
• worker::engine::EngineError
• worker::engine::FilterDlqPolicy
• worker::engine::config::ParseErrorAction
• worker::engine::config::PreRouteFilterConfig
• worker::engine::driver::CommitMode
• worker::engine::parse::ParseError
• worker::engine::pre_route::PreRouteExtraction
• worker::engine::pre_route::PreRouteFilter
• worker::engine::pre_route::PreRouteOutcome
• worker::engine::types::ParsedMessage
• worker::engine::types::PayloadFormat
• worker::engine::types::PreRouteResult

Traits

• cli::DfeApp
• concurrency::Actor
• concurrency::PeriodicTask
• concurrency::SinkDrain
• config::flat_env::ApplyFlatEnv
• config::flat_env::Normalize
• database::DatabaseUrl
• governor::GateActuator
• governor::PressureSource
• http_server::IntoResponse
• secrets::SecretProvider
• tiered_sink::Sink
• transport::CommitToken
• transport::FromCascade
• transport::Transport
• transport::TransportBase
• transport::TransportReceiver
• transport::TransportSender
• transport::grpc::proto::dfe_transport_server::DfeTransport
• worker::BatchProcessor

Functions

• cli::output::print_error
• cli::output::print_info
• cli::output::print_kv
• cli::output::print_success
• cli::output::print_table
• cli::output::print_warn
• cli::run_app
• config::env_compat::aws::access_key_id
• config::env_compat::aws::endpoint_url
• config::env_compat::aws::region
• config::env_compat::aws::secret_access_key
• config::env_compat::aws::session_token
• config::env_compat::clickhouse::database
• config::env_compat::clickhouse::host
• config::env_compat::clickhouse::http_port
• config::env_compat::clickhouse::native_port
• config::env_compat::clickhouse::password
• config::env_compat::clickhouse::user
• config::env_compat::kafka::bootstrap_servers
• config::env_compat::kafka::client_id
• config::env_compat::kafka::group_id
• config::env_compat::kafka::profile
• config::env_compat::kafka::sasl_mechanism
• config::env_compat::kafka::sasl_password
• config::env_compat::kafka::sasl_username
• config::env_compat::kafka::security_protocol
• config::env_compat::kafka::ssl_ca_location
• config::env_compat::kafka::ssl_skip_verify
• config::env_compat::kafka::topics
• config::env_compat::kafka::with_prefix
• config::env_compat::load_all_standard
• config::env_compat::postgres::database
• config::env_compat::postgres::host
• config::env_compat::postgres::password
• config::env_compat::postgres::port
• config::env_compat::postgres::sslmode
• config::env_compat::postgres::user
• config::env_compat::vault::addr
• config::env_compat::vault::approle_role_id
• config::env_compat::vault::approle_secret_id
• config::env_compat::vault::ca_cert
• config::env_compat::vault::k8s_role
• config::env_compat::vault::namespace
• config::env_compat::vault::skip_verify
• config::env_compat::vault::token
• config::flat_env::flat_env_bool
• config::flat_env::flat_env_list
• config::flat_env::flat_env_parsed
• config::flat_env::flat_env_string
• config::flat_env::flat_env_string_sensitive
• config::flat_env::load_config
• config::get
• config::registry::dump_defaults
• config::registry::dump_effective
• config::registry::get_section
• config::registry::is_registered
• config::registry::on_change
• config::registry::register
• config::registry::sections
• config::registry::update
• config::setup
• config::try_get
• deployment::app_project::generate_argocd_app_project
• deployment::argocd_repo_url_from_cascade
• deployment::base_image_from_cascade
• deployment::generate::generate_argocd_application
• deployment::generate::generate_chart
• deployment::generate::generate_compose_fragment
• deployment::generate::generate_container_manifest
• deployment::generate::generate_dockerfile
• deployment::generate::generate_runtime_stage
• deployment::image_registry_from_cascade
• deployment::validate_dockerfile
• deployment::validate_helm_values
• env::get_app_env
• env::is_helm
• env::is_production
• env::runtime_context
• expression::evaluator::build_context
• expression::evaluator::compile
• expression::evaluator::compile_with_config
• expression::evaluator::evaluate
• expression::evaluator::evaluate_condition
• expression::evaluator::validate
• expression::evaluator::validate_with_config
• expression::profile::check_profile
• expression::profile::check_profile_with_config
• http_server::delete
• http_server::get
• http_server::post
• http_server::put
• init
• kafka_config::config_from_file
• kafka_config::config_from_properties_str
• kafka_config::merge_with_overrides
• logger::default_sensitive_fields
• logger::helpers::log_debounced
• logger::helpers::log_sampled
• logger::helpers::log_state_change
• logger::mask_sensitive_string
• logger::security::access_denied
• logger::security::auth_failure
• logger::security::auth_success
• logger::security::config_changed
• logger::security::data_quality_alert
• logger::security::input_validation_failure
• logger::security::rate_limit_triggered
• logger::security::record_dlq
• logger::security::tls_event
• logger::security::token_rotated
• logger::setup
• logger::setup_default
• memory::cgroup::detect_memory_limit
• memory::cgroup::detect_memory_pressure
• memory::guard::set_heap_source
• metrics::latency_buckets
• metrics::size_buckets
• otel_tracing::build_tracer_layer
• sensitive::expose_during
• shutdown::install_signal_handler
• shutdown::is_shutdown
• shutdown::token
• shutdown::trigger
• transport::codec::parse
• transport::codec::to_json_bytes
• transport::codec::to_msgpack_bytes
• transport::detect_format
• transport::filter::budget::check_payload_budget
• transport::filter::budget::check_static_budget
• transport::filter::classify::classify
• transport::grpc::batch::proto_batch_to_records
• transport::grpc::batch::records_to_proto
• transport::propagation::current_traceparent
• transport::propagation::format_traceparent_raw
• transport::propagation::is_valid_traceparent
• worker::engine::metrics::emit_thresholds
• worker::engine::metrics::register
• worker::engine::parse::parse_payload
• worker::engine::pre_route::apply_filters
• worker::engine::pre_route::extract_routing_field
• worker::engine::pre_route::filters_from_config
• worker::ndjson::count_lines
• worker::ndjson::split_lines
• worker::records_into_work_batch

Type Aliases

• directory_config::error::DirectoryConfigResult
• dlq::Result
• expression::error::ExpressionResult
• http_server::Response
• http_server::Result
• kafka_config::KafkaConfigResult
• metrics::ReadinessFn
• secrets::SecretsResult
• spool::Result
• tiered_sink::Result
• transport::TransportResult

Constants

• VERSION
• deployment::DEFAULT_BASE_IMAGE
• deployment::DEFAULT_IMAGE_REGISTRY
• deployment::contract_identity::KEY_PREFIX
• deployment::contract_identity::VERSION
• deployment::waves::WAVE_APPS
• deployment::waves::WAVE_CRDS
• deployment::waves::WAVE_OPERATORS
• deployment::waves::WAVE_POST
• deployment::waves::WAVE_TOPICS
• expression::profile::ALLOWED_FUNCTIONS
• expression::profile::DISALLOWED_FUNCTIONS
• expression::profile::RESTRICTED_ITERATION
• expression::profile::RESTRICTED_REGEX
• expression::profile::RESTRICTED_TIME
• kafka_config::CONSUMER_DEVTEST
• kafka_config::CONSUMER_LOW_LATENCY
• kafka_config::CONSUMER_PRODUCTION
• kafka_config::PRODUCER_DEVTEST
• kafka_config::PRODUCER_EXACTLY_ONCE
• kafka_config::PRODUCER_LOW_LATENCY
• kafka_config::PRODUCER_PRODUCTION
• kafka_config::TOPIC_SUFFIX_LAND
• kafka_config::TOPIC_SUFFIX_LOAD
• transport::grpc::proto::dfe_transport_server::SERVICE_NAME
• transport::propagation::TRACEPARENT_HEADER