Add todos

Cargo.lock

@@ -59,6 +59,7 @@ dependencies = [
 name = "apis"
 version = "0.1.0"
 dependencies = [
+ "anyhow",
  "bytes",
  "serde",
 ]

control_plane/src/storage.rs

@@ -533,7 +533,7 @@ impl PageServerNode {
         tenant_id: ZTenantId,
         timeline_id: ZTimelineId,
     ) -> anyhow::Result<()> {
-        // TODO send the timeline via the "import {tenant} {timeline}" copy both API
+        // TODO send using apis::upload::send_basebackup
         Ok(())
     }
 }

libs/apis/Cargo.toml

@@ -8,3 +8,4 @@ edition = "2021"
 [dependencies]
 bytes = { version = "1.0.1", features = ['serde'] }
 serde = { version = "1.0", features = ["derive"] }
+anyhow = "1.0"

libs/apis/src/import.rs

@@ -1,3 +1,5 @@
+use std::path::PathBuf;
+
 use bytes::Bytes;
 use serde::{Serialize, Deserialize};
 
@@ -13,3 +15,11 @@ pub enum ImportBeMessage {
     Done,
     Error(String),
 }
+
+// TODO add a thin binary wrapper for this function, aside from neon_local
+pub fn send_basebackup(basebackup_dir: PathBuf) -> anyhow::Result<()> {
+    // TODO change return type
+    // TODO implement as sender of ImportFeMessage and receiver of ImportBeMessage
+    //      on generic channel.
+    Ok(())
+}