chore: typo successful (#4238)

infinyon · Nov 12, 2024 · 5f101f2 · 5f101f2
1 parent 4734e0c
commit 5f101f2
Show file tree

Hide file tree

Showing 7 changed files with 15 additions and 15 deletions.
diff --git a/crates/fluvio-connector-common/src/lib.rs b/crates/fluvio-connector-common/src/lib.rs
@@ -59,7 +59,7 @@ pub async fn ensure_topic_exists(config: &config::ConnectorConfig) -> Result<()>
             )
             .await
         {
-            Ok(_) => info!(topic, "succesfully created"),
+            Ok(_) => info!(topic, "successfully created"),
             Err(err) => {
                 error!("unable to create topic {topic}: {err}");
                 return Err(err);

diff --git a/crates/fluvio-controlplane-metadata/src/mirror/status.rs b/crates/fluvio-controlplane-metadata/src/mirror/status.rs
@@ -67,7 +67,7 @@ pub enum MirrorPairStatus {
     #[fluvio(tag = 0)]
     Waiting,
     #[fluvio(tag = 1)]
-    Succesful,
+    Successful,
     #[fluvio(tag = 2)]
     Failed,
     #[fluvio(tag = 3)]
@@ -129,7 +129,7 @@ impl std::fmt::Display for MirrorStatus {
 impl std::fmt::Display for MirrorPairStatus {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
         let status = match self {
-            MirrorPairStatus::Succesful => "Connected",
+            MirrorPairStatus::Successful => "Connected",
             MirrorPairStatus::Disabled => "Disabled",
             MirrorPairStatus::Failed => "Failed",
             MirrorPairStatus::Waiting => "Waiting",
@@ -159,7 +159,7 @@ mod test {
     #[test]
     fn test_last_seen() {
         let status = MirrorStatus {
-            pairing_sc: MirrorPairStatus::Succesful,
+            pairing_sc: MirrorPairStatus::Successful,
             pairing_spu: MirrorPairStatus::Waiting,
             connection_status: ConnectionStatus::Online,
             connection_stat: ConnectionStat {
@@ -172,7 +172,7 @@ mod test {
         assert_eq!(last_seen, "5s");
 
         let default_status = MirrorStatus {
-            pairing_sc: MirrorPairStatus::Succesful,
+            pairing_sc: MirrorPairStatus::Successful,
             pairing_spu: MirrorPairStatus::Waiting,
             connection_status: ConnectionStatus::Online,
             connection_stat: ConnectionStat { last_seen: 0 },

diff --git a/crates/fluvio-sc/src/controllers/mirroring/controller.rs b/crates/fluvio-sc/src/controllers/mirroring/controller.rs
@@ -94,7 +94,7 @@ impl<C: MetadataItem> RemoteMirrorController<C> {
                             }
 
                             info!("synced topics from home");
-                            self.update_status(MirrorPairStatus::Succesful).await?;
+                            self.update_status(MirrorPairStatus::Successful).await?;
                             backoff.reset();
                         }
                         Err(err) => {

diff --git a/crates/fluvio-sc/src/services/public_api/mirroring/connect.rs b/crates/fluvio-sc/src/services/public_api/mirroring/connect.rs
@@ -240,7 +240,7 @@ impl<AC: AuthContext, C: MetadataItem> RemoteFetchingFromHomeController<AC, C> {
                 }
 
                 // update status
-                self.update_status(MirrorPairStatus::Succesful, status)
+                self.update_status(MirrorPairStatus::Successful, status)
                     .await?;
 
                 return Ok(());

diff --git a/crates/fluvio-spu/src/mirroring/home/connection.rs b/crates/fluvio-spu/src/mirroring/home/connection.rs
@@ -198,7 +198,7 @@ impl MirrorHomeHandler {
         // create timer
         let mut timer = sleep(Duration::from_secs(MIRROR_RECONCILIATION_INTERVAL_SEC));
 
-        self.update_status(MirrorPairStatus::Succesful).await?;
+        self.update_status(MirrorPairStatus::Successful).await?;
 
         loop {
             debug!(

diff --git a/crates/fluvio-spu/src/mirroring/remote/controller.rs b/crates/fluvio-spu/src/mirroring/remote/controller.rs
@@ -255,7 +255,7 @@ where
             if home_updated_needed && home_leo >= 0 {
                 self.update_remote_as_source(&mut home_sink, home_leo)
                     .await?;
-                self.update_status(MirrorPairStatus::Succesful).await?;
+                self.update_status(MirrorPairStatus::Successful).await?;
                 home_updated_needed = false;
             }
 
@@ -278,7 +278,7 @@ where
                                 return Err(anyhow!("received sync record request from home, this should not happen, since we are source"));
                             }
                          }
-                        self.update_status(MirrorPairStatus::Succesful).await?;
+                        self.update_status(MirrorPairStatus::Successful).await?;
                         backoff.reset();
                     } else {
                         warn!("spu socket to home has terminated");
@@ -349,7 +349,7 @@ where
                             HomeMirrorRequest::SyncRecords(sync_request)=> {
                                 if(!paired) {
                                     info!("sync received for the first time, indicating paired");
-                                    self.update_status(MirrorPairStatus::Succesful).await?;
+                                    self.update_status(MirrorPairStatus::Successful).await?;
                                     paired = true;
                                 }
 

diff --git a/tests/cli/cdk_smoke_tests/cdk-multi-partition-consumer.bats b/tests/cli/cdk_smoke_tests/cdk-multi-partition-consumer.bats
@@ -54,7 +54,7 @@ EOF
     assert_success
     assert_output --partial "Connector runs with process id"
 
-    wait_for_line_in_file "succesfully created" $LOG_PATH 30
+    wait_for_line_in_file "successfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
     echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
@@ -106,7 +106,7 @@ EOF
     assert_success
     assert_output --partial "Connector runs with process id"
 
-    wait_for_line_in_file "succesfully created" $LOG_PATH 30
+    wait_for_line_in_file "successfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
     echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
@@ -157,7 +157,7 @@ EOF
     assert_success
     assert_output --partial "Connector runs with process id"
 
-    wait_for_line_in_file "succesfully created" $LOG_PATH 30
+    wait_for_line_in_file "successfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
     echo 3:3 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"
@@ -229,7 +229,7 @@ EOF
     assert_success
     assert_output --partial "Connector runs with process id"
 
-    wait_for_line_in_file "succesfully created" $LOG_PATH 30
+    wait_for_line_in_file "successfully created" $LOG_PATH 30
     wait_for_line_in_file "monitoring started" $LOG_PATH 30
 
     echo 1:1 | "$FLUVIO_BIN" produce $TOPIC_NAME --key-separator ":"