Class IntakeEvents

java.lang.Object

ai.pipeline.connector.intake.event.IntakeEvents

public final class IntakeEvents
extends Object

Builds the intake_events protos from upload context and maps the service's IntakeErrorCode taxonomy onto the proto's RejectionReason. Keeping this translation in one place means the HTTP and gRPC surfaces emit identical, consistent events.

Method Summary

Modifier and Type	Method	Description
static ai.pipestream.connector.intake.v1.DocumentAccepted	accepted(String datasourceId, String crawlId, String sessionId, String sourceDocId, String docId)
static ai.pipestream.connector.intake.v1.DocumentError	error(String datasourceId, String crawlId, String sessionId, String sourceDocId, String docId, String errorId, IntakeErrorCode code, String message)
static ai.pipestream.connector.intake.v1.ErrorReason	errorReasonFor(IntakeErrorCode code)	Map the client-facing error taxonomy onto the proto error reason (5xx-class).
static ai.pipestream.connector.intake.v1.RejectionReason	reasonFor(IntakeErrorCode code)	Map the client-facing error taxonomy onto the proto rejection reason (4xx-class).
static ai.pipestream.connector.intake.v1.DocumentRejected	rejected(String datasourceId, String crawlId, String sessionId, String sourceDocId, String docId, IntakeErrorCode code, String message)

Methods inherited from class Object

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

Method Details

accepted

public static ai.pipestream.connector.intake.v1.DocumentAccepted accepted(String datasourceId,
 String crawlId,
 String sessionId,
 String sourceDocId,
 String docId)

rejected

public static ai.pipestream.connector.intake.v1.DocumentRejected rejected(String datasourceId,
 String crawlId,
 String sessionId,
 String sourceDocId,
 String docId,
 IntakeErrorCode code,
 String message)

error

public static ai.pipestream.connector.intake.v1.DocumentError error(String datasourceId,
 String crawlId,
 String sessionId,
 String sourceDocId,
 String docId,
 String errorId,
 IntakeErrorCode code,
 String message)

reasonFor

public static ai.pipestream.connector.intake.v1.RejectionReason reasonFor(IntakeErrorCode code)

Map the client-facing error taxonomy onto the proto rejection reason (4xx-class).

errorReasonFor

public static ai.pipestream.connector.intake.v1.ErrorReason errorReasonFor(IntakeErrorCode code)

Map the client-facing error taxonomy onto the proto error reason (5xx-class).