diff options
author | Alex Auvolat <alex@adnab.me> | 2022-03-16 12:09:50 +0100 |
---|---|---|
committer | Gitea <gitea@fake.local> | 2022-03-24 16:57:43 +0100 |
commit | 9d0ed788879ad50450ebd44cd2a0b4fc942d45b6 (patch) | |
tree | 34225ffffac6b0bd3d2788d9827c08e4ae5e1afd /src/rpc/kubernetes.rs | |
parent | 509d256c58ccb1aa0041569556465908453976b3 (diff) | |
download | garage-9d0ed788879ad50450ebd44cd2a0b4fc942d45b6.tar.gz garage-9d0ed788879ad50450ebd44cd2a0b4fc942d45b6.zip |
Add feature flag for Kubernetes discovery
Diffstat (limited to 'src/rpc/kubernetes.rs')
-rw-r--r-- | src/rpc/kubernetes.rs | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/rpc/kubernetes.rs b/src/rpc/kubernetes.rs index 272d9162..939a0eed 100644 --- a/src/rpc/kubernetes.rs +++ b/src/rpc/kubernetes.rs @@ -12,8 +12,6 @@ use serde::{Deserialize, Serialize}; use netapp::NodeID; -use garage_util::error::Error; - static K8S_GROUP: &str = "deuxfleurs.fr"; #[derive(CustomResource, Debug, Serialize, Deserialize, Clone, JsonSchema)] @@ -29,7 +27,7 @@ pub struct Node { port: u16, } -pub async fn create_kubernetes_crd() -> Result<(), Error> { +pub async fn create_kubernetes_crd() -> Result<(), kube::Error> { let client = Client::try_default().await?; let crds: Api<CustomResourceDefinition> = Api::all(client.clone()); @@ -45,7 +43,7 @@ pub async fn create_kubernetes_crd() -> Result<(), Error> { pub async fn get_kubernetes_nodes( kubernetes_service_name: &str, kubernetes_namespace: &str, -) -> Result<Vec<(NodeID, SocketAddr)>, Error> { +) -> Result<Vec<(NodeID, SocketAddr)>, kube::Error> { let client = Client::try_default().await?; let nodes: Api<GarageNode> = Api::namespaced(client.clone(), kubernetes_namespace); @@ -80,7 +78,7 @@ pub async fn publish_kubernetes_node( node_id: NodeID, hostname: &str, rpc_public_addr: SocketAddr, -) -> Result<(), Error> { +) -> Result<(), kube::Error> { let node_pubkey = hex::encode(node_id); let mut node = GarageNode::new( |