Struct AiReadmeWriter

pub struct AiReadmeWriter { /* private fields */ }

Implementations

impl AiReadmeWriter

pub fn language_model_client( &self, ) -> &Arc<dyn LanguageModelClientInterface<LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError>>

pub fn language_model_type(&self) -> &LanguageModelType

pub fn batch_workspace(&self) -> &Arc<BatchWorkspace>

impl AiReadmeWriter

pub const AIREADMEWRITER_OUTPUT_FILE_BRIDGE: for<'a> fn(&'a BatchFileTriple, &'a dyn BatchWorkspaceInterface<Item = Arc<dyn GetTargetPathForAIExpansion + Send + Sync>>, &'a ExpectedContentType) -> Pin<Box<dyn Future<Output = Result<(), BatchOutputProcessingError>> + Send + 'a>> = {workspacer_readme_writer::AiReadmeWriter::AiReadmeWriter_output_file_bridge_fn as for<'a> fn(&'a workspacer_3p::BatchFileTriple, &'a (dyn workspacer_3p::BatchWorkspaceInterface + 'a), &'a workspacer_3p::ExpectedContentType) -> std::pin::Pin<std::boxed::Box<(dyn std::future::Future<Output = std::result::Result<(), workspacer_3p::BatchOutputProcessingError>> + std::marker::Send + 'a)>>}

A public constant pointer to that bridging function, matching BatchWorkflowProcessOutputFileFn.

impl AiReadmeWriter

pub async fn default() -> Result<AiReadmeWriter, AiReadmeWriterError>

pub async fn new( workspace_root: impl AsRef<Path>, language_model_type: LanguageModelType, ) -> Result<AiReadmeWriter, AiReadmeWriterError>

Trait Implementations

impl ComputeLanguageModelCoreQuery for AiReadmeWriter

type Seed = AiReadmeWriterRequest<PathBuf>

The seed item type (e.g., AiTomlWriterRequest).

fn compute_language_model_core_query( &self, input: &<AiReadmeWriter as ComputeLanguageModelCoreQuery>::Seed, ) -> String

Builds a single language model API request for a given seed item. The macro will call this once per seed item inside compute_language_model_requests().

impl ComputeLanguageModelRequests for AiReadmeWriter

type Seed = <AiReadmeWriter as ComputeLanguageModelCoreQuery>::Seed

fn compute_language_model_requests( &self, model: &LanguageModelType, inputs: &[<AiReadmeWriter as ComputeLanguageModelRequests>::Seed], ) -> Vec<LanguageModelBatchAPIRequest>

Identify which new items need to be processed and build the requests.

impl ComputeSystemMessage for AiReadmeWriter

fn system_message() -> String

Returns the system message to be applied to all requests.

impl FinishProcessingUncompletedBatches for AiReadmeWriter

type Error = LanguageModelBatchWorkflowError

fn finish_processing_uncompleted_batches<'life0, 'life1, 'async_trait>( &'life0 self, expected_content_type: &'life1 ExpectedContentType, ) -> Pin<Box<dyn Future<Output = Result<(), <AiReadmeWriter as FinishProcessingUncompletedBatches>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AiReadmeWriter: 'async_trait,

Possibly complete or discard partial data from prior runs.

impl GetBatchWorkspace<BatchWorkspaceError, <AiReadmeWriter as ComputeLanguageModelCoreQuery>::Seed> for AiReadmeWriter

fn workspace( &self, ) -> Arc<dyn FullBatchWorkspaceInterface<BatchWorkspaceError, <AiReadmeWriter as ComputeLanguageModelCoreQuery>::Seed, Item = Arc<dyn GetTargetPathForAIExpansion + Send + Sync>, Error = BatchWorkspaceError, Error = BatchWorkspaceError, Error = BatchWorkspaceError>>

impl GetLanguageModelClient<LanguageModelBatchWorkflowError> for AiReadmeWriter

fn language_model_client( &self, ) -> Arc<dyn LanguageModelClientInterface<LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError, Error = LanguageModelBatchWorkflowError>>

impl LanguageModelBatchWorkflow<LanguageModelBatchWorkflowError> for AiReadmeWriter

fn plant_seed_and_wait<'life0, 'life1, 'async_trait>( &'life0 mut self, input_tokens: &'life1 [<AiReadmeWriter as ComputeLanguageModelRequests>::Seed], ) -> Pin<Box<dyn Future<Output = Result<(), LanguageModelBatchWorkflowError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AiReadmeWriter: 'async_trait,

const REQUESTS_PER_BATCH: usize = 80usize

fn execute_language_model_batch_workflow<'life0, 'life1, 'async_trait>( &'life0 mut self, model: LanguageModelType, expected_content_type: ExpectedContentType, input_tokens: &'life1 [Self::Seed], ) -> Pin<Box<dyn Future<Output = Result<(), E>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: Send + 'async_trait,

High-level method that ties it all together. Fixes the mismatch by enumerating chunk-slices properly and passing &[LanguageModelBatchAPIRequest] to process_batch_requests.

impl LanguageModelBatchWorkflowGatherResults for AiReadmeWriter

type Error = LanguageModelBatchWorkflowError

type Seed = <AiReadmeWriter as ComputeLanguageModelCoreQuery>::Seed

type Output = AiReadmeWriterDesiredOutput

fn gather_results<'life0, 'life1, 'async_trait>( &'life0 self, seeds: &'life1 [<AiReadmeWriter as LanguageModelBatchWorkflowGatherResults>::Seed], ) -> Pin<Box<dyn Future<Output = Result<Vec<(<AiReadmeWriter as LanguageModelBatchWorkflowGatherResults>::Seed, <AiReadmeWriter as LanguageModelBatchWorkflowGatherResults>::Output)>, <AiReadmeWriter as LanguageModelBatchWorkflowGatherResults>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, AiReadmeWriter: 'async_trait,

Gathers AI-generated JSON outputs for the given seeds in the same order, returning (Seed, Output) pairs.

impl ProcessBatchRequests for AiReadmeWriter

type Error = LanguageModelBatchWorkflowError

fn process_batch_requests<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, batch_requests: &'life1 [LanguageModelBatchAPIRequest], expected_content_type: &'life2 ExpectedContentType, ) -> Pin<Box<dyn Future<Output = Result<(), <AiReadmeWriter as ProcessBatchRequests>::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, AiReadmeWriter: 'async_trait,

Process each batch, writing it to disk or sending it to a remote server.

impl Send for AiReadmeWriter

impl Sync for AiReadmeWriter