Integrate mysql into trigger2

Signed-off-by: Ryan Levick <[email protected]>
fermyon · Aug 22, 2024 · 337fdeb · 337fdeb
1 parent bbf0a36
commit 337fdeb
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 0 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/runtime-config/Cargo.toml b/crates/runtime-config/Cargo.toml
@@ -19,6 +19,7 @@ spin-factor-outbound-http = { path = "../factor-outbound-http" }
 spin-factor-outbound-mqtt = { path = "../factor-outbound-mqtt" }
 spin-factor-outbound-networking = { path = "../factor-outbound-networking" }
 spin-factor-outbound-pg = { path = "../factor-outbound-pg" }
+spin-factor-outbound-mysql = { path = "../factor-outbound-mysql" }
 spin-factor-outbound-redis = { path = "../factor-outbound-redis" }
 spin-factor-sqlite = { path = "../factor-sqlite" }
 spin-factor-variables = { path = "../factor-variables" }

diff --git a/crates/runtime-config/src/lib.rs b/crates/runtime-config/src/lib.rs
@@ -5,6 +5,7 @@ use spin_factor_key_value::runtime_config::spin::{self as key_value, MakeKeyValu
 use spin_factor_key_value::{DefaultLabelResolver as _, KeyValueFactor};
 use spin_factor_outbound_http::OutboundHttpFactor;
 use spin_factor_outbound_mqtt::OutboundMqttFactor;
+use spin_factor_outbound_mysql::OutboundMysqlFactor;
 use spin_factor_outbound_networking::runtime_config::spin::SpinTlsRuntimeConfig;
 use spin_factor_outbound_networking::OutboundNetworkingFactor;
 use spin_factor_outbound_pg::OutboundPgFactor;
@@ -166,6 +167,12 @@ impl FactorRuntimeConfigSource<OutboundPgFactor> for TomlRuntimeConfigSource<'_>
     }
 }
 
+impl FactorRuntimeConfigSource<OutboundMysqlFactor> for TomlRuntimeConfigSource<'_> {
+    fn get_runtime_config(&mut self) -> anyhow::Result<Option<()>> {
+        Ok(None)
+    }
+}
+
 impl FactorRuntimeConfigSource<OutboundRedisFactor> for TomlRuntimeConfigSource<'_> {
     fn get_runtime_config(&mut self) -> anyhow::Result<Option<()>> {
         Ok(None)

diff --git a/crates/trigger2/Cargo.toml b/crates/trigger2/Cargo.toml
@@ -26,6 +26,7 @@ spin-factor-outbound-http = { path = "../factor-outbound-http" }
 spin-factor-outbound-mqtt = { path = "../factor-outbound-mqtt" }
 spin-factor-outbound-networking = { path = "../factor-outbound-networking" }
 spin-factor-outbound-pg = { path = "../factor-outbound-pg" }
+spin-factor-outbound-mysql = { path = "../factor-outbound-mysql" }
 spin-factor-outbound-redis = { path = "../factor-outbound-redis" }
 spin-factor-sqlite = { path = "../factor-sqlite" }
 spin-factor-variables = { path = "../factor-variables" }

diff --git a/crates/trigger2/src/factors.rs b/crates/trigger2/src/factors.rs
@@ -3,6 +3,7 @@ use std::path::PathBuf;
 use spin_factor_key_value::KeyValueFactor;
 use spin_factor_outbound_http::OutboundHttpFactor;
 use spin_factor_outbound_mqtt::{NetworkedMqttClient, OutboundMqttFactor};
+use spin_factor_outbound_mysql::OutboundMysqlFactor;
 use spin_factor_outbound_networking::OutboundNetworkingFactor;
 use spin_factor_outbound_pg::OutboundPgFactor;
 use spin_factor_outbound_redis::OutboundRedisFactor;
@@ -23,6 +24,7 @@ pub struct TriggerFactors {
     pub redis: OutboundRedisFactor,
     pub mqtt: OutboundMqttFactor,
     pub pg: OutboundPgFactor,
+    pub mysql: OutboundMysqlFactor,
 }
 
 impl TriggerFactors {
@@ -42,6 +44,7 @@ impl TriggerFactors {
             redis: OutboundRedisFactor::new(),
             mqtt: OutboundMqttFactor::new(NetworkedMqttClient::creator()),
             pg: OutboundPgFactor::new(),
+            mysql: OutboundMysqlFactor::new(),
         }
     }
 }