List of all items
Structs
- backend::BackendCapabilities
- backend::BackendContext
- backend::GenericPhotonBackend
- checkpoint::CheckpointCoalescer
- consumer_group::ConsumerLease
- consumer_group::FleetGroupCoordinator
- consumer_group::GroupMember
- consumer_group::MemoryLeaseStore
- consumer_group::StaticAssignmentConfig
- consumer_group::StaticGroupCoordinator
- delivery::DlqRecord
- delivery::DlqRecordParams
- delivery::DlqSink
- delivery::WorkerPool
- delivery_mode::ShardConfig
- descriptor::TopicDescriptor
- event::TransportCrypto
- executor_services::ExecutorServices
- group_subscribe::AbortOnDrop
- handler_ctx::HandlerCtx
- handler_descriptor::HandlerDescriptor
- handler_registry::HandlerRegistry
- instrumentation::InstrumentedPhotonBackend
- instrumentation::PhotonDlqRow
- models::Envelope
- models::Event
- models::GroupOpts
- models::SubscribeOpts
- models::Subscription
- models::SubscriptionHandle
- models::TopicMetadata
- publish_routing::PublishTarget
- registry::TopicRegistry
- retention::ReclaimReport
- retention::RetentionDeps
- retention::RetentionPolicy
- retention::RetentionReclaimer
- retention::SubscriptionPartition
- retention::TopicPartition
- retention::WatermarkContext
- storage::InProcStoragePort
- storage::StorageCapabilities
Enums
- broker_security::BrokerTransportSecurity
- delivery_mode::DeliveryMode
- error::PhotonError
- instrumentation::FailureReason
- models::SubscriptionMode
Traits
- backend::PhotonBackend
- consumer_group::ConsumerGroupCoordinator
- consumer_group::LeaseStore
- retention::PartitionReclaim
- retention::RetentionHook
- storage::StoragePort
Functions
- consumer_group::instance_id_from_env
- consumer_group::member_count_from_env
- consumer_group::parse_shard_assignment
- consumer_group::round_robin_shards_for_member
- consumer_group::shard_count_from_env
- consumer_group::static_assigned_shards
- event::open_stored_event
- event::seal_event_for_storage
- group_subscribe::merge_shard_streams
- input::map_broker_connect_err
- input::redact_credentials_in_text
- input::redact_endpoint
- input::validate_payload_size
- input::validate_topic_name
- instrumentation::dlq_fields
- instrumentation::log_ops
- instrumentation::ops_log_fields
- instrumentation::record_drain
- instrumentation::record_handler_failure
- instrumentation::record_publish
- instrumentation::record_publish_error
- instrumentation::record_retention_reclaim
- instrumentation::record_retention_safe_seq
- instrumentation::wrap_backend
- publish_routing::resolve_publish_target
- retention::merge_truncate_bound
- retention::min_seq_pins
- retention::retention_max_age_secs
- retention::retention_pin_dlq
- retention::retention_sweep_ms
- retention::truncate_before_arg
- retention::truncate_bound_from_checkpoint
- sanitize::sanitize_error_message
- shard_router::group_publish_storage_key
- shard_router::is_shard_storage_key
- shard_router::parse_shard_storage_key
- shard_router::routing_key
- shard_router::shard_id
- shard_router::shard_storage_key
- storage::topic_filter_matches