chore: CI with unit tests

.github/workflows/ci.yaml

@@ -0,0 +1,51 @@
+name: Rust
+
+on:
+  push:
+    branches: [ main ]
+  pull_request:
+    branches: [ main ]
+
+jobs:
+  build:
+    name: Unit Tests
+    runs-on: ubuntu-latest
+    steps:
+      - name: Check out code
+        uses: actions/checkout@v2
+
+      - name: Set up Rust
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          override: true
+
+      - name: Cache Cargo dependencies
+        uses: actions/cache@v2
+        with:
+          path: |
+            ~/.cargo/bin/
+            ~/.cargo/registry/index/
+            ~/.cargo/registry/cache/
+            ~/.cargo/git/db/
+            target/
+          key: ${{ runner.os }}-cargo-${{ hashFiles('**/Cargo.lock') }}
+
+      - name: Install protoc (for Protocol Buffers)
+        run: |
+          set -eux -o pipefail
+          PROTOC_VERSION=3.19.4
+          PROTOC_ZIP=protoc-$PROTOC_VERSION-linux-x86_64.zip
+          curl -OL https://github.com/protocolbuffers/protobuf/releases/download/v$PROTOC_VERSION/$PROTOC_ZIP
+          sudo unzip -o $PROTOC_ZIP -d /usr/local bin/protoc
+          sudo unzip -o $PROTOC_ZIP -d /usr/local 'include/*'
+          sudo chmod +x /usr/local/bin/protoc
+          sudo find /usr/local/include -type f | xargs sudo chmod a+r
+          sudo find /usr/local/include -type d | xargs sudo chmod a+rx
+          rm -f $PROTOC_ZIP
+
+      - name: Build
+        run: cargo build --verbose
+
+      - name: Run tests
+        run: cargo test --verbose

src/map.rs

@@ -24,7 +24,7 @@ pub trait Mapper {
     ///
     /// Following is an example of a cat container that just copies the input to output.
     ///
-    /// ```rust
+    /// ```rust,ignore
     /// use numaflow::map::start_uds_server;
     ///
     /// #[tokio::main]

src/reduce.rs

@@ -36,8 +36,8 @@ pub trait Reducer {
     ///
     /// Below is a reduce code to count the number of elements for a given set of keys and window.
     ///
-    /// ```rust
-    // use numaflow::reduce::start_uds_server;
+    /// ```rust,ignore
+    /// use numaflow::reduce::start_uds_server;
     /// #[tokio::main]
     /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
     ///     let reduce_handler = counter::Counter::new();

src/sink.rs

@@ -28,7 +28,7 @@ pub trait Sinker {
     ///
     /// A simple log sink.
     ///
-    /// ```rust
+    /// ```rust,ignore
     /// use numaflow::sink;
     /// use numaflow::sink::{Datum, Response};
     /// use tonic::async_trait;

src/sourcetransform.rs

@@ -29,11 +29,10 @@ pub trait SourceTransformer {
     ///
     /// #Example
     ///
-    ///
-    /// ```rust
+    ///  ```rust,ignore
     /// use numaflow::sourcetransform::start_uds_server;
     ///
-    /// A simple source transformer which assigns event time to the current time in utc.
+    /// // A simple source transformer which assigns event time to the current time in utc.
     ///
     /// #[tokio::main]
     /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -69,7 +68,7 @@ pub trait SourceTransformer {
     ///            reponse
     ///        }
     ///    }
-    ///}
+    /// }
     /// ```
     async fn transform<T: Datum + Send + Sync + 'static>(&self, input: T) -> Vec<Message>;
 }