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
• 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

• 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
• group_subscribe::merge_shard_streams
• 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
• 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

Type Aliases

• backend::EmbeddedBackend
• error::Result
• handler_descriptor::HandlerInvoker

Constants

• shard_router::SHARD_KEY_PREFIX