Public declaration syntax from forge-rs/crates/forge-flowers/src/interceptor.rs
Original source SHA-256: 933ac699c415348b87ecf052664ec09097734e89d884294e39763ef915a48cad
Function bodies and constant values are omitted. This is not the complete implementation.

Source line 62
pub struct JournaledProvider<'ctx> {

}

Source line 80
pub fn new(inner: Arc<dyn LanguageModel>, ctx: &'ctx ExecutionContext) -> Self;

Source line 85
pub fn model_id(&self) -> &str;

Source line 90
pub fn provider(&self) -> &str;

Source line 113
pub async fn generate(
        &self,
        messages: &[ModelMessage],
        tools: &[ToolDefinition],
        options: &GenerateOptions,
    ) -> Result<GenerateResult, FlowersError>;

Source line 174
pub async fn stream(
        &self,
        messages: &[ModelMessage],
        tools: &[ToolDefinition],
        options: &GenerateOptions,
    ) -> Result<Vec<StreamChunk>, FlowersError>;

Source line 241
pub struct JournaledToolExecutor<'ctx> {

}

Source line 252
pub fn new(ctx: &'ctx ExecutionContext) -> Self;

Source line 274
pub async fn execute<F, Fut>(
        &self,
        tool_id: &str,
        parameters: serde_json::Value,
        execute_fn: F,
    ) -> Result<serde_json::Value, FlowersError>
    where
        F: FnOnce(serde_json::Value) -> Fut + Send,
        Fut: std::future::Future<Output = Result<serde_json::Value, FlowersError>> + Send,;