chore: expose and export side-input path (#156)

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

Author: vigith

examples/sideinput/udf/src/main.rs

@@ -5,8 +5,6 @@ use numaflow::map::{MapRequest, Mapper, Message, Server};
 use tokio::spawn;
 use tonic::async_trait;
 
-const DIR_PATH: &str = "/var/numaflow/sideinputs";
-
 struct UdfMapper;
 
 #[async_trait]
@@ -39,6 +37,9 @@ async fn file_watcher() -> Result<()> {
         Ok(event) => println!("event: {:?}", event),
         Err(e) => println!("watch error: {:?}", e),
     })?;
-    watcher.watch(Path::new(DIR_PATH), RecursiveMode::Recursive)?;
+    watcher.watch(
+        Path::new(numaflow::sideinput::DIR_PATH),
+        RecursiveMode::Recursive,
+    )?;
     Ok(())
 }

numaflow/src/sideinput.rs

@@ -17,6 +17,9 @@ pub const SOCK_ADDR: &str = "/var/run/numaflow/sideinput.sock";
 /// Default server info file for sideinput service
 pub const SERVER_INFO_FILE: &str = "/var/run/numaflow/sideinput-server-info";
 
+/// Default directory path for storing side-input files
+pub const DIR_PATH: &str = "/var/numaflow/side-inputs";
+
 struct SideInputService<T> {
     handler: Arc<T>,
     shutdown_tx: mpsc::Sender<()>,