wip(failover): Started implementation of the FailoverTopology with PostgreSQL capability

This is our first Higher Order Topology (see ADR-015)

Cargo.lock

@@ -1835,6 +1835,21 @@ dependencies = [
  "url",
 ]
 
+[[package]]
+name = "example-operatorhub-catalogsource"
+version = "0.1.0"
+dependencies = [
+ "cidr",
+ "env_logger",
+ "harmony",
+ "harmony_cli",
+ "harmony_macros",
+ "harmony_types",
+ "log",
+ "tokio",
+ "url",
+]
+
 [[package]]
 name = "example-opnsense"
 version = "0.1.0"

examples/operatorhub_catalog/src/main.rs

@@ -3,13 +3,12 @@ use std::str::FromStr;
 use harmony::{
     inventory::Inventory,
     modules::{k8s::apps::OperatorHubCatalogSourceScore, tenant::TenantScore},
-    topology::{tenant::TenantConfig, K8sAnywhereTopology},
+    topology::{K8sAnywhereTopology, tenant::TenantConfig},
 };
 use harmony_types::id::Id;
 
 #[tokio::main]
 async fn main() {
-
     let operatorhub_catalog = OperatorHubCatalogSourceScore::default();
 
     harmony_cli::run(

harmony/src/domain/topology/mod.rs

@@ -1,6 +1,6 @@
+mod failover;
 mod ha_cluster;
 pub mod ingress;
-mod failover;
 pub use failover::*;
 use harmony_types::net::IpAddress;
 mod host_binding;

harmony/src/modules/k8s/apps/crd/mod.rs

@@ -1,4 +1,2 @@
-
 mod catalogsources_operators_coreos_com;
 pub use catalogsources_operators_coreos_com::*;
-

harmony/src/modules/k8s/apps/mod.rs

@@ -1,4 +1,3 @@
 mod operatorhub;
 pub use operatorhub::*;
 pub mod crd;
-

harmony/src/modules/k8s/mod.rs

@@ -1,5 +1,5 @@
+pub mod apps;
 pub mod deployment;
 pub mod ingress;
 pub mod namespace;
 pub mod resource;
-pub mod apps;

harmony/src/modules/mod.rs

@@ -13,8 +13,8 @@ pub mod load_balancer;
 pub mod monitoring;
 pub mod okd;
 pub mod opnsense;
+pub mod postgresql;
 pub mod prometheus;
 pub mod storage;
 pub mod tenant;
 pub mod tftp;
-pub mod postgresql;

harmony/src/modules/postgresql/capability.rs

@@ -18,7 +18,10 @@ pub trait PostgreSQL: Send + Sync {
     /// Returns None if no public endpoint (internal-only cluster).
     /// UNSTABLE: This is opinionated for initial multisite use cases. Networking abstraction is complex
     /// (cf. k8s Ingress -> Gateway API evolution); may move to higher-order Networking/PostgreSQLNetworking trait.
-    async fn get_public_endpoint(&self, cluster_name: &str) -> Result<Option<PostgreSQLEndpoint>, String>;
+    async fn get_public_endpoint(
+        &self,
+        cluster_name: &str,
+    ) -> Result<Option<PostgreSQLEndpoint>, String>;
 }
 
 #[derive(Clone, Debug, Serialize)]

harmony/src/modules/postgresql/mod.rs

@@ -1,7 +1,4 @@
-
 pub mod capability;
 mod score;
 
-
 pub mod failover;
-

harmony_types/src/lib.rs

@@ -1,4 +1,4 @@
 pub mod id;
 pub mod net;
-pub mod switch;
 pub mod storage;
+pub mod switch;