Struct WorkflowProvider 

pub struct WorkflowProvider<P> { /* private fields */ }

LLM provider wrapper that tracks costs per workflow

Implementations

impl<P> WorkflowProvider<P>

pub fn new( provider: P, tracker: WorkflowTracker, workflow_id: String, budget: Option<BudgetLimit>, ) -> Self

Create a new workflow provider

pub fn with_pricing(self, pricing: ModelPricing) -> Self

Set the pricing model for cost calculation

pub fn tracker(&self) -> &WorkflowTracker

Get the workflow tracker

pub fn workflow_id(&self) -> &str

Get the workflow ID

pub fn stats(&self) -> WorkflowStats

Get statistics for this workflow

Trait Implementations

impl<P: LlmProvider> LlmProvider for WorkflowProvider<P>

fn complete<'life0, 'async_trait>( &'life0 self, request: LlmRequest, ) -> Pin<Box<dyn Future<Output = Result<LlmResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<P: StreamingLlmProvider> StreamingLlmProvider for WorkflowProvider<P>

fn complete_stream<'life0, 'async_trait>( &'life0 self, request: LlmRequest, ) -> Pin<Box<dyn Future<Output = Result<LlmStream>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stream completion responses token-by-token