Class IntakeExceptions

java.lang.Object

ai.pipestream.connector.intake.error.IntakeExceptions

public final class IntakeExceptions
extends Object

Normalizes any failure into a client-safe IntakeException. Used at the gRPC and HTTP boundaries so an arbitrary thrown Throwable becomes a curated code + message before anything reaches a client.

Method Summary

Modifier and Type	Method	Description
static IntakeException	toIntake(Throwable t)	Returns t if it is already an IntakeException (preserving its code), otherwise classifies it via IntakeServiceException.fromUpstream(Throwable).

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

toIntake

public static IntakeException toIntake(Throwable t)

Returns t if it is already an IntakeException (preserving its code), otherwise classifies it via IntakeServiceException.fromUpstream(Throwable).