Merge pull request #405 from tansu-io/400-storage-service-doc-tests

v0.5.0

Author: shortishly

Cargo.lock

@@ -19,7 +19,7 @@ members = [
 
 [workspace.package]
 edition = "2024"
-version = "0.4.10"
+version = "0.5.0"
 license = "Apache-2.0"
 homepage = "https://tansu.io"
 repository = "https://github.com/tansu-io/tansu"
@@ -121,20 +121,20 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1"
 snap = "1.1.1"
 syn = { version = "2.0", features = ["full"] }
-tansu = { version = "0.4.10", path = "tansu" }
-tansu-broker = { version = "0.4.10", path = "tansu-broker" }
-tansu-cat = { version = "0.4.10", path = "tansu-cat" }
-tansu-cli = { version = "0.4.10", path = "tansu-cli" }
-tansu-client = { version = "0.4.10", path = "tansu-client" }
-tansu-generator = { version = "0.4.10", path = "tansu-generator" }
-tansu-model = { version = "0.4.10", path = "tansu-model" }
-tansu-otel = { version = "0.4.10", path = "tansu-otel" }
-tansu-proxy = { version = "0.4.10", path = "tansu-proxy" }
-tansu-sans-io = { version = "0.4.10", path = "tansu-sans-io" }
-tansu-schema = { version = "0.4.10", path = "tansu-schema" }
-tansu-service = { version = "0.4.10", path = "tansu-service" }
-tansu-storage = { version = "0.4.10", path = "tansu-storage" }
-tansu-topic = { version = "0.4.10", path = "tansu-topic" }
+tansu = { version = "0.5.0", path = "tansu" }
+tansu-broker = { version = "0.5.0", path = "tansu-broker" }
+tansu-cat = { version = "0.5.0", path = "tansu-cat" }
+tansu-cli = { version = "0.5.0", path = "tansu-cli" }
+tansu-client = { version = "0.5.0", path = "tansu-client" }
+tansu-generator = { version = "0.5.0", path = "tansu-generator" }
+tansu-model = { version = "0.5.0", path = "tansu-model" }
+tansu-otel = { version = "0.5.0", path = "tansu-otel" }
+tansu-proxy = { version = "0.5.0", path = "tansu-proxy" }
+tansu-sans-io = { version = "0.5.0", path = "tansu-sans-io" }
+tansu-schema = { version = "0.5.0", path = "tansu-schema" }
+tansu-service = { version = "0.5.0", path = "tansu-service" }
+tansu-storage = { version = "0.5.0", path = "tansu-storage" }
+tansu-topic = { version = "0.5.0", path = "tansu-topic" }
 tempfile = "3"
 thiserror = "2.0"
 time = { version = "0.3.37", features = ["formatting", "macros"] }
@@ -144,12 +144,11 @@ tokio-postgres = { version = "0.7.13", features = [
     "with-serde_json-1",
     "with-uuid-1",
 ] }
-tower = "0.5.2"
 tracing = "0.1"
 tracing-core = { version = "0.1" }
 tracing-opentelemetry = "0.29.0"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
-turso = { git = "https://github.com/tursodatabase/turso.git", tag = "v0.1.4-pre.8" }
+turso = "0.1.4"
 url = { version = "2.5.4", features = ["serde"] }
 uuid = { version = "1.13.2", features = ["serde", "v4", "v7"] }
 zstd = "0.13.2"

Cargo.toml

@@ -187,7 +187,7 @@ impl<'de> Decoder<'de> {
     }
 
     #[must_use]
-    pub fn field_name(&self) -> String {
+    fn field_name(&self) -> String {
         self.path.iter().fold(String::new(), |acc, step| {
             if acc.is_empty() {
                 (*step).to_string()
@@ -337,10 +337,6 @@ impl<'de> Decoder<'de> {
 
         Ok(accumulator)
     }
-
-    pub fn position(&self) -> u64 {
-        self.reader.position
-    }
 }
 
 impl fmt::Debug for Decoder<'_> {

tansu-sans-io/src/de.rs

@@ -1054,9 +1054,7 @@ pub struct PartitionDetail {
     partition_index: i32,
 }
 
-/// Version
-///
-/// Representing an `e_tag` and `version` used in conditional writes to an object store.
+/// Version representing an `e_tag` and `version` used in conditional writes to an object store.
 #[derive(Clone, Debug, Default, Deserialize, Eq, Hash, Ord, PartialEq, PartialOrd, Serialize)]
 pub struct Version {
     e_tag: Option<String>,
@@ -1081,9 +1079,8 @@ impl Default for ProducerIdResponse {
     }
 }
 
-/// Transaction Add Partitions Request
-///
-/// For protocol versions 0..=3 using `AddPartitionsToTxnTopic`, thereafter using `AddPartitionsToTxnTransaction`.
+/// For protocol versions 0..=3 using [`AddPartitionsToTxnTopic`],
+/// thereafter using [`AddPartitionsToTxnTransaction`].
 #[derive(Clone, Debug, Deserialize, Eq, Hash, Ord, PartialEq, PartialOrd, Serialize)]
 pub enum TxnAddPartitionsRequest {
     VersionZeroToThree {

tansu-storage/src/lib.rs

@@ -18,6 +18,7 @@ use tracing::instrument;
 
 use crate::{Error, Result, Storage};
 
+/// A [`Service`] using [`Storage`] as [`Context`] taking [`DeleteRecordsRequest`] returning [`DeleteRecordsResponse`].
 #[derive(Clone, Copy, Debug, Default, Eq, Hash, Ord, PartialEq, PartialOrd)]
 pub struct DeleteRecordsService;