Struct OutputFanoutProvider 

pub struct OutputFanoutProvider { /* private fields */ }

Provider decorator that turns one logical multi-output request into bounded calls.

Implementations

impl OutputFanoutProvider

pub fn new( inner: Arc<dyn ImageProvider>, config: OutputFanoutConfig, ) -> Result<Self, BridgeError>

Decorates a provider without changing its registry identity.

Trait Implementations

impl Debug for OutputFanoutProvider

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ImageProvider for OutputFanoutProvider

fn descriptor(&self) -> ProviderDescriptor

Returns stable provider identity.

fn capabilities<'life0, 'life1, 'async_trait>( &'life0 self, model: Option<&'life1 str>, ) -> Pin<Box<dyn Future<Output = Result<ProviderCapabilities, BridgeError>> + Send + 'async_trait>>

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

Returns current capabilities for an optional model.

fn execute<'life0, 'async_trait>( &'life0 self, request: ImageRequest, context: ProviderContext, ) -> Pin<Box<dyn Future<Output = Result<ImageResponse, BridgeError>> + Send + 'async_trait>>

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

Executes one normalized request without exposing incremental events.

fn check_ready<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Performs a non-generating auth/readiness check.

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<SessionMetadata, BridgeError>> + Send + 'async_trait>>

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

Looks up caller-visible persistent session metadata when supported.

fn delete_session<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Deletes a persistent session binding when supported.

fn restart_count(&self) -> Option<u64>

Returns the number of supervised provider process restarts when exposed.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BridgeError>> + Send + 'async_trait>>

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

Releases provider resources during graceful shutdown.

fn execute_stream<'life0, 'async_trait>( &'life0 self, _request: ImageRequest, _context: ProviderContext, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<ProviderEvent, BridgeError>> + Send>>, BridgeError>> + Send + 'async_trait>>

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

Starts a request with incremental events when supported.