fix for retention for distributed deployment

nikhilsinhaparseable · nikhilsinhaparseable · commit 052c6ded9603 · 2024-04-20T00:20:31.000+05:30
fix for stream info api
diff --git a/server/src/catalog.rs b/server/src/catalog.rs
@@ -284,15 +284,15 @@ pub async fn get_first_event(
                 let dates_bytes = Bytes::from(serde_json::to_vec(&dates).unwrap());
                 // delete the stream
 
-                let inegstor_first_event_at =
+                let ingestor_first_event_at =
                     handlers::http::cluster::send_retention_cleanup_request(
                         &url,
                         ingestor.clone(),
                         dates_bytes,
                     )
                     .await?;
-                if !inegstor_first_event_at.is_empty() {
-                    ingestors_first_event_at.push(inegstor_first_event_at);
+                if !ingestor_first_event_at.is_empty() {
+                    ingestors_first_event_at.push(ingestor_first_event_at);
                 }
             }
             if ingestors_first_event_at.is_empty() {

Original file line number	Diff line number	Diff line change
`@@ -284,15 +284,15 @@ pub async fn get_first_event(`
`284`	`284`	`let dates_bytes = Bytes::from(serde_json::to_vec(&dates).unwrap());`
`285`	`285`	`// delete the stream`
`286`	`286`
`287`		`- let inegstor_first_event_at =`
	`287`	`+ let ingestor_first_event_at =`
`288`	`288`	`handlers::http::cluster::send_retention_cleanup_request(`
`289`	`289`	`&url,`
`290`	`290`	`ingestor.clone(),`
`291`	`291`	`dates_bytes,`
`292`	`292`	`)`
`293`	`293`	`.await?;`
`294`		`- if !inegstor_first_event_at.is_empty() {`
`295`		`- ingestors_first_event_at.push(inegstor_first_event_at);`
	`294`	`+ if !ingestor_first_event_at.is_empty() {`
	`295`	`+ ingestors_first_event_at.push(ingestor_first_event_at);`
`296`	`296`	`}`
`297`	`297`	`}`
`298`	`298`	`if ingestors_first_event_at.is_empty() {`