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

fix: Remove iox catalog shard tests

pull/24376/head
Carol (Nichols || Goulding) 2023-04-19 15:11:52 -04:00
parent 8f17d217fb
commit cf051e8091
No known key found for this signature in database
GPG Key ID: E907EE5A736F87D4
1 changed files with 0 additions and 67 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
iox_catalog/src/interface.rs
View File

@ -875,10 +875,6 @@ pub(crate) mod test_helpers {
test_column(Arc::clone(&catalog)).await; test_column(Arc::clone(&catalog)).await;
assert_metric_hit(&catalog.metrics(), "column_create_or_get"); assert_metric_hit(&catalog.metrics(), "column_create_or_get");
let catalog = clean_state().await;
test_shards(Arc::clone(&catalog)).await;
assert_metric_hit(&catalog.metrics(), "shard_create_or_get");
let catalog = clean_state().await; let catalog = clean_state().await;
test_partition(Arc::clone(&catalog)).await; test_partition(Arc::clone(&catalog)).await;
assert_metric_hit(&catalog.metrics(), "partition_create_or_get"); assert_metric_hit(&catalog.metrics(), "partition_create_or_get");
@ -1546,69 +1542,6 @@ pub(crate) mod test_helpers {
.expect("delete namespace should succeed"); .expect("delete namespace should succeed");
} }
async fn test_shards(catalog: Arc<dyn Catalog>) {
let mut repos = catalog.repositories().await;
let topic = repos.topics().create_or_get("shard_test").await.unwrap();
// Create 10 shards
let mut created = BTreeMap::new();
for shard_index in 1..=10 {
let shard = repos
.shards()
.create_or_get(&topic, ShardIndex::new(shard_index))
.await
.expect("failed to create shard");
created.insert(shard.id, shard);
}
// List them and assert they match
let listed = repos
.shards()
.list_by_topic(&topic)
.await
.expect("failed to list shards")
.into_iter()
.map(|v| (v.id, v))
.collect::<BTreeMap<_, _>>();
assert_eq!(created, listed);
// get by the topic and shard index
let shard_index = ShardIndex::new(1);
let shard = repos
.shards()
.get_by_topic_id_and_shard_index(topic.id, shard_index)
.await
.unwrap()
.unwrap();
assert_eq!(topic.id, shard.topic_id);
assert_eq!(shard_index, shard.shard_index);
// update the number
repos
.shards()
.update_min_unpersisted_sequence_number(shard.id, SequenceNumber::new(53))
.await
.unwrap();
let updated_shard = repos
.shards()
.create_or_get(&topic, shard_index)
.await
.unwrap();
assert_eq!(updated_shard.id, shard.id);
assert_eq!(
updated_shard.min_unpersisted_sequence_number,
SequenceNumber::new(53)
);
let shard = repos
.shards()
.get_by_topic_id_and_shard_index(topic.id, ShardIndex::new(523))
.await
.unwrap();
assert!(shard.is_none());
}
async fn test_partition(catalog: Arc<dyn Catalog>) { async fn test_partition(catalog: Arc<dyn Catalog>) {
let mut repos = catalog.repositories().await; let mut repos = catalog.repositories().await;
let topic = repos.topics().create_or_get("foo").await.unwrap(); let topic = repos.topics().create_or_get("foo").await.unwrap();