Struct ProviderRegistry 

pub struct ProviderRegistry { /* private fields */ }

Registry of all available stream providers, keyed by API protocol.

Implementations

impl ProviderRegistry

pub fn new() -> Self

Create an empty registry (no providers registered). Use ProviderRegistry::default() to get all built-in providers.

pub fn register( &mut self, protocol: ApiProtocol, provider: impl StreamProvider + 'static, )

Register a provider for a given protocol.

pub fn get(&self, protocol: &ApiProtocol) -> Option<&dyn StreamProvider>

Get a reference to the provider for a given protocol, if registered.

pub fn has(&self, protocol: &ApiProtocol) -> bool

Returns true if a provider is registered for the given protocol.

pub fn protocols(&self) -> Vec<ApiProtocol>

List all protocols that have a registered provider.

pub async fn stream( &self, model: &ModelConfig, config: StreamConfig, tx: UnboundedSender<StreamEvent>, cancel: CancellationToken, ) -> Result<Message, ProviderError>

Stream using the appropriate provider for the model’s API protocol.

Trait Implementations

impl Default for ProviderRegistry

fn default() -> Self

Create a registry with all 7 built-in providers registered.