chore: export proto definitions

Signed-off-by: Vigith Maurice <vigith@gmail.com>

.rustfmt.toml

@@ -0,0 +1,2 @@
+edition = "2021"
+indent_style = "Block"

src/map.rs

@@ -6,7 +6,8 @@ use tonic::{async_trait, Request, Response, Status};
 
 use crate::shared;
 
-mod proto {
+/// Numaflow Map Proto definitions.
+pub mod proto {
     tonic::include_proto!("map.v1");
 }
 

src/reduce.rs

@@ -16,7 +16,8 @@ use crate::shared;
 
 use self::reducer::reduce_server::Reduce;
 
-mod reducer {
+/// Numaflow Reduce Proto definitions.
+pub mod reducer {
     tonic::include_proto!("reduce.v1");
 }
 

src/sink.rs

@@ -7,7 +7,7 @@ use tonic::{Request, Status, Streaming};
 
 use crate::shared;
 
-mod proto {
+pub mod proto {
     tonic::include_proto!("sink.v1");
 }
 

src/source.rs

@@ -11,7 +11,8 @@ use tokio::sync::mpsc::{self, Sender};
 use tokio_stream::wrappers::ReceiverStream;
 use tonic::{async_trait, Request, Response, Status};
 
-mod proto {
+/// Source Proto definitions.
+pub mod proto {
     tonic::include_proto!("source.v1");
 }
 

src/sourcetransform.rs

@@ -6,7 +6,8 @@ use tonic::{async_trait, Request, Response, Status};
 
 use crate::shared::{self, prost_timestamp_from_utc};
 
-mod proto {
+/// Numaflow SourceTransformer Proto definitions.
+pub mod proto {
     tonic::include_proto!("sourcetransformer.v1");
 }