Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix: Rename some more comments and test values from sequencer to shard

pull/24376/head
Carol (Nichols || Goulding) 2022-08-19 15:32:48 -04:00
parent 6443858870
commit ab20828c2f
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
iox_catalog/src/interface.rs
View File

@ -590,7 +590,7 @@ pub trait ParquetFileRepo: Send + Sync {
/// Return count
async fn count(&mut self) -> Result<i64>;
/// Return count of level-0 files of given tableId and sequenceId that
/// Return count of level-0 files of given tableId and shardId that
/// overlap with the given min_time and max_time and have sequencer number
/// smaller the given one
async fn count_by_overlaps_with_level_0(
@ -1341,14 +1341,14 @@ pub(crate) mod test_helpers {
.update_min_unpersisted_sequence_number(shard.id, SequenceNumber::new(53))
.await
.unwrap();
let updated_sequencer = repos
let updated_shard = repos
.shards()
.create_or_get(&kafka, kafka_partition)
.await
.unwrap();
assert_eq!(updated_sequencer.id, shard.id);
assert_eq!(updated_shard.id, shard.id);
assert_eq!(
updated_sequencer.min_unpersisted_sequence_number,
updated_shard.min_unpersisted_sequence_number,
SequenceNumber::new(53)
);