Fix fmt in quickwit-lambda

quickwit/quickwit-lambda/src/bin/indexer.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/bin/searcher.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/indexer/environment.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/indexer/handler.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/indexer/ingest.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].
@@ -169,7 +169,7 @@ pub async fn ingest(args: IngestArgs) -> anyhow::Result<IndexingStatistics> {
         metastore
             .create_index(CreateIndexRequest::try_from_index_config(index_config)?)
             .await?;
-        debug!("Index created");
+        debug!("index created");
     } else if args.overwrite {
         info!(
             index_id = *INDEX_ID,
@@ -221,9 +221,9 @@ pub async fn ingest(args: IngestArgs) -> anyhow::Result<IndexingStatistics> {
     let indexing_pipeline_handle = indexing_server_mailbox
         .ask_for_res(DetachIndexingPipeline { pipeline_id })
         .await?;
-    debug!("Wait for indexing statistics");
+    debug!("wait for indexing statistics");
     let statistics = start_statistics_reporting_loop(indexing_pipeline_handle, false).await?;
-    debug!("Indexing completed, tear down actors");
+    debug!("indexing completed, tear down actors");
     merge_pipeline_handle.quit().await;
     universe
         .send_exit_with_success(&indexing_server_mailbox)
@@ -232,9 +232,9 @@ pub async fn ingest(args: IngestArgs) -> anyhow::Result<IndexingStatistics> {
     universe.quit().await;
 
     if args.clear_cache {
-        info!("Clearing local cache directory...");
+        info!("clearing local cache directory");
         clear_cache_directory(&config.data_dir_path).await?;
-        info!("Local cache directory cleared.");
+        info!("local cache directory cleared");
     }
 
     if statistics.num_invalid_docs > 0 {

quickwit/quickwit-lambda/src/indexer/mod.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/indexer/model.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/lib.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/logger.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].
@@ -143,7 +143,7 @@ pub fn setup_lambda_tracer() -> anyhow::Result<()> {
 
 pub fn flush_tracer() {
     if let Some(Some(tracer_provider)) = TRACER_PROVIDER.get() {
-        debug!("Flush tracers");
+        debug!("flush tracers");
         for res in tracer_provider.force_flush() {
             if let Err(err) = res {
                 debug!(err=?err, "Failed to flush tracer");

quickwit/quickwit-lambda/src/searcher/environment.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/searcher/handler.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/searcher/mod.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/searcher/search.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].

quickwit/quickwit-lambda/src/utils.rs

@@ -1,4 +1,4 @@
-// Copyright (C) 2023 Quickwit, Inc.
+// Copyright (C) 2024 Quickwit, Inc.
 //
 // Quickwit is offered under the AGPL v3.0 and as commercial software.
 // For commercial licensing, contact us at [email protected].
@@ -33,7 +33,7 @@ pub(crate) async fn load_node_config(
     let config = NodeConfig::load(ConfigFormat::Yaml, config_template.as_bytes())
         .await
         .with_context(|| format!("Failed to parse node config `{config_template}`."))?;
-    info!(config=?config, "Loaded node config.");
+    info!(config=?config, "loaded node config");
     let storage_resolver = StorageResolver::configured(&config.storage_configs);
     let metastore_resolver =
         MetastoreResolver::configured(storage_resolver.clone(), &config.metastore_configs);