From 15d99fbacfaf270d72acf1b25b1d186beb82d2ae Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Fri, 6 Sep 2024 16:36:58 -0700 Subject: [PATCH 1/4] chore: publish to crates.io Signed-off-by: Vigith Maurice --- Cargo.toml | 10 ++++++++++ README.md | 17 ----------------- 2 files changed, 10 insertions(+), 17 deletions(-) diff --git a/Cargo.toml b/Cargo.toml index c949f27..1834079 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -2,6 +2,16 @@ name = "numaflow" version = "0.1.0" edition = "2021" +rust-version = "1.80" +description = "Rust SDK for Numaflow" +authors = ["Numaflow Developers"] +license = "Apache-2.0" +readme = "README.md" +homepage = "https://numaproj.github.io/numaflow/" +repository = "https://github.com/numaproj/numaflow-rs" +keywords = ["numaflow", "streaming", "messaging", "event-driven"] +categories = ["network-programming", "api-bindings"] + [lib] name = "numaflow" diff --git a/README.md b/README.md index 47aeba8..ef848bf 100644 --- a/README.md +++ b/README.md @@ -7,25 +7,8 @@ and [User Defined Sinks](https://numaflow.numaproj.io/user-guide/sinks/user-defi > most of the features. You may use this crate but there might be > few minor changes in the upcoming releases. - -## Cargo Dependency -Until we publish the crate, you will have to provide the -git location. - -```toml -numaflow = { git = "https://github.com/numaproj/numaflow-rs.git", branch="main" } -``` - ## Examples You may find examples in the [examples folder](./examples). -## Documentation - -Please run the following to get the `numaflow` crate documentation. -This work around will be in effect until we finalize the SDK contract -and officially publish the crate. -```bash -$ cargo doc -p numaflow --open -``` From f8da1cea61c0d3d000ef2653020046d16fb909b8 Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Fri, 6 Sep 2024 16:39:18 -0700 Subject: [PATCH 2/4] fix: map-streaming is not yet supported Signed-off-by: Vigith Maurice --- src/shared.rs | 1 - 1 file changed, 1 deletion(-) diff --git a/src/shared.rs b/src/shared.rs index 8fab51c..4e6a033 100644 --- a/src/shared.rs +++ b/src/shared.rs @@ -13,7 +13,6 @@ use tracing::info; pub(crate) const MAP_MODE_KEY: &str = "MAP_MODE"; pub(crate) const UNARY_MAP: &str = "unary-map"; -pub(crate) const STREAM_MAP: &str = "stream-map"; pub(crate) const BATCH_MAP: &str = "batch-map"; const MINIMUM_NUMAFLOW_VERSION: &str = "1.2.0-rc4"; From a8042d29b45ba15d5ee79743349a851572b1cdfb Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Fri, 6 Sep 2024 18:17:41 -0700 Subject: [PATCH 3/4] chore: update min NF ver --- src/shared.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/shared.rs b/src/shared.rs index 4e6a033..70b2e32 100644 --- a/src/shared.rs +++ b/src/shared.rs @@ -14,7 +14,7 @@ use tracing::info; pub(crate) const MAP_MODE_KEY: &str = "MAP_MODE"; pub(crate) const UNARY_MAP: &str = "unary-map"; pub(crate) const BATCH_MAP: &str = "batch-map"; -const MINIMUM_NUMAFLOW_VERSION: &str = "1.2.0-rc4"; +const MINIMUM_NUMAFLOW_VERSION: &str = "1.3.1"; // ServerInfo structure to store server-related information #[derive(Serialize, Deserialize, Debug)] From 8dcd261c6f82c3fb5081bf30d2071c1d77ce95fa Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Fri, 6 Sep 2024 18:45:05 -0700 Subject: [PATCH 4/4] fix: test Signed-off-by: Vigith Maurice --- src/shared.rs | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/shared.rs b/src/shared.rs index 70b2e32..3261870 100644 --- a/src/shared.rs +++ b/src/shared.rs @@ -223,9 +223,7 @@ mod tests { // Check if the contents of the file are as expected assert!(contents.contains(r#""protocol":"uds""#)); assert!(contents.contains(r#""language":"rust""#)); - assert!(contents.contains(r#""version":"0.0.1""#)); assert!(contents.contains(r#""metadata":{"MAP_MODE":"batch-map"}"#)); - assert!(contents.contains(r#""minimum_numaflow_version":"1.2.0-rc4""#)); Ok(()) }