Skip to content

Commit 3a3bd34

Browse files
authored
Rename IndexPart::{from_s3_bytes,to_s3_bytes} (#9481)
We support multiple storage backends now, so remove the `_s3_` from the name. Analogous to the names adopted for tenant manifests added in #9444.
1 parent 64949a3 commit 3a3bd34

File tree

3 files changed

+14
-14
lines changed

3 files changed

+14
-14
lines changed

pageserver/ctl/src/index_part.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ pub(crate) async fn main(cmd: &IndexPartCmd) -> anyhow::Result<()> {
1111
match cmd {
1212
IndexPartCmd::Dump { path } => {
1313
let bytes = tokio::fs::read(path).await.context("read file")?;
14-
let des: IndexPart = IndexPart::from_s3_bytes(&bytes).context("deserialize")?;
14+
let des: IndexPart = IndexPart::from_json_bytes(&bytes).context("deserialize")?;
1515
let output = serde_json::to_string_pretty(&des).context("serialize output")?;
1616
println!("{output}");
1717
Ok(())

pageserver/src/tenant/remote_timeline_client/index.rs

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -121,11 +121,11 @@ impl IndexPart {
121121
self.disk_consistent_lsn
122122
}
123123

124-
pub fn from_s3_bytes(bytes: &[u8]) -> Result<Self, serde_json::Error> {
124+
pub fn from_json_bytes(bytes: &[u8]) -> Result<Self, serde_json::Error> {
125125
serde_json::from_slice::<IndexPart>(bytes)
126126
}
127127

128-
pub fn to_s3_bytes(&self) -> serde_json::Result<Vec<u8>> {
128+
pub fn to_json_bytes(&self) -> serde_json::Result<Vec<u8>> {
129129
serde_json::to_vec(self)
130130
}
131131

@@ -383,7 +383,7 @@ mod tests {
383383
last_aux_file_policy: None,
384384
};
385385

386-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
386+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
387387
assert_eq!(part, expected);
388388
}
389389

@@ -427,7 +427,7 @@ mod tests {
427427
last_aux_file_policy: None,
428428
};
429429

430-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
430+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
431431
assert_eq!(part, expected);
432432
}
433433

@@ -472,7 +472,7 @@ mod tests {
472472
last_aux_file_policy: None,
473473
};
474474

475-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
475+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
476476
assert_eq!(part, expected);
477477
}
478478

@@ -520,7 +520,7 @@ mod tests {
520520
last_aux_file_policy: None,
521521
};
522522

523-
let empty_layers_parsed = IndexPart::from_s3_bytes(empty_layers_json.as_bytes()).unwrap();
523+
let empty_layers_parsed = IndexPart::from_json_bytes(empty_layers_json.as_bytes()).unwrap();
524524

525525
assert_eq!(empty_layers_parsed, expected);
526526
}
@@ -563,7 +563,7 @@ mod tests {
563563
last_aux_file_policy: None,
564564
};
565565

566-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
566+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
567567
assert_eq!(part, expected);
568568
}
569569

@@ -609,7 +609,7 @@ mod tests {
609609
last_aux_file_policy: None,
610610
};
611611

612-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
612+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
613613
assert_eq!(part, expected);
614614
}
615615

@@ -660,7 +660,7 @@ mod tests {
660660
last_aux_file_policy: Some(AuxFilePolicy::V2),
661661
};
662662

663-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
663+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
664664
assert_eq!(part, expected);
665665
}
666666

@@ -716,7 +716,7 @@ mod tests {
716716
last_aux_file_policy: Default::default(),
717717
};
718718

719-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
719+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
720720
assert_eq!(part, expected);
721721
}
722722

@@ -773,7 +773,7 @@ mod tests {
773773
last_aux_file_policy: Default::default(),
774774
};
775775

776-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
776+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
777777
assert_eq!(part, expected);
778778
}
779779

@@ -835,7 +835,7 @@ mod tests {
835835
archived_at: None,
836836
};
837837

838-
let part = IndexPart::from_s3_bytes(example.as_bytes()).unwrap();
838+
let part = IndexPart::from_json_bytes(example.as_bytes()).unwrap();
839839
assert_eq!(part, expected);
840840
}
841841

pageserver/src/tenant/remote_timeline_client/upload.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ pub(crate) async fn upload_index_part<'a>(
4141
pausable_failpoint!("before-upload-index-pausable");
4242

4343
// FIXME: this error comes too late
44-
let serialized = index_part.to_s3_bytes()?;
44+
let serialized = index_part.to_json_bytes()?;
4545
let serialized = Bytes::from(serialized);
4646

4747
let index_part_size = serialized.len();

0 commit comments

Comments
 (0)