chore: rename fns

src/overseer/mod.rs

@@ -54,7 +54,7 @@ pub enum IngressStreamType {
 /// The control process that oversees streaming operations
 pub trait Overseer: Send + Sync {
     /// Set up a new streaming pipeline
-    async fn configure_pipeline(
+    async fn start_stream(
         &self,
         connection: &ConnectionInfo,
         stream_info: &IngressInfo,
@@ -63,7 +63,7 @@ pub trait Overseer: Send + Sync {
     /// A new segment (HLS etc.) was generated for a stream variant
     ///
     /// This handler is usually used for distribution / billing
-    async fn new_segment(
+    async fn on_segment(
         &self,
         pipeline: &Uuid,
         variant_id: &Uuid,
@@ -170,7 +170,7 @@ impl StaticOverseer {
 
 #[async_trait]
 impl Overseer for StaticOverseer {
-    async fn configure_pipeline(
+    async fn start_stream(
         &self,
         connection: &ConnectionInfo,
         stream_info: &IngressInfo,
@@ -196,7 +196,7 @@ impl Overseer for StaticOverseer {
         })
     }
 
-    async fn new_segment(
+    async fn on_segment(
         &self,
         pipeline: &Uuid,
         variant_id: &Uuid,

src/overseer/webhook.rs

@@ -21,7 +21,7 @@ impl WebhookOverseer {
 
 #[async_trait]
 impl Overseer for WebhookOverseer {
-    async fn configure_pipeline(
+    async fn start_stream(
         &self,
         connection: &ConnectionInfo,
         stream_info: &IngressInfo,
@@ -29,7 +29,7 @@ impl Overseer for WebhookOverseer {
         todo!()
     }
 
-    async fn new_segment(
+    async fn on_segment(
         &self,
         pipeline: &Uuid,
         variant_id: &Uuid,

src/overseer/zap_stream/mod.rs

@@ -143,7 +143,7 @@ impl ZapStreamOverseer {
 
 #[async_trait]
 impl Overseer for ZapStreamOverseer {
-    async fn configure_pipeline(
+    async fn start_stream(
         &self,
         connection: &ConnectionInfo,
         stream_info: &IngressInfo,
@@ -188,7 +188,7 @@ impl Overseer for ZapStreamOverseer {
         })
     }
 
-    async fn new_segment(
+    async fn on_segment(
         &self,
         pipeline: &Uuid,
         variant_id: &Uuid,

src/pipeline/runner.rs

@@ -232,7 +232,7 @@ impl PipelineRunner {
 
         let cfg = self.handle.block_on(async {
             self.overseer
-                .configure_pipeline(&self.connection, &i_info)
+                .start_stream(&self.connection, &i_info)
                 .await
         })?;
         self.config = Some(cfg);