chore: bump version to 260304.0.0

Cargo.toml

@@ -1,5 +1,5 @@
 [workspace.package]
-version = "260217.0.0"
+version = "260304.0.0"
 authors = ["Databend Authors <opensource@datafuselabs.com>"]
 license = "Apache-2.0"
 publish = false

crates/common/version/src/grpc_changelog.rs

@@ -0,0 +1,144 @@
+// Copyright 2021 Datafuse Labs
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+//! Changelog of gRPC version compatibility.
+//!
+//! Records the minimum compatible client and server versions at each package
+//! version where compatibility changed. Consumers use
+//! `.range(..=v).last()` to find the applicable entry for a given version.
+
+use std::collections::BTreeMap;
+
+use crate::version::Version;
+
+/// Min-compatible client and server versions at a given package version.
+#[derive(Debug, Clone, PartialEq, Eq)]
+pub struct GrpcVersionCompat {
+    pub min_client: Version,
+    pub min_server: Version,
+}
+
+/// Returns a changelog mapping each package version (where compatibility
+/// changed) to the min-compatible client and server versions at that point.
+///
+/// Only versions where `min_client` or `min_server` changed are included.
+pub fn grpc_changelog() -> BTreeMap<Version, GrpcVersionCompat> {
+    const fn ver(major: u64, minor: u64, patch: u64) -> Version {
+        Version::new(major, minor, patch)
+    }
+
+    let mut m = BTreeMap::new();
+
+    // 260205.0.0: client adds ExpireInMillis, PutSequential (server since 1.2.770)
+    m.insert(ver(260205, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(1, 2, 770),
+    });
+
+    // 260214.0.0: client adds KvGetMany(srv:1.2.869), TransactionPrevValue(srv:1.2.304)
+    m.insert(ver(260214, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(1, 2, 869),
+    });
+
+    // 260217.0.0: client adds KvTransactionPutMatchSeq (server since 260217.0.0)
+    #[cfg(feature = "txn-put-match-seq")]
+    m.insert(ver(260217, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(260217, 0, 0),
+    });
+
+    // 260217.0.0: without txn-put-match-seq, no new client requirement
+    #[cfg(not(feature = "txn-put-match-seq"))]
+    m.insert(ver(260217, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(1, 2, 869),
+    });
+
+    // 260304.0.0: no compatibility change
+    #[cfg(feature = "txn-put-match-seq")]
+    m.insert(ver(260304, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(260217, 0, 0),
+    });
+
+    #[cfg(not(feature = "txn-put-match-seq"))]
+    m.insert(ver(260304, 0, 0), GrpcVersionCompat {
+        min_client: ver(1, 2, 676),
+        min_server: ver(1, 2, 869),
+    });
+
+    m
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use crate::MIN_CLIENT_VERSION;
+    use crate::MIN_SERVER_VERSION;
+
+    #[test]
+    fn test_grpc_changelog_contains_current_version() {
+        let changelog = grpc_changelog();
+        let current = *crate::version();
+
+        assert!(
+            changelog.contains_key(&current),
+            "changelog must contain an entry for the current version {}",
+            current
+        );
+    }
+
+    #[test]
+    fn test_grpc_changelog_last_entry_matches_current() {
+        let changelog = grpc_changelog();
+        let (_, last) = changelog.iter().next_back().unwrap();
+
+        assert_eq!(
+            last.min_client, MIN_CLIENT_VERSION,
+            "last changelog min_client must match MIN_CLIENT_VERSION"
+        );
+
+        assert_eq!(
+            last.min_server, MIN_SERVER_VERSION,
+            "last changelog min_server must match MIN_SERVER_VERSION"
+        );
+    }
+
+    #[test]
+    fn test_grpc_changelog_monotonic() {
+        let changelog = grpc_changelog();
+        let mut prev_client = Version::min();
+        let mut prev_server = Version::min();
+
+        for (ver, compat) in &changelog {
+            assert!(
+                compat.min_client >= prev_client,
+                "min_client decreased at {}: {:?} < {:?}",
+                ver,
+                compat.min_client,
+                prev_client
+            );
+            assert!(
+                compat.min_server >= prev_server,
+                "min_server decreased at {}: {:?} < {:?}",
+                ver,
+                compat.min_server,
+                prev_server
+            );
+            prev_client = compat.min_client;
+            prev_server = compat.min_server;
+        }
+    }
+}

crates/common/version/src/lib.rs

@@ -32,6 +32,7 @@
 //! See [Compatibility Algorithm](./compatibility_algorithm.md) for details.
 
 mod feature_span;
+mod grpc_changelog;
 mod grpc_feat;
 mod grpc_spec;
 mod raft_feat;
@@ -41,6 +42,8 @@ mod version;
 pub use self::feature_span::FeatureSet;
 pub use self::feature_span::FeatureSpan;
 pub use self::feature_span::FeatureSpec;
+pub use self::grpc_changelog::GrpcVersionCompat;
+pub use self::grpc_changelog::grpc_changelog;
 pub use self::grpc_feat::GrpcFeature;
 pub use self::grpc_spec::GrpcSpec;
 pub use self::raft_feat::RaftFeature;
@@ -128,17 +131,17 @@ mod tests {
 
     #[test]
     fn test_version_string() {
-        assert_eq!(version_str(), "260217.0.0");
+        assert_eq!(version_str(), "260304.0.0");
     }
 
     #[test]
     fn test_semver_components() {
-        assert_eq!(semver_tuple(version()), (260217, 0, 0));
+        assert_eq!(semver_tuple(version()), (260304, 0, 0));
     }
 
     #[test]
     fn test_semver_display() {
-        assert_eq!(version().to_semver().to_string(), "260217.0.0");
+        assert_eq!(version().to_semver().to_string(), "260304.0.0");
     }
 
     #[test]