Module wal_provider

Modules§

optional_region_wal_options_serde: Serde helpers for optional RegionWalOptions persisted in procedure state.
region_wal_options_serde: Serde helpers for RegionWalOptions persisted in metadata.
selector 🔒
topic_creator 🔒
topic_manager 🔒
topic_pool 🔒

acquire_remote_wal_read_locks: Acquires per-topic read locks for remote WAL topics.
build_kafka_client: Builds a kafka Client.
build_kafka_topic_creator: Builds a KafkaTopicCreator.
build_wal_provider: Builds a wal provider based on the given configuration.
deserialize_region_wal_options 🔒
extract_topic_from_wal_options: Extracts the topic from the wal options.
refresh_initial_pruned_entry_ids: Refreshes initial pruned entry ids for Kafka WAL options.
remote_wal_topics: Returns remote WAL topics referenced by region WAL options.
serialize_wal_options: Serializes and inserts WAL options into the region options.