Skip to content

Commit c388a59

Browse files
make clearer
1 parent 9b7053d commit c388a59

2 files changed

Lines changed: 6 additions & 4 deletions

File tree

consensus/src/marshal/core/actor.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,10 @@ where
177177
)
178178
.await;
179179

180-
let stream = Stream::new(context.child("stream"), &config.partition_prefix).await;
180+
// The application metadata name is retained for legacy support.
181+
let application_metadata_partition =
182+
format!("{}-application-metadata", config.partition_prefix);
183+
let stream = Stream::new(context.child("stream"), &application_metadata_partition).await;
181184
let last_processed_height = stream.processed_height();
182185
let processed_height_floor = last_processed_height.unwrap_or_else(Height::zero);
183186

consensus/src/marshal/core/stream.rs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,12 +49,11 @@ pub(super) struct Stream<E: Context> {
4949
}
5050

5151
impl<E: Context> Stream<E> {
52-
pub(super) async fn new(context: E, partition_prefix: &str) -> Self {
52+
pub(super) async fn new(context: E, application_metadata_partition: &str) -> Self {
5353
let metadata = Metadata::init(
5454
context,
5555
metadata::Config {
56-
// The application metadata name is retained for legacy support.
57-
partition: format!("{partition_prefix}-application-metadata"),
56+
partition: application_metadata_partition.to_string(),
5857
codec_config: (),
5958
},
6059
)

0 commit comments

Comments
 (0)