From 5f3706bb93e740cbfb852dbeae2209953291d015 Mon Sep 17 00:00:00 2001 From: Aaron Po Date: Sun, 19 Jul 2026 04:10:32 -0400 Subject: [PATCH] Formatted includes --- .../biergarten_pipeline_orchestrator.h | 164 +++++++++--------- .../pipeline/includes/llama_backend_state.h | 10 +- 2 files changed, 87 insertions(+), 87 deletions(-) diff --git a/tooling/pipeline/includes/biergarten_pipeline_orchestrator.h b/tooling/pipeline/includes/biergarten_pipeline_orchestrator.h index 89dbc648..ff0f7210 100644 --- a/tooling/pipeline/includes/biergarten_pipeline_orchestrator.h +++ b/tooling/pipeline/includes/biergarten_pipeline_orchestrator.h @@ -24,98 +24,98 @@ * Handles location loading, city enrichment, and brewery/user generation. */ class BiergartenPipelineOrchestrator { - public: - /** - * @brief Constructs the orchestrator with injected pipeline dependencies. - * - * @param logger Sink for pipeline diagnostics. - * @param context_service Provides regional context for locations. - * @param generator Implementation (Llama or Mock) for brewery/user - * generation. - * @param exporter Database backend for persisting generated records. - * @param curated_data_service Loads curated location, persona, and name - * data used to seed generation. - * @param postal_code_service Resolves a postal code for a city from its - * curated postal-code data. - * @param application_options CLI configuration and paths. - */ - BiergartenPipelineOrchestrator( - std::shared_ptr logger, - std::unique_ptr context_service, - std::unique_ptr generator, - std::unique_ptr exporter, - std::unique_ptr curated_data_service, - std::unique_ptr postal_code_service, - const ApplicationOptions& application_options); + public: + /** + * @brief Constructs the orchestrator with injected pipeline dependencies. + * + * @param logger Sink for pipeline diagnostics. + * @param context_service Provides regional context for locations. + * @param generator Implementation (Llama or Mock) for brewery/user + * generation. + * @param exporter Database backend for persisting generated records. + * @param curated_data_service Loads curated location, persona, and name + * data used to seed generation. + * @param postal_code_service Resolves a postal code for a city from its + * curated postal-code data. + * @param application_options CLI configuration and paths. + */ + BiergartenPipelineOrchestrator( + std::shared_ptr logger, + std::unique_ptr context_service, + std::unique_ptr generator, + std::unique_ptr exporter, + std::unique_ptr curated_data_service, + std::unique_ptr postal_code_service, + const ApplicationOptions& application_options); - /** - * @brief Run the data generation pipeline. - * - * Performs the following steps: - * 1. Load curated locations from JSON - * 2. Resolve context for each city using the injected context service - * 3. Generate brewery and user data for sampled cities - * - * @note STRUCTURAL CONCURRENCY REQUIREMENT: - * When transitioned to a multithreaded design, this method MUST - * structurally enforce that all deployed worker threads are joined before - * returning (e.g. by using std::jthread or a structured concurrency - * primitive). This ensures workers do not attempt to log to a closed - * channel during application teardown. - * - * @return true if successful, false if not - */ - bool Run(); + /** + * @brief Run the data generation pipeline. + * + * Performs the following steps: + * 1. Load curated locations from JSON + * 2. Resolve context for each city using the injected context service + * 3. Generate brewery and user data for sampled cities + * + * @note STRUCTURAL CONCURRENCY REQUIREMENT: + * When transitioned to a multithreaded design, this method MUST + * structurally enforce that all deployed worker threads are joined before + * returning (e.g. by using std::jthread or a structured concurrency + * primitive). This ensures workers do not attempt to log to a closed + * channel during application teardown. + * + * @return true if successful, false if not + */ + bool Run(); - private: - std::shared_ptr logger_; - std::unique_ptr context_service_; + private: + std::shared_ptr logger_; + std::unique_ptr context_service_; - /** - * @brief Generator implementation selected at the composition root (Llama - * or Mock). - */ - std::unique_ptr generator_; + /** + * @brief Generator implementation selected at the composition root (Llama + * or Mock). + */ + std::unique_ptr generator_; - /** - * @brief Storage backend for generated brewery and user records. - */ - std::unique_ptr exporter_; - std::unique_ptr curated_data_service_; - std::unique_ptr postal_code_service_; + /** + * @brief Storage backend for generated brewery and user records. + */ + std::unique_ptr exporter_; + std::unique_ptr curated_data_service_; + std::unique_ptr postal_code_service_; - ApplicationOptions application_options_; + ApplicationOptions application_options_; - /** - * @brief Load locations from JSON and sample cities. - * - * @return Vector of locations randomly sampled per - * PipelineOptions::location_count. - */ - std::vector QueryLocations(); + /** + * @brief Load locations from JSON and sample cities. + * + * @return Vector of locations randomly sampled per + * PipelineOptions::location_count. + */ + std::vector QueryLocations(); - /** - * @brief Generate breweries for enriched cities. - * - * @param cities Span of enriched city data. - */ - void GenerateBreweries(std::span cities); + /** + * @brief Generate breweries for enriched cities. + * + * @param cities Span of enriched city data. + */ + void GenerateBreweries(std::span cities); - /** - * @brief Generate users grounded in sampled names and personas for - * enriched cities. - * - * @param cities Span of enriched city data. - */ - void GenerateUsers(std::span cities); + /** + * @brief Generate users grounded in sampled names and personas for + * enriched cities. + * + * @param cities Span of enriched city data. + */ + void GenerateUsers(std::span cities); - /** - * @brief Log the generated brewery and user results. - */ - void LogResults() const; + /** + * @brief Log the generated brewery and user results. + */ + void LogResults() const; - std::vector generated_breweries_; - std::vector generated_users_; + std::vector generated_breweries_; + std::vector generated_users_; }; #endif // BIERGARTEN_PIPELINE_INCLUDES_BIERGARTEN_PIPELINE_ORCHESTRATOR_H_ diff --git a/tooling/pipeline/includes/llama_backend_state.h b/tooling/pipeline/includes/llama_backend_state.h index d50fa80a..d52b2f00 100644 --- a/tooling/pipeline/includes/llama_backend_state.h +++ b/tooling/pipeline/includes/llama_backend_state.h @@ -15,12 +15,12 @@ * it alive for application lifetime. */ class LlamaBackendState { - public: - LlamaBackendState() { llama_backend_init(); } - ~LlamaBackendState() { llama_backend_free(); } + public: + LlamaBackendState() { llama_backend_init(); } + ~LlamaBackendState() { llama_backend_free(); } - LlamaBackendState(const LlamaBackendState&) = delete; - LlamaBackendState& operator=(const LlamaBackendState&) = delete; + LlamaBackendState(const LlamaBackendState&) = delete; + LlamaBackendState& operator=(const LlamaBackendState&) = delete; }; #endif // BIERGARTEN_PIPELINE_INCLUDES_LLAMA_BACKEND_STATE_H_