diff --git a/crates/fluvio-connector-common/src/lib.rs b/crates/fluvio-connector-common/src/lib.rs index 8c9a9cf7a4..580ffcb111 100644 --- 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 index e609621244..59a51cf675 100644 --- 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 index c5b5ba7ca3..b6a6fede46 100644 --- a/crates/fluvio-sc/src/controllers/mirroring/controller.rs +++ b/crates/fluvio-sc/src/controllers/mirroring/controller.rs @@ -94,7 +94,7 @@ impl RemoteMirrorController { } 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 index 101e469689..6b754ec832 100644 --- 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 RemoteFetchingFromHomeController { } // 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 index afa6e537e6..8f776b757d 100644 --- 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 index 23a0ccfbf4..5e26422d6a 100644 --- 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 index cd8b8e8a93..d8578a536c 100644 --- 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 ":"