Skip to content

Commit 3405d37

Browse files
committed
Remove ReconfAsync runtime because it blocks for other changes
1 parent c3a8357 commit 3405d37

File tree

10 files changed

+6
-1599
lines changed

10 files changed

+6
-1599
lines changed

src/cli/adapters.rs

Lines changed: 0 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -115,28 +115,6 @@ impl DistributionModeBuilder {
115115

116116
pub async fn build(self) -> anyhow::Result<BuilderDistributionMode> {
117117
Ok(match (self.distribution_mode, self.runtime) {
118-
(_, Some(Runtime::ReconfigurableAsync)) => {
119-
debug!("setting up reconfigurable distribution mode");
120-
let local_node = self.local_node.context("Local node not specified")?;
121-
let receiver = match self.mqtt_port {
122-
Some(port) => crate::io::mqtt::MQTTLocalityReceiver::new_with_port(
123-
MQTT_HOSTNAME.to_string(),
124-
local_node.into(),
125-
port,
126-
),
127-
None => crate::io::mqtt::MQTTLocalityReceiver::new(
128-
MQTT_HOSTNAME.to_string(),
129-
local_node.into(),
130-
),
131-
};
132-
debug!("Initiating MQTT locality receiver");
133-
receiver
134-
.ready()
135-
.await
136-
.context("Failed to initialize MQTT locality receiver")?;
137-
debug!("Initialized MQTT locality receiver");
138-
BuilderDistributionMode::ReconfigurableLocalMonitor(receiver)
139-
}
140118
(
141119
DistributionMode {
142120
distribution_graph: Some(file_path),

src/core/interfaces.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@ pub enum Semantics {
1919
pub enum Runtime {
2020
Async,
2121
Distributed,
22-
ReconfigurableAsync,
2322
SemiSync,
2423
ReconfigurableSemiSync,
2524
}

0 commit comments

Comments
 (0)