Merge pull request #5549 from influxdata/alamb/guilio-python-main

chore: changed `iox_shared` to `iox-shared`

import/src/aggregate_tsm_schema/update_catalog.rs

@@ -494,7 +494,7 @@ mod tests {
             .repositories()
             .await
             .topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -524,8 +524,8 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         update_iox_catalog(
             &agg_schema,
-            "iox_shared",
-            Some("iox_shared"),
+            "iox-shared",
+            Some("iox-shared"),
             Some("inf"),
             Arc::clone(&catalog),
             connection,
@@ -580,7 +580,7 @@ mod tests {
             .await
             .expect("started transaction");
         txn.topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -644,8 +644,8 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         update_iox_catalog(
             &agg_schema,
-            "iox_shared",
-            Some("iox_shared"),
+            "iox-shared",
+            Some("iox-shared"),
             Some("inf"),
             Arc::clone(&catalog),
             connection,
@@ -685,7 +685,7 @@ mod tests {
             .await
             .expect("started transaction");
         txn.topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -742,8 +742,8 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         let err = update_iox_catalog(
             &agg_schema,
-            "iox_shared",
-            Some("iox_shared"),
+            "iox-shared",
+            Some("iox-shared"),
             Some("inf"),
             Arc::clone(&catalog),
             connection,
@@ -766,7 +766,7 @@ mod tests {
             .await
             .expect("started transaction");
         txn.topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -822,8 +822,8 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         let err = update_iox_catalog(
             &agg_schema,
-            "iox_shared",
-            Some("iox_shared"),
+            "iox-shared",
+            Some("iox-shared"),
             Some("inf"),
             Arc::clone(&catalog),
             connection,
@@ -845,7 +845,7 @@ mod tests {
             .repositories()
             .await
             .topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -875,7 +875,7 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         let err = update_iox_catalog(
             &agg_schema,
-            "iox_shared",
+            "iox-shared",
             None,
             Some("inf"),
             Arc::clone(&catalog),
@@ -895,7 +895,7 @@ mod tests {
             .repositories()
             .await
             .topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, _requests) = create_test_shard_service(MapToShardResponse {
@@ -925,7 +925,7 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         let err = update_iox_catalog(
             &agg_schema,
-            "iox_shared",
+            "iox-shared",
             Some("iox-shared"),
             None,
             Arc::clone(&catalog),
@@ -945,7 +945,7 @@ mod tests {
             .repositories()
             .await
             .topics()
-            .create_or_get("iox_shared")
+            .create_or_get("iox-shared")
             .await
             .expect("topic created");
         let (connection, _join_handle, requests) = create_test_shard_service(MapToShardResponse {
@@ -984,8 +984,8 @@ mod tests {
         let agg_schema: AggregateTSMSchema = json.try_into().unwrap();
         update_iox_catalog(
             &agg_schema,
-            "iox_shared",
-            Some("iox_shared"),
+            "iox-shared",
+            Some("iox-shared"),
             Some("inf"),
             Arc::clone(&catalog),
             connection,

influxdb_iox/src/commands/remote/partition.rs

@@ -225,9 +225,9 @@ pub async fn command(connection: Connection, config: Config) -> Result<(), Error
     }
 }
 
-const TOPIC_NAME: &str = "iox_shared";
+const TOPIC_NAME: &str = "iox-shared";
 const SHARD_INDEX: ShardIndex = ShardIndex::new(0);
-const QUERY_POOL: &str = "iox_shared";
+const QUERY_POOL: &str = "iox-shared";
 
 // loads the protobuf namespace schema returned from a remote IOx server into the passed in
 // catalog. It does this based on namespace, table, and column names, not IDs. It also inserts

querier/src/cache/read_buffer.rs

@@ -205,7 +205,7 @@ async fn read_buffer_chunk_from_stream(
     let schema = stream.schema();
 
     // create "global" metric object, so that we don't blow up prometheus w/ too many metrics
-    let metrics = ChunkMetrics::new(metric_registry, "iox_shared");
+    let metrics = ChunkMetrics::new(metric_registry, "iox-shared");
 
     let mut builder = read_buffer::RBChunkBuilder::new(schema).with_metrics(metrics);
 
@@ -516,7 +516,7 @@ mod tests {
             .get_instrument("read_buffer_row_group_total")
             .unwrap();
         let v = g
-            .get_observer(&Attributes::from(&[("db_name", "iox_shared")]))
+            .get_observer(&Attributes::from(&[("db_name", "iox-shared")]))
             .unwrap()
             .fetch();
 

service_grpc_catalog/src/lib.rs

@@ -133,10 +133,10 @@ mod tests {
             let metrics = Arc::new(metric::Registry::default());
             let catalog = Arc::new(MemCatalog::new(metrics));
             let mut repos = catalog.repositories().await;
-            let topic = repos.topics().create_or_get("iox_shared").await.unwrap();
+            let topic = repos.topics().create_or_get("iox-shared").await.unwrap();
             let pool = repos
                 .query_pools()
-                .create_or_get("iox_shared")
+                .create_or_get("iox-shared")
                 .await
                 .unwrap();
             let shard = repos
@@ -210,10 +210,10 @@ mod tests {
             let metrics = Arc::new(metric::Registry::default());
             let catalog = Arc::new(MemCatalog::new(metrics));
             let mut repos = catalog.repositories().await;
-            let topic = repos.topics().create_or_get("iox_shared").await.unwrap();
+            let topic = repos.topics().create_or_get("iox-shared").await.unwrap();
             let pool = repos
                 .query_pools()
-                .create_or_get("iox_shared")
+                .create_or_get("iox-shared")
                 .await
                 .unwrap();
             let shard = repos

service_grpc_object_store/src/lib.rs

@@ -112,10 +112,10 @@ mod tests {
             let metrics = Arc::new(metric::Registry::default());
             let catalog = Arc::new(MemCatalog::new(metrics));
             let mut repos = catalog.repositories().await;
-            let topic = repos.topics().create_or_get("iox_shared").await.unwrap();
+            let topic = repos.topics().create_or_get("iox-shared").await.unwrap();
             let pool = repos
                 .query_pools()
-                .create_or_get("iox_shared")
+                .create_or_get("iox-shared")
                 .await
                 .unwrap();
             let shard = repos