[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10,"_11":12},"actionData","errors","root",{"_179":-5,"_182":183,"_184":185},"routes/shell",{"_41":42,"_178":-5,"_179":-5,"_180":181},"routes/repo",{"_34":-7,"_35":36,"_37":38,"_39":40,"_41":42,"_43":32,"_44":32,"_45":32,"_46":32,"_47":32,"_48":32,"_49":50,"_51":50,"_52":32,"_53":-7,"_54":-7,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69},"routes/repo.blob",{"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5,"_26":27,"_28":29,"_29":30,"_31":32,"_33":14},"ref","main","path","crates/ltx/src/client/mod.rs","oid","1001849a5e059a7b8b20cea65b0e8bcd433ab25b","size",4401,"commit","90b43017241f81189453d326d05948f388b34652","mounts",[],"source","plain",{"_13":14,"_15":16},"kind","text","//! client — the `ReplicaClient` trait.\n//!\n//! Ported from litestream@v0.5.11 `replica_client.go`. The trait is the storage\n//! abstraction that every backend implements.\n//!\n//! # I/O\n//! Go's `ReplicaClient` uses `io.Reader`/`io.ReadCloser`. We take/return owned\n//! byte buffers (`&[u8]` / `Vec`) for ordinary replication. Oversized\n//! compaction uses ranged reads and uploads a scratch file in bounded chunks.\n\nuse crate::error::Result;\nuse crate::ltx::FileInfo;\nuse crate::TXID;\nuse async_trait::async_trait;\n\npub mod bundle;\npub mod epochs;\npub mod file;\npub mod object_store;\n\n/// One bounded read from a scratch file, dispatched through its host.\npub(crate) async fn read_upload_chunk(\n mut file: crate::host::HostFile,\n host: &crate::LtxHost,\n offset: u64,\n limit: usize,\n) -> Result<(crate::host::HostFile, Vec, u64)> {\n host.run_blocking(move || {\n let size = file.file_len()?;\n let len = size.saturating_sub(offset).min(limit as u64) as usize;\n let bytes = file.read_exact_at(offset, len)?;\n Ok((file, bytes, size))\n })\n .await\n .map_err(|error| crate::error::Error::Other(error.to_string().into()))?\n}\n\n/// Client for reading and writing LTX files on a replica backend.\n///\n/// Ported from the `ReplicaClient` interface (replica_client.go:19-51). Methods\n/// take a compaction `level` (0 = L0, the only level in the one-shot scope).\n#[async_trait]\npub trait ReplicaClient: Send + Sync {\n /// Returns all LTX files for `level`, sorted ascending by `min_txid`, that\n /// start at or after `seek`.\n async fn ltx_files(&self, level: i32, seek: TXID) -> Result>;\n\n /// Returns at most `limit` LTX files at or after `seek`.\n ///\n /// Remote clients can stop their object listing after they collect the\n /// requested prefix. The default keeps compatibility with local and custom\n /// clients.\n async fn ltx_files_bounded(\n &self,\n level: i32,\n seek: TXID,\n limit: usize,\n ) -> Result> {\n let mut files = self.ltx_files(level, seek).await?;\n files.truncate(limit);\n Ok(files)\n }\n\n /// Reads an LTX file. Returns an `io::ErrorKind::NotFound` error (wrapped)\n /// if the file does not exist.\n async fn open_ltx_file(&self, level: i32, min_txid: TXID, max_txid: TXID) -> Result>;\n\n /// Reads bytes `[offset, offset+len)` of an LTX file. Paged restore fetches\n /// an object's trailing page index and then single page frames this way,\n /// without downloading the whole object. `offset` and `len` must lie within\n /// the object (the caller knows its size from the [`FileInfo`] listing); a\n /// short object yields the available bytes.\n ///\n /// The default reads the whole object and slices it, so a backend without a\n /// native ranged read still works; a remote backend overrides this with a\n /// ranged GET so the read cost is proportional to the range, not the object.\n async fn read_range(\n &self,\n level: i32,\n min_txid: TXID,\n max_txid: TXID,\n offset: u64,\n len: u64,\n ) -> Result> {\n let bytes = self.open_ltx_file(level, min_txid, max_txid).await?;\n let start = (offset as usize).min(bytes.len());\n let end = start.saturating_add(len as usize).min(bytes.len());\n Ok(bytes[start..end].to_vec())\n }\n\n /// Writes an LTX file to the replica and returns its metadata.\n async fn write_ltx_file(\n &self,\n level: i32,\n min_txid: TXID,\n max_txid: TXID,\n data: &[u8],\n ) -> Result;\n\n /// Uploads a validated scratch file without buffering its complete body.\n /// Backends that support oversized compaction must implement this method.\n async fn write_ltx_file_from_file(\n &self,\n _level: i32,\n _min_txid: TXID,\n _max_txid: TXID,\n _file: crate::host::HostFile,\n _host: crate::LtxHost,\n ) -> Result {\n Err(crate::error::Error::Io(std::io::Error::new(\n std::io::ErrorKind::Unsupported,\n \"the replica does not support file uploads\",\n )))\n }\n\n /// Deletes the given LTX files.\n async fn delete_ltx_files(&self, files: &[FileInfo]) -> Result<()>;\n\n /// Deletes all files on the replica.\n async fn delete_all(&self) -> Result<()>;\n}\n","editable",false,"branch","documentNavigation","repo","denoland/celld","repoId","a23b8a10-92cf-4dc4-a7ab-a04e58298dde","ownerId","org:42048915","site","nexthub","private","admin","settings","maintainer","triage","starred","stars",1,"watchers","watching","pinned","notify","views",[134,135,136,137,138,139,140,141,142,143,144,145,146],"navigation",{"_55":56,"_91":92,"_93":94,"_95":96,"_97":98,"_99":100,"_101":102},"sources",[],"viewer","meta",{"_83":84,"_85":86,"_87":88,"_43":32,"_89":14,"_90":32,"_49":50,"_51":50},"branches",[14],"tags",[70,71,72,73,74,75,76,77,78,79,80,81,82],"cloneUrl","https://git.nexthub.sh/denoland/celld.git","v0.0.1","v0.0.2","v0.1.0","v0.2.0","v0.2.1","v0.3.0","v0.4.0","v0.4.1","v0.5.0","v0.5.1","v0.6.0","v0.6.1","v0.6.2","description","self-hosted, distributed Durable Objects","owner","denoland","section","","head","empty","pins",[116,117,118],"documents",{"_111":112,"_113":114},"code",{"_108":109,"_110":104},"automations",{"_106":50,"_107":-5},"delivery",{"_103":104,"_105":-5},"tag","7gTA52Z9a1vO6FP6eCQPix9zO4O","releases",0,"applications","workflows","deployments","commits",13,"changes","counts",{"_115":114},"total",38,"issue",{"_119":110,"_121":132,"_15":110,"_123":133,"_53":125,"_126":32,"_127":125,"_128":104},{"_119":129,"_121":130,"_15":129,"_123":131,"_53":125,"_126":32,"_127":125,"_128":104},{"_119":120,"_121":122,"_15":120,"_123":124,"_53":125,"_126":32,"_127":125,"_128":114},"id","issues","name","Issues","filters",{},true,"saved","pinnable","count","tasks","Tasks",{},"Changes",{},{"_119":110,"_121":132,"_15":110,"_123":177,"_53":125,"_126":32,"_127":125},{"_119":129,"_121":130,"_15":129,"_123":176,"_53":125,"_126":32,"_127":125},{"_119":120,"_121":122,"_15":120,"_123":175,"_53":125,"_126":32,"_127":125},{"_119":172,"_121":173,"_15":172,"_123":174,"_53":32,"_126":32,"_127":125},{"_119":169,"_121":170,"_15":169,"_123":171,"_53":32,"_126":32,"_127":125},{"_119":106,"_121":167,"_15":97,"_123":168,"_53":32,"_126":32,"_127":125},{"_119":107,"_121":164,"_15":165,"_123":166,"_53":32,"_126":32,"_127":125},{"_119":103,"_121":162,"_15":103,"_123":163,"_53":32,"_126":32,"_127":125},{"_119":158,"_121":159,"_15":160,"_123":161,"_53":32,"_126":32,"_127":125},{"_119":93,"_121":156,"_15":93,"_123":157,"_53":32,"_126":32,"_127":32},{"_119":153,"_121":154,"_15":153,"_123":155,"_53":32,"_126":32,"_127":32},{"_119":150,"_121":151,"_15":150,"_123":152,"_53":32,"_126":32,"_127":32},{"_119":147,"_121":148,"_15":147,"_123":149,"_53":32,"_126":32,"_127":32},"decisions","Decisions",{},"changelog","Changelog",{},"roadmap","Roadmap",{},"Documents",{},"activity","Activity","insights",{},"Releases",{},"Deployments","automations/deployments",{},"Workflows",{},"discussions","Discussions",{},"goals","Goals",{},{},{},{},"groups","user","agents",[],"now",1794451784237,"sidebar","expanded"]