Removing lifetime to the Metadata struct

apis/rust/node/src/event_stream/event.rs

@@ -16,7 +16,7 @@ pub enum Event {
     },
     Input {
         id: DataId,
-        metadata: Metadata<'static>,
+        metadata: Metadata,
         data: Option<Data>,
     },
     InputClosed {

apis/rust/node/src/node/control_channel.rs

@@ -83,7 +83,7 @@ impl ControlChannel {
     pub fn send_message(
         &mut self,
         output_id: DataId,
-        metadata: Metadata<'static>,
+        metadata: Metadata,
         data: Option<Data>,
     ) -> eyre::Result<()> {
         let request = DaemonRequest::SendMessage {

binaries/daemon/src/lib.rs

@@ -758,7 +758,7 @@ impl Daemon {
         dataflow_id: Uuid,
         node_id: NodeId,
         output_id: DataId,
-        metadata: dora_core::message::Metadata<'static>,
+        metadata: dora_core::message::Metadata,
         data: Option<Data>,
     ) -> Result<(), eyre::ErrReport> {
         let dataflow = self.running.get_mut(&dataflow_id).wrap_err_with(|| {
@@ -1069,7 +1069,7 @@ async fn send_output_to_local_receivers(
     node_id: NodeId,
     output_id: DataId,
     dataflow: &mut RunningDataflow,
-    metadata: &dora_core::message::Metadata<'static>,
+    metadata: &dora_core::message::Metadata,
     data: Option<Data>,
     clock: &HLC,
 ) -> Result<Option<Vec<u8>>, eyre::ErrReport> {
@@ -1443,7 +1443,7 @@ pub enum DaemonNodeEvent {
     },
     SendOut {
         output_id: DataId,
-        metadata: dora_core::message::Metadata<'static>,
+        metadata: dora_core::message::Metadata,
         data: Option<Data>,
     },
     ReportDrop {
@@ -1459,7 +1459,7 @@ pub enum DoraEvent {
     Timer {
         dataflow_id: DataflowId,
         interval: Duration,
-        metadata: dora_core::message::Metadata<'static>,
+        metadata: dora_core::message::Metadata,
     },
     SpawnedNodeResult {
         dataflow_id: DataflowId,

libraries/core/src/daemon_messages.rs

@@ -50,7 +50,7 @@ pub enum DaemonRequest {
     Subscribe,
     SendMessage {
         output_id: DataId,
-        metadata: Metadata<'static>,
+        metadata: Metadata,
         data: Option<Data>,
     },
     CloseOutputs(Vec<DataId>),
@@ -152,7 +152,7 @@ pub enum NodeEvent {
     },
     Input {
         id: DataId,
-        metadata: Metadata<'static>,
+        metadata: Metadata,
         data: Option<Data>,
     },
     InputClosed {
@@ -233,7 +233,7 @@ pub enum InterDaemonEvent {
         dataflow_id: DataflowId,
         node_id: NodeId,
         output_id: DataId,
-        metadata: Metadata<'static>,
+        metadata: Metadata,
         data: Option<Vec<u8>>,
     },
     InputsClosed {