pub enum ImageGenerationError {
HttpError(Error),
JsonError(Error),
RequestError(Box<dyn Error + Send + Sync + 'static>),
ResponseError(String),
ProviderError(String),
ProviderResponse(ProviderResponseError),
}image only.Expand description
Errors returned by image generation models.
Inspect provider failures with Self::provider_response_body,
Self::provider_response_json, and Self::provider_response_status.
Variants§
HttpError(Error)
Http error (e.g.: connection error, timeout, etc.)
JsonError(Error)
Json error (e.g.: serialization, deserialization)
RequestError(Box<dyn Error + Send + Sync + 'static>)
Error building the image generation request
ResponseError(String)
Error parsing the image generation response
ProviderError(String)
Error returned by the image generation model provider
ProviderResponse(ProviderResponseError)
Raw error response preserved from the image generation model provider
Implementations§
Source§impl ImageGenerationError
impl ImageGenerationError
Sourcepub fn from_http_response(status: StatusCode, body: impl Into<String>) -> Self
pub fn from_http_response(status: StatusCode, body: impl Into<String>) -> Self
Builds an error from a captured HTTP status and raw response body,
routing it so the provider_response_* helpers stay useful.
This is the single funnel every HTTP-error path should use instead
of flattening a status and body into a ProviderError(String):
- A success (2xx) status carries a provider-authored error
envelope, so it is preserved as
Self::ProviderResponsetogether with the status. - A non-success status is preserved as
Self::HttpError(http_client::Error::InvalidStatusCodeWithMessage).
Either way the raw body is kept verbatim and the status stays
recoverable through Self::provider_response_status. Read the
response body exactly once and hand it here for both branches.
Sourcepub fn from_http_response_with_request_id(
status: StatusCode,
body: impl Into<String>,
provider_request_id: Option<String>,
) -> Self
pub fn from_http_response_with_request_id( status: StatusCode, body: impl Into<String>, provider_request_id: Option<String>, ) -> Self
Self::from_http_response for paths that captured the
provider’s transport request id alongside the response
(rig#2314).
Unlike the metadata-less funnel, a non-success status is
preserved as Self::ProviderResponse too — http_client’s
error type has no slot for provider metadata, and the id the
provider reported on a failed call is exactly what support
asks for. Classification therefore follows the code path
(did this call site capture transport metadata?), never the
presence of the header on a particular response, so a given
provider’s errors classify consistently. The status stays
recoverable through Self::provider_response_status and the
id through Self::provider_request_id.
Sourcepub fn with_response_headers(self, headers: Option<Box<HeaderMap>>) -> Self
pub fn with_response_headers(self, headers: Option<Box<HeaderMap>>) -> Self
Attaches the response’s headers to an error just built by one of
the from_http_response* funnels, so rate-limit metadata
(Retry-After, x-ratelimit-*) survives onto it (rig#2210).
This is a separate step rather than a funnel parameter because
the funnels’ classification is fixed by the call path (does
this provider have a request-id contract?), while header capture
depends only on whether the transport handed the response back.
Both routes can therefore carry headers:
Self::ProviderResponse stores them alongside the request id,
and a non-success Self::HttpError is upgraded in place to
http_client::Error::InvalidStatusCodeWithDetails,
which displays identically to the header-less variant.
Passing None leaves the error untouched, as does calling this
on a variant with no response to annotate. An error that already
captured headers keeps the ones it has: the first capture is the
one that saw the response, so this never overwrites.
Sourcepub fn from_provider_body(body: impl Into<String>) -> Self
pub fn from_provider_body(body: impl Into<String>) -> Self
Preserves a raw provider error body that has no HTTP status.
Use this for non-HTTP transports (gRPC / SDK clients such as AWS
Bedrock, Vertex AI, or the gRPC Gemini client) where the provider
returns an error payload but no http::StatusCode is available.
The body is preserved as Self::ProviderResponse with
status == None, so Self::provider_response_body still surfaces
it while Self::provider_response_status returns None.
Sourcepub fn provider_response_body(&self) -> Option<&str>
pub fn provider_response_body(&self) -> Option<&str>
Returns the raw provider response body when available.
This is available for:
Self::ProviderResponseusing its preserved body.Self::HttpErrorwhen it wraps an HTTP non-success response that carries a body.
Returns None for any other variant — for example a Rig-generated
ProviderError diagnostic, or a failure from a transport with no
provider response body to preserve. An empty preserved body is
reported as Some("") (the provider returned no payload), which is
distinct from None; note that Self::provider_response_json
maps that same empty body to Ok(None).
Sourcepub fn provider_response_json(&self) -> Result<Option<Value>, Error>
pub fn provider_response_json(&self) -> Result<Option<Value>, Error>
Parses the provider response body as JSON.
Returns:
Ok(Some(value))when a body is present and valid JSON.Ok(None)when no provider response body is available.Err(error)when a body is present but isn’t valid JSON.
Sourcepub fn provider_response_status(&self) -> Option<StatusCode>
pub fn provider_response_status(&self) -> Option<StatusCode>
Returns the HTTP status code when this error preserves one, either from a non-success HTTP response, from a preserved provider response, or from a 2xx error envelope.
Warning: this can return a 2xx status. Some providers send
an error envelope alongside a success status, which Rig preserves
via Self::ProviderResponse. Callers must not infer failure from
the status code alone — the existence of this error already means
the call failed. Returns None for non-HTTP transports (gRPC / SDK
clients) and for variants that carry no provider response.
Sourcepub fn provider_request_id(&self) -> Option<&str>
pub fn provider_request_id(&self) -> Option<&str>
Returns the provider’s transport request id for the failed
call, when the capture path preserved one (rig#2314) — the id
provider support asks for. None for providers that report
none, for paths that captured no transport metadata, and for
errors with no provider response at all.
Sourcepub fn provider_response_headers(&self) -> Option<&HeaderMap>
pub fn provider_response_headers(&self) -> Option<&HeaderMap>
Returns the response’s headers when the capture path preserved
them (rig#2210) — the rate-limit metadata (Retry-After,
x-ratelimit-*) a caller needs to back off correctly:
fn backoff(error: &CompletionError) -> Option<Duration> {
let seconds = error
.provider_response_headers()?
.get(http::header::RETRY_AFTER)?
.to_str()
.ok()?
.parse()
.ok()?;
Some(Duration::from_secs(seconds))
}Returns None when no headers were captured: non-HTTP
transports (gRPC / SDK clients), Rig-generated diagnostics,
errors funnelled from only a status and body (e.g. via
Self::from_http_response), and transports that report a
non-success status without preserving them. None therefore
means “not captured”, never “the response had no headers”.
Trait Implementations§
Source§impl Debug for ImageGenerationError
impl Debug for ImageGenerationError
Source§impl Display for ImageGenerationError
impl Display for ImageGenerationError
Source§impl Error for ImageGenerationError
impl Error for ImageGenerationError
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
use the Display impl or to_string()
Source§impl From<Error> for ImageGenerationError
impl From<Error> for ImageGenerationError
Auto Trait Implementations§
impl !Freeze for ImageGenerationError
impl !RefUnwindSafe for ImageGenerationError
impl !UnwindSafe for ImageGenerationError
impl Send for ImageGenerationError
impl Sync for ImageGenerationError
impl Unpin for ImageGenerationError
impl UnsafeUnpin for ImageGenerationError
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<T> ToStringFallible for Twhere
T: Display,
impl<T> ToStringFallible for Twhere
T: Display,
Source§fn try_to_string(&self) -> Result<String, TryReserveError>
fn try_to_string(&self) -> Result<String, TryReserveError>
ToString::to_string, but without panic on OOM.