Skip to content

Commit 5605591

Browse files
committed
migrate: remove special handling for cronut
This handling is no longer required now that `migrate` is directly integrated into the control plane `agent`.
1 parent d09cb56 commit 5605591

File tree

1 file changed

+2
-16
lines changed

1 file changed

+2
-16
lines changed

crates/migrate/src/lib.rs

Lines changed: 2 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -531,25 +531,11 @@ async fn fetch_data_plane(pg_pool: &sqlx::PgPool, name: &str) -> anyhow::Result<
531531
)
532532
.context("failed to sign claims for data-plane")?;
533533

534-
// Data-plane gateway doesn't support journal suspension,
535-
// nor do we want to update it to do so, so require that
536-
// cronut is port-forwarded locally.
537-
let broker_address = if row.broker_address.contains("svc.cluster.local:") {
538-
"http://localhost:8080".to_string()
539-
} else {
540-
row.broker_address.clone()
541-
};
542-
let reactor_address = if row.reactor_address.contains("svc.cluster.local:") {
543-
"http://localhost:9000".to_string()
544-
} else {
545-
row.reactor_address.clone()
546-
};
547-
548534
// Create the journal and shard clients that are used for interacting with the data plane
549535
let router = gazette::Router::new("local");
550536
let journal_client =
551-
gazette::journal::Client::new(broker_address, metadata.clone(), router.clone());
552-
let shard_client = gazette::shard::Client::new(reactor_address, metadata, router);
537+
gazette::journal::Client::new(row.broker_address.clone(), metadata.clone(), router.clone());
538+
let shard_client = gazette::shard::Client::new(row.reactor_address.clone(), metadata, router);
553539

554540
Ok(DataPlane {
555541
row,

0 commit comments

Comments
 (0)