From 0539468a5c9be3f28fe2789e86e47e65cc45cf1e Mon Sep 17 00:00:00 2001
From: kieran <kieran@harkin.me>
Date: Fri, 15 Nov 2024 15:56:53 +0000
Subject: [PATCH] chore: rename fns

---
 src/overseer/mod.rs            | 8 ++++----
 src/overseer/webhook.rs        | 4 ++--
 src/overseer/zap_stream/mod.rs | 4 ++--
 src/pipeline/runner.rs         | 2 +-
 4 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/overseer/mod.rs b/src/overseer/mod.rs
index 1e19264..3194e20 100644
--- a/src/overseer/mod.rs
+++ b/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,
diff --git a/src/overseer/webhook.rs b/src/overseer/webhook.rs
index ed7fc9d..86aab8f 100644
--- a/src/overseer/webhook.rs
+++ b/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,
diff --git a/src/overseer/zap_stream/mod.rs b/src/overseer/zap_stream/mod.rs
index c500ab2..399314b 100644
--- a/src/overseer/zap_stream/mod.rs
+++ b/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,
diff --git a/src/pipeline/runner.rs b/src/pipeline/runner.rs
index 241a109..8490a77 100644
--- a/src/pipeline/runner.rs
+++ b/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);