Index

A B C D E F G H I L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accepted(String, String, String, String, String) - Static method in class ai.pipeline.connector.intake.event.IntakeEvents
 
accepted(String, String, String, String, String) - Method in class ai.pipeline.connector.intake.status.IntakeOutcomeRecorder
 
ACCEPTED - Enum constant in enum class ai.pipeline.connector.intake.status.UploadState
Intake accepted the document and handed it off downstream.
acceptedAtMs() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the acceptedAtMs record component.
acceptStreamingItem(PipeDocItem, StreamContext, ConfigResolutionService.ResolvedConfig) - Method in class ai.pipeline.connector.intake.pipedoc.PipeDocAcceptanceService
 
accountId - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Account ID this connector belongs to.
accountId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the accountId record component.
accountId() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns the value of the accountId record component.
addBytesProcessed(String, long) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Add the number of processed bytes to the session total.
addBytesProcessed(String, long) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
ai.pipeline.connector.intake.config - package ai.pipeline.connector.intake.config
 
ai.pipeline.connector.intake.entity - package ai.pipeline.connector.intake.entity
 
ai.pipeline.connector.intake.error - package ai.pipeline.connector.intake.error
 
ai.pipeline.connector.intake.event - package ai.pipeline.connector.intake.event
 
ai.pipeline.connector.intake.grpc - package ai.pipeline.connector.intake.grpc
 
ai.pipeline.connector.intake.http - package ai.pipeline.connector.intake.http
 
ai.pipeline.connector.intake.ingress - package ai.pipeline.connector.intake.ingress
 
ai.pipeline.connector.intake.pipedoc - package ai.pipeline.connector.intake.pipedoc
 
ai.pipeline.connector.intake.pipedoc.streaming - package ai.pipeline.connector.intake.pipedoc.streaming
 
ai.pipeline.connector.intake.repository - package ai.pipeline.connector.intake.repository
 
ai.pipeline.connector.intake.security - package ai.pipeline.connector.intake.security
 
ai.pipeline.connector.intake.service - package ai.pipeline.connector.intake.service
 
ai.pipeline.connector.intake.session - package ai.pipeline.connector.intake.session
 
ai.pipeline.connector.intake.status - package ai.pipeline.connector.intake.status
 
ai.pipeline.connector.intake.token - package ai.pipeline.connector.intake.token
 
ai.pipeline.connector.intake.util - package ai.pipeline.connector.intake.util
 
ai.pipeline.connector.util - package ai.pipeline.connector.util
 
allowed() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Returns the value of the allowed record component.
API_KEY_HEADER - Static variable in class ai.pipeline.connector.intake.grpc.ApiKeyServerInterceptor
Header carrying the datasource API key.
apiKey() - Static method in class ai.pipeline.connector.intake.grpc.ApiKeyServerInterceptor
The calling request's API key, or "" when the header was absent.
ApiKeyServerInterceptor - Class in ai.pipeline.connector.intake.grpc
Captures the x-api-key gRPC metadata header into the call Context.
ApiKeyServerInterceptor() - Constructor for class ai.pipeline.connector.intake.grpc.ApiKeyServerInterceptor
CDI.
ApiKeyUtil - Class in ai.pipeline.connector.util
Utilities for API key generation and hashing.
ApiKeyUtil() - Constructor for class ai.pipeline.connector.util.ApiKeyUtil
Default constructor for CDI proxying.

B

badRequest(String) - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
Generic malformed request with an explicit, safe explanation.
BlobUploadHandoffService - Class in ai.pipeline.connector.intake.pipedoc
Handles the gRPC blob upload path: persist the doc to repository (durable, blobs are large so we don't route them through Redis), then hand off a reference-only request to the engine.
BlobUploadHandoffService() - Constructor for class ai.pipeline.connector.intake.pipedoc.BlobUploadHandoffService
Default constructor for CDI proxying.
body() - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Returns the value of the body record component.
buildHandoffRequest(PipeDoc, String, String, IngestionConfig, String) - Static method in class ai.pipeline.connector.intake.service.EngineClient
Build an IntakeHandoffRequest for an inline document.
buildReferenceRequest(String, String, String, String, IngestionConfig, String) - Method in class ai.pipeline.connector.intake.service.EngineClient
Build the reference-only IntakeHandoffRequest (a document_ref pointer to an already-persisted repo doc) WITHOUT sending it, so the blob path can enqueue the same request to the Redis intake ingress instead of the dropped gRPC handoff.
bytesProcessed - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Total bytes processed.

C

callWithApiKey(String, Callable) - Static method in class ai.pipeline.connector.intake.grpc.ApiKeyServerInterceptor
Run body with apiKey bound as the call credential.
canonicalInput - Variable in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
Human-readable canonical source (pre-hash) for provenance/observability.
canonicalizeUri(String) - Static method in class ai.pipeline.connector.intake.util.UriCanonicalizer
Canonicalizes a URI, keeping query parameters.
canonicalizeUri(String, boolean) - Static method in class ai.pipeline.connector.intake.util.UriCanonicalizer
Transforms a source URI into a canonical ID string.
chunkSizeCalculator() - Method in class ai.pipeline.connector.intake.config.ChunkSizeCalculatorProducer
Produces a default ChunkSizeCalculator instance.
ChunkSizeCalculatorProducer - Class in ai.pipeline.connector.intake.config
Provides a default ChunkSizeCalculator bean when the pipestream-server dependency does not expose it as a CDI bean.
ChunkSizeCalculatorProducer() - Constructor for class ai.pipeline.connector.intake.config.ChunkSizeCalculatorProducer
Default constructor for CDI proxying.
clientFacingMessage() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
Client message with the errorId appended for server-faults — for surfaces (gRPC in-band responses) that have no dedicated errorId field yet.
clientMessage() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
Safe, client-facing message.
code - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
Client-safe outcome code for REJECTED/ERROR (e.g.
code() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns the value of the code record component.
code() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
 
code() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the code record component.
code() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Returns the value of the code record component.
code() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the code record component.
completedAt - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Timestamp when session completed.
completeSession(String, String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Mark a session as completed and set its terminal state.
completeSession(String, String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
ConfigResolutionService - Class in ai.pipeline.connector.intake.service
Service for resolving Tier 1 configuration for a datasource.
ConfigResolutionService() - Constructor for class ai.pipeline.connector.intake.service.ConfigResolutionService
Default constructor for CDI.
ConfigResolutionService.ResolvedConfig - Record Class in ai.pipeline.connector.intake.service
Resolved configuration containing Tier 1 config and base IngestionConfig.
CONFLICT - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
ConnectorIntakeServiceImpl - Class in ai.pipeline.connector.intake.service
Thin gRPC adapter for connector intake endpoints.
ConnectorIntakeServiceImpl() - Constructor for class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
Default constructor for gRPC service instantiation.
ConnectorMetadata - Class in ai.pipeline.connector.intake.util
Utility class for parsing and serializing connector metadata JSON.
ConnectorMetadata() - Constructor for class ai.pipeline.connector.intake.util.ConnectorMetadata
Create an instance with safe defaults.
connectorType - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Connector type identifier.
ConnectorValidationService - Class in ai.pipeline.connector.intake.service
Service for validating connector API keys and fetching connector configuration.
ConnectorValidationService() - Constructor for class ai.pipeline.connector.intake.service.ConnectorValidationService
Default constructor for CDI.
consumeIntakeRepoEvents(Message) - Method in class ai.pipeline.connector.intake.service.IntakeRepoEventConsumer
@RunOnVirtualThread tells SmallRye Reactive Messaging to dispatch each incoming Kafka record on its own virtual thread instead of the Vert.x event loop.
contentType() - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Returns the value of the contentType record component.
CrawlDocument - Class in ai.pipeline.connector.intake.entity
Document tracking entity for orphan detection.
CrawlDocument() - Constructor for class ai.pipeline.connector.intake.entity.CrawlDocument
Default constructor for JPA.
CrawlDocument(String, String, String) - Constructor for class ai.pipeline.connector.intake.entity.CrawlDocument
Create a new crawl document tracking entry.
CrawlDocument.CrawlDocumentId - Class in ai.pipeline.connector.intake.entity
Composite primary key for CrawlDocument.
CrawlDocumentId() - Constructor for class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
Default constructor for JPA.
CrawlDocumentId(String, String) - Constructor for class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
Create a composite identifier.
CrawlDocumentRepository - Class in ai.pipeline.connector.intake.repository
Repository for crawl document tracking operations.
CrawlDocumentRepository() - Constructor for class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Default constructor for CDI.
crawlId - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Client-provided crawl ID.
crawlId - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
 
crawlId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the crawlId record component.
CrawlSession - Class in ai.pipeline.connector.intake.entity
Crawl session entity tracking document ingestion sessions.
CrawlSession() - Constructor for class ai.pipeline.connector.intake.entity.CrawlSession
Default constructor for JPA.
CrawlSession(String, String, String, String, String) - Constructor for class ai.pipeline.connector.intake.entity.CrawlSession
Create a new crawl session.
crawlSessionId - Variable in class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
Crawl session identifier (UUID of the session that processed the document).
CrawlSessionRepository - Class in ai.pipeline.connector.intake.repository
Repository for crawl session operations.
CrawlSessionRepository() - Constructor for class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Default constructor for CDI.
CrawlSessionRpcService - Class in ai.pipeline.connector.intake.session
RPC service for managing crawl session lifecycle and heartbeats.
CrawlSessionRpcService() - Constructor for class ai.pipeline.connector.intake.session.CrawlSessionRpcService
Default constructor for CDI proxying.
createdAt - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
 
createSession(String, String, String, String, String, String, boolean, boolean) - Method in class ai.pipeline.connector.intake.service.SessionManager
 

D

datasourceId - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
DataSource ID that started this session.
datasourceId - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
 
datasourceId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the datasourceId record component.
datasourceId() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns the value of the datasourceId record component.
defaultMessage() - Method in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
deleteBySessionId(String) - Method in class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Delete all tracked document entries for the given session.
deleteOrphans - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Whether to delete orphans at end of crawl.
derive(String, String, String, SearchMetadata) - Method in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver
Deterministically derive a doc_id for a document.
docId - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
The platform doc_id ({datasourceId}:{uuid}).
docId - Variable in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
 
docId() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns the value of the docId record component.
docId() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the docId record component.
docId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the docId record component.
docId() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the docId record component.
docId() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns the value of the docId record component.
docIdTooLong(int) - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
A derived or caller-supplied doc_id exceeds the storable maximum.
DocumentAcceptedExtractor() - Constructor for class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentAcceptedExtractor
 
DocumentDeleteEmitter - Class in ai.pipeline.connector.intake.pipedoc.streaming
Publishes the intake layer's broadcast DocumentDeleted signal to Kafka.
DocumentDeleteEmitter() - Constructor for class ai.pipeline.connector.intake.pipedoc.streaming.DocumentDeleteEmitter
 
DocumentErrorExtractor() - Constructor for class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentErrorExtractor
 
documentId - Variable in class ai.pipeline.connector.intake.entity.CrawlDocument
Repository document ID (UUID).
DocumentRejectedExtractor() - Constructor for class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentRejectedExtractor
 
documentsFailed - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Number of documents that failed processing.
documentsFound - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Number of documents found during crawl.
documentsProcessed - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Number of documents successfully processed.
documentsSkipped - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Number of documents skipped.

E

emitAccepted(DocumentAccepted) - Method in class ai.pipeline.connector.intake.event.IntakeEventProducer
 
emitError(DocumentError) - Method in class ai.pipeline.connector.intake.event.IntakeEventProducer
 
emitRejected(DocumentRejected) - Method in class ai.pipeline.connector.intake.event.IntakeEventProducer
 
endCrawlSession(EndCrawlSessionRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
endCrawlSession(EndCrawlSessionRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.session.CrawlSessionRpcService
Ends an existing crawl session.
enforce(SecurityScanTarget) - Method in class ai.pipeline.connector.intake.security.IntakeSecurityScanner
Throwing form for the HTTP and unary gRPC paths: a rejection becomes a client-safe HttpIntakeException.
EngineClient - Class in ai.pipeline.connector.intake.service
Builds engine intake handoff requests and sends them over the configured engine transport.
EngineClient() - Constructor for class ai.pipeline.connector.intake.service.EngineClient
Default constructor for CDI proxying.
enqueue(IntakeHandoffRequest, String) - Method in interface ai.pipeline.connector.intake.ingress.IntakeIngressProducer
 
enqueue(IntakeHandoffRequest, String) - Method in class ai.pipeline.connector.intake.ingress.RedisStreamIntakeIngressProducer
 
enqueueAndMaybePersist(PipeDoc, ConfigResolutionService.ResolvedConfig, String, long) - Method in class ai.pipeline.connector.intake.pipedoc.PipeDocAcceptanceService
Accepts a fully-hydrated inline PipeDoc into the configured handoff path.
EnqueueResult(String) - Constructor for record class ai.pipeline.connector.intake.ingress.IntakeIngressProducer.EnqueueResult
Creates an instance of a EnqueueResult record class.
equals(Object) - Method in class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
 
equals(Object) - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressProducer.EnqueueResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Indicates whether some other object is "equal to" this one.
error() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns the value of the error record component.
error(String, String, String, String, String, String, IntakeErrorCode, String) - Static method in class ai.pipeline.connector.intake.event.IntakeEvents
 
ERROR - Enum constant in enum class ai.pipeline.connector.intake.status.UploadState
Failed due to a server-side fault (5xx-class); see code/errorId.
errorId - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
Support-quotable trace id; set only for ERROR.
errorId() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns the value of the errorId record component.
errorId() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
Unique, traceable id for a server-fault occurrence; empty for client rejections.
errorId() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the errorId record component.
errorId() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the errorId record component.
errorReasonFor(IntakeErrorCode) - Static method in class ai.pipeline.connector.intake.event.IntakeEvents
Map the client-facing error taxonomy onto the proto error reason (5xx-class).
evaluate(SecurityScanTarget) - Method in class ai.pipeline.connector.intake.security.IntakeSecurityScanner
Decision form for the streaming path, which surfaces rejections in-band.
extractKey(DocumentAccepted) - Method in class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentAcceptedExtractor
 
extractKey(DocumentError) - Method in class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentErrorExtractor
 
extractKey(DocumentRejected) - Method in class ai.pipeline.connector.intake.event.IntakeEventKeyExtractors.DocumentRejectedExtractor
 

F

failed(String, String, String, String, String, IntakeErrorCode, String, String) - Method in class ai.pipeline.connector.intake.status.IntakeOutcomeRecorder
A failed upload, emitted as a lifecycle event so the consumer can project it into the status read-model.
FIELD_ACCEPTED_AT_MS - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_ACCOUNT_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_CRAWL_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_DATASOURCE_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_DOC_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_PAYLOAD_MODE - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_REQUEST - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_RETRY_COUNT - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_SCHEMA_VERSION - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_SOURCE_DOC_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
FIELD_STREAM_ID - Static variable in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
 
findByAccountId(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find all sessions for an account.
findByDatasourceAndCrawl(String, String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find a session by datasource ID and crawl ID.
findByDatasourceId(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find all sessions for a datasource.
findByDocId(String) - Method in class ai.pipeline.connector.intake.repository.UploadReceiptRepository
 
findByDocumentId(String) - Method in class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Find all tracked entries referencing the given repository document ID across sessions.
findById(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find a session by its unique identifier.
findBySessionAndSource(String, String) - Method in class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Find a tracked document by session and source ID.
findBySessionId(String) - Method in class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Find all tracked documents for a given session.
findByState(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find sessions by state.
findStaleSessions(OffsetDateTime) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Find running sessions whose last heartbeat is older than the cutoff time.
fromJson(String) - Static method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Parse a ConnectorMetadata instance from its JSON representation.
fromRedisFields(Map) - Static method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Reconstruct an envelope from a map of Redis Stream fields.
fromRequest(IntakeHandoffRequest, String) - Static method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Create an envelope from a gRPC request and source document ID.
fromUpstream(Throwable) - Static method in exception class ai.pipeline.connector.intake.error.IntakeServiceException
Translate any failure thrown while resolving config or proxying the upload into a client-safe intake error.
fromUpstreamHttpStatus(int) - Static method in exception class ai.pipeline.connector.intake.error.IntakeServiceException
Map a non-2xx HTTP status returned by repository-service to a client code, so the upstream's own error body is never forwarded to the caller.

G

generateApiKey() - Method in class ai.pipeline.connector.util.ApiKeyUtil
Generate a new secure random API key.
getDefaultMetadata() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Get default metadata applied to every stored document.
getMaxFileSize() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Get the maximum allowed file size for uploads.
getRateLimitPerMinute() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Get the allowed ingestion rate.
getS3BasePath() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Get the base path within the S3 bucket where documents are stored.
getS3Bucket() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Get the S3 bucket name used for storage.
getSession(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
getStatus(String) - Method in class ai.pipeline.connector.intake.http.UploadStatusResource
 
getUploadStatus(GetUploadStatusRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
getUploadStatus(GetUploadStatusRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.status.UploadStatusGrpcService
 
GrpcBlobUploadService - Class in ai.pipeline.connector.intake.pipedoc
Handles the unary UploadBlob RPC.
GrpcBlobUploadService() - Constructor for class ai.pipeline.connector.intake.pipedoc.GrpcBlobUploadService
 

H

handoffReferenceToEngine(String, String, String, String, IngestionConfig) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off a repository-staged document reference to engine without a crawl ID.
handoffReferenceToEngine(String, String, String, String, IngestionConfig, String) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off a repository-staged document reference to engine.
handoffToEngine(PipeDoc, String, String, IngestionConfig) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off an inline document through the streaming engine path without a crawl ID.
handoffToEngine(PipeDoc, String, String, IngestionConfig, String) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off an inline document through the streaming engine path.
handoffToEngineUnary(PipeDoc, String, String, IngestionConfig, String) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off an inline document to the engine through the legacy unary RPC.
hashApiKey(String) - Method in class ai.pipeline.connector.util.ApiKeyUtil
Hash an API key for secure storage.
hashCode() - Method in class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
 
hashCode() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressProducer.EnqueueResult
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns a hash code value for this object.
hashCode() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns a hash code value for this object.
heartbeat(HeartbeatRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
heartbeat(HeartbeatRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.session.CrawlSessionRpcService
Sends a heartbeat to keep a crawl session alive.
HttpIntakeException - Exception Class in ai.pipeline.connector.intake.error
A failure attributable to the HTTP request itself — a malformed shape, a missing header, an undeterminable document identity, or an oversized body.
httpStatus() - Method in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
httpStatus() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
 

I

id - Variable in class ai.pipeline.connector.intake.entity.CrawlDocument
Composite primary key.
id - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Unique session identifier (primary key).
incrementDocumentsFailed(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Increment the counter of documents that failed processing for the session.
incrementDocumentsFailed(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
incrementDocumentsFound(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Increment the counter of documents discovered for the session.
incrementDocumentsFound(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
incrementDocumentsProcessed(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Increment the counter of documents successfully processed for the session.
incrementDocumentsProcessed(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
incrementDocumentsSkipped(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Increment the counter of documents skipped (not processed) for the session.
incrementDocumentsSkipped(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
ingestionConfig() - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Returns the value of the ingestionConfig record component.
input - Variable in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
 
IntakeErrorCode - Enum Class in ai.pipeline.connector.intake.error
Stable, client-facing error taxonomy for the intake HTTP surface.
IntakeErrorResponse - Record Class in ai.pipeline.connector.intake.error
Uniform, client-safe error body.
IntakeErrorResponse(String, String, String, String, String) - Constructor for record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Creates an instance of a IntakeErrorResponse record class.
IntakeEventKeyExtractors - Class in ai.pipeline.connector.intake.event
UUID key extractors for the intake event types, auto-discovered by the quarkus-apicurio-registry-protobuf extension and used to key each record for Kafka partitioning + dedup.
IntakeEventKeyExtractors.DocumentAcceptedExtractor - Class in ai.pipeline.connector.intake.event
 
IntakeEventKeyExtractors.DocumentErrorExtractor - Class in ai.pipeline.connector.intake.event
 
IntakeEventKeyExtractors.DocumentRejectedExtractor - Class in ai.pipeline.connector.intake.event
 
IntakeEventProducer - Class in ai.pipeline.connector.intake.event
Publishes intake lifecycle events to Kafka via the platform's quarkus-apicurio-registry-protobuf extension: inject a typed ProtobufEmitter per channel and call send(event) — the extension handles protobuf serialization, the deterministic UUID key (via IntakeEventKeyExtractors), Apicurio schema registration, and topic wiring.
IntakeEventProducer() - Constructor for class ai.pipeline.connector.intake.event.IntakeEventProducer
 
IntakeEvents - Class in ai.pipeline.connector.intake.event
Builds the intake_events protos from upload context and maps the service's IntakeErrorCode taxonomy onto the proto's RejectionReason.
IntakeException - Exception Class in ai.pipeline.connector.intake.error
Base type for every failure the intake HTTP surface deliberately surfaces.
IntakeException(IntakeErrorCode, String, Throwable) - Constructor for exception class ai.pipeline.connector.intake.error.IntakeException
 
IntakeExceptionMapper - Class in ai.pipeline.connector.intake.error
Renders every IntakeException as a uniform, client-safe JSON envelope and guarantees the real cause is logged server-side, never serialized.
IntakeExceptionMapper() - Constructor for class ai.pipeline.connector.intake.error.IntakeExceptionMapper
 
IntakeExceptions - Class in ai.pipeline.connector.intake.error
Normalizes any failure into a client-safe IntakeException.
intakeHandoff(IntakeHandoffRequest) - Method in class ai.pipeline.connector.intake.service.EngineClient
Hands off one document to the engine.
intakeHandoff(IntakeHandoffRequest) - Method in class ai.pipeline.connector.intake.service.IntakeHandoffStreamClient
Sends one intake handoff over the lane.
IntakeHandoffStreamClient - Class in ai.pipeline.connector.intake.service
intake-service → engine streaming intake-handoff lane.
IntakeHandoffStreamClient() - Constructor for class ai.pipeline.connector.intake.service.IntakeHandoffStreamClient
 
intakeHandoffUnary(IntakeHandoffRequest) - Method in class ai.pipeline.connector.intake.service.EngineClient
Sends one already-built intake handoff request over the legacy unary engine RPC.
IntakeIngressEnvelope - Record Class in ai.pipeline.connector.intake.ingress
Redis Stream payload shared by connector-intake and the engine sidecar.
IntakeIngressEnvelope(IntakeHandoffRequest, String, String, String, String, String, String, String, String, int, long) - Constructor for record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Creates an instance of a IntakeIngressEnvelope record class.
IntakeIngressProducer - Interface in ai.pipeline.connector.intake.ingress
 
IntakeIngressProducer.EnqueueResult - Record Class in ai.pipeline.connector.intake.ingress
 
IntakeOutcomeRecorder - Class in ai.pipeline.connector.intake.status
Single place where an intake outcome is published.
IntakeOutcomeRecorder() - Constructor for class ai.pipeline.connector.intake.status.IntakeOutcomeRecorder
 
IntakeReceiptProjector - Class in ai.pipeline.connector.intake.event
Projects the intake lifecycle event streams — accepted, rejected, error — into the upload-receipt read-model that backs the status lookup.
IntakeReceiptProjector() - Constructor for class ai.pipeline.connector.intake.event.IntakeReceiptProjector
 
IntakeReplayPersister - Class in ai.pipeline.connector.intake.pipedoc
Fire-and-forget durable copy to the repository service for any document whose datasource is configured with persist_pipedoc=true.
IntakeReplayPersister() - Constructor for class ai.pipeline.connector.intake.pipedoc.IntakeReplayPersister
 
IntakeRepoEventConsumer - Class in ai.pipeline.connector.intake.service
Consumes IntakeRepoEvent messages and initiates intake handoff.
IntakeRepoEventConsumer() - Constructor for class ai.pipeline.connector.intake.service.IntakeRepoEventConsumer
 
IntakeSecurityScanner - Class in ai.pipeline.connector.intake.security
Pre-acceptance security screening for uploads.
IntakeSecurityScanner() - Constructor for class ai.pipeline.connector.intake.security.IntakeSecurityScanner
 
IntakeSecurityScanner.ScanVerdict - Record Class in ai.pipeline.connector.intake.security
Outcome of a security scan: allowed, or a client-safe rejection code + message.
IntakeServiceException - Exception Class in ai.pipeline.connector.intake.error
A failure that originates beyond the request shape — resolving datasource config, authenticating the API key, or proxying the body to repository-service.
IntakeServiceException(IntakeErrorCode, String, Throwable) - Constructor for exception class ai.pipeline.connector.intake.error.IntakeServiceException
 
interceptCall(ServerCall, Metadata, ServerCallHandler) - Method in class ai.pipeline.connector.intake.grpc.ApiKeyServerInterceptor
 
internal(String, Throwable) - Static method in exception class ai.pipeline.connector.intake.error.IntakeServiceException
An internal fault in the intake service itself (misconfig, bug, invariant break).
INTERNAL - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
INVALID_REQUEST - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
isError() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
true when this is a server-side error (5xx) rather than a client rejection (4xx).
issue(String, String, String) - Method in class ai.pipeline.connector.intake.token.UploadTrackingToken
Mint a token for an upload — issued on success and on failure once a doc_id is derived, since doc_id is deterministic and the client can poll any outcome (a retry lands on the same row).
issuedAt() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns the value of the issuedAt record component.

L

lastHeartbeat - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Timestamp of last heartbeat.
lookup(String) - Method in class ai.pipeline.connector.intake.status.UploadStatusService
 

M

MAX_DOC_ID_LENGTH - Static variable in class ai.pipeline.connector.intake.entity.UploadReceipt
Max storable doc_id length — matches the upload_receipts.doc_id column.
message - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
Client-safe human-readable summary for REJECTED/ERROR; never upstream/internal text.
message() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the message record component.
message() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Returns the value of the message record component.
message() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the message record component.
messageId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressProducer.EnqueueResult
Returns the value of the messageId record component.
metadata - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Crawl metadata as JSON.
method - Variable in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
 
mimeType() - Method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Returns the value of the mimeType record component.
missingHeader(String) - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
A required header was absent or blank.

N

names() - Method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Returns the value of the names record component.
NOT_FOUND - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
NOT_IMPLEMENTED - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 

O

of(IntakeErrorCode, Throwable) - Static method in exception class ai.pipeline.connector.intake.error.IntakeServiceException
A code with its default safe message, preserving the cause for logging.
of(String, String...) - Static method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
 
ofPipeDoc(PipeDoc) - Static method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Build a target from a PipeDoc: its blob filename + MIME, plus source path/URI.
onAccepted(Record) - Method in class ai.pipeline.connector.intake.event.IntakeReceiptProjector
 
onCompleted() - Method in class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
 
onError(Record) - Method in class ai.pipeline.connector.intake.event.IntakeReceiptProjector
 
onError(Throwable) - Method in class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
 
onNext(UploadPipeDocStreamRequest) - Method in class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
 
onRejected(Record) - Method in class ai.pipeline.connector.intake.event.IntakeReceiptProjector
 
open(StreamObserver) - Method in class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocUploadService
 

P

PAYLOAD_TOO_LARGE - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
payloadMode() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the payloadMode record component.
payloadTooLarge() - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
The declared or streamed body exceeds the permitted size.
PERMISSION_DENIED - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
persistAsync(PipeDoc, String, String, String) - Method in class ai.pipeline.connector.intake.pipedoc.IntakeReplayPersister
Schedule a fire-and-forget durable persist of pipeDoc to the repository service.
persistBlobAndHandoff(PipeDoc, ConfigResolutionService.ResolvedConfig, long, String) - Method in class ai.pipeline.connector.intake.pipedoc.BlobUploadHandoffService
Persist a blob and hand off the reference to the engine.
PipeDocAcceptanceService - Class in ai.pipeline.connector.intake.pipedoc
Per-doc acceptance for the gRPC upload paths (bidi and unary).
PipeDocAcceptanceService() - Constructor for class ai.pipeline.connector.intake.pipedoc.PipeDocAcceptanceService
 
PipeDocIdDeriver - Class in ai.pipeline.connector.intake.pipedoc
 
PipeDocIdDeriver() - Constructor for class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver
 
PipeDocIdDeriver.DocIdDerivationResult - Class in ai.pipeline.connector.intake.pipedoc
 
processedAt - Variable in class ai.pipeline.connector.intake.entity.CrawlDocument
Timestamp when document was processed.
projectAccepted(DocumentAccepted) - Method in class ai.pipeline.connector.intake.status.UploadStatusService
 
projectError(DocumentError) - Method in class ai.pipeline.connector.intake.status.UploadStatusService
 
projectRejected(DocumentRejected) - Method in class ai.pipeline.connector.intake.status.UploadStatusService
 
publish(DocumentDeleted) - Method in class ai.pipeline.connector.intake.pipedoc.streaming.DocumentDeleteEmitter
Publish one delete broadcast.

R

RATE_LIMITED - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
RawUploadResource - Class in ai.pipeline.connector.intake.http
HTTP endpoint for raw binary uploads from connectors (POST /uploads/raw).
RawUploadResource() - Constructor for class ai.pipeline.connector.intake.http.RawUploadResource
 
reasonFor(IntakeErrorCode) - Static method in class ai.pipeline.connector.intake.event.IntakeEvents
Map the client-facing error taxonomy onto the proto rejection reason (4xx-class).
RedisStreamIntakeIngressProducer - Class in ai.pipeline.connector.intake.ingress
 
RedisStreamIntakeIngressProducer() - Constructor for class ai.pipeline.connector.intake.ingress.RedisStreamIntakeIngressProducer
 
rejected() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
 
rejected(IntakeErrorCode, String) - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
A client rejection with an explicit code and curated message — used by policy/security checks (e.g.
rejected(String, String, String, String, String, IntakeErrorCode, String) - Static method in class ai.pipeline.connector.intake.event.IntakeEvents
 
REJECTED - Enum constant in enum class ai.pipeline.connector.intake.status.UploadState
Rejected at the boundary — the client's fault (4xx-class); see code.
RepositoryClient - Class in ai.pipeline.connector.intake.service
Client for repository-service integration.
RepositoryClient() - Constructor for class ai.pipeline.connector.intake.service.RepositoryClient
 
RepositoryUploadClient - Class in ai.pipeline.connector.intake.http
Synchronous HTTP client for proxying raw uploads to repository-service.
RepositoryUploadClient() - Constructor for class ai.pipeline.connector.intake.http.RepositoryUploadClient
 
RepositoryUploadClient.RepositoryUploadResponse - Record Class in ai.pipeline.connector.intake.http
 
RepositoryUploadResponse(int, String, String) - Constructor for record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Creates an instance of a RepositoryUploadResponse record class.
RepositoryUploadRestClient - Interface in ai.pipeline.connector.intake.http
Declarative REST client for proxying raw uploads to repository-service.
request() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the request record component.
requestId() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns the value of the requestId record component.
requestId() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns the value of the requestId record component.
requestNext() - Method in class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
 
resolve(UploadTokenClaims) - Method in class ai.pipeline.connector.intake.status.UploadStatusService
Resolve the status a signed token points at.
resolveConfig(String, String) - Method in class ai.pipeline.connector.intake.service.ConfigResolutionService
Resolve Tier 1 configuration for a datasource using its ID and API key.
ResolvedConfig(DataSourceConfig, IngestionConfig) - Constructor for record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Creates an instance of a ResolvedConfig record class.
retryCount() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the retryCount record component.

S

ScanVerdict(boolean, IntakeErrorCode, String) - Constructor for record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Creates an instance of a ScanVerdict record class.
schemaVersion() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the schemaVersion record component.
SecurityScanTarget - Record Class in ai.pipeline.connector.intake.security
What the intake security scan examines for one upload.
SecurityScanTarget(String, List) - Constructor for record class ai.pipeline.connector.intake.security.SecurityScanTarget
Creates an instance of a SecurityScanTarget record class.
SessionManager - Class in ai.pipeline.connector.intake.service
Service for managing crawl session lifecycle.
SessionManager() - Constructor for class ai.pipeline.connector.intake.service.SessionManager
 
setDefaultMetadata(Map) - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Set default metadata applied to every stored document.
setMaxFileSize(long) - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Set the maximum allowed file size for uploads.
setRateLimitPerMinute(long) - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Set the allowed ingestion rate.
setS3BasePath(String) - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Set the base path within the S3 bucket where documents are stored.
setS3Bucket(String) - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Set the S3 bucket name used for storage.
shouldPersist() - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Check if persistence is enabled for gRPC PipeDoc uploads.
sourceDocId - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
 
sourceDocId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the sourceDocId record component.
sourceId - Variable in class ai.pipeline.connector.intake.entity.CrawlDocument.CrawlDocumentId
Source-system unique identifier for the document (e.g., external ID or path).
sourceSystem - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Source system identifier.
startCrawlSession(StartCrawlSessionRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
startCrawlSession(StartCrawlSessionRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.session.CrawlSessionRpcService
Starts a new crawl session.
startedAt - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Timestamp when session started.
state - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Session state.
state - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
One of UploadState: ACCEPTED, REJECTED, ERROR.
state() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the state record component.
state() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the state record component.
status() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns the value of the status record component.
statusCode() - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Returns the value of the statusCode record component.
StatusResponse(String, String, String, String, String, String) - Constructor for record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Creates an instance of a StatusResponse record class.
StatusView(String, String, String, String, String, OffsetDateTime) - Constructor for record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Creates an instance of a StatusView record class.
storeDocument(String, String, String, String, String, byte[], Map) - Method in class ai.pipeline.connector.intake.service.RepositoryClient
 
streamId() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns the value of the streamId record component.
StreamingPipeDocObserver - Class in ai.pipeline.connector.intake.pipedoc.streaming
Serializes one bidi UploadPipeDocStream call onto a small mailbox.
StreamingPipeDocObserver(StreamObserver, ConfigResolutionService, PipeDocAcceptanceService, DocumentDeleteEmitter, IntakeOutcomeRecorder, String) - Constructor for class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
 
StreamingPipeDocUploadService - Class in ai.pipeline.connector.intake.pipedoc.streaming
 
StreamingPipeDocUploadService() - Constructor for class ai.pipeline.connector.intake.pipedoc.streaming.StreamingPipeDocUploadService
 

T

tier1Config() - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Returns the value of the tier1Config record component.
toIntake(Throwable) - Static method in class ai.pipeline.connector.intake.error.IntakeExceptions
Returns t if it is already an IntakeException (preserving its code), otherwise classifies it via IntakeServiceException.fromUpstream(Throwable).
toJson() - Method in class ai.pipeline.connector.intake.util.ConnectorMetadata
Convert this metadata object to its JSON representation.
token() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns the value of the token record component.
token() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns the value of the token record component.
toProto() - Method in class ai.pipeline.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
 
toRedisFields() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Convert the envelope to a map of strings for storage in Redis Stream.
toResponse(IntakeException) - Method in class ai.pipeline.connector.intake.error.IntakeExceptionMapper
 
toString() - Method in record class ai.pipeline.connector.intake.error.IntakeErrorResponse
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressEnvelope
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.ingress.IntakeIngressProducer.EnqueueResult
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.security.IntakeSecurityScanner.ScanVerdict
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.security.SecurityScanTarget
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns a string representation of this record class.
toString() - Method in record class ai.pipeline.connector.intake.token.UploadTokenClaims
Returns a string representation of this record class.
trackDocument(String, String, String) - Method in class ai.pipeline.connector.intake.repository.CrawlDocumentRepository
Track a document in a session.
trackDocuments - Variable in class ai.pipeline.connector.intake.entity.CrawlSession
Whether to track documents for orphan detection.
trackingToken() - Method in exception class ai.pipeline.connector.intake.error.IntakeException
The status-tracking token, or empty when no doc_id was derivable before the failure.

U

UnaryPipeDocUploadService - Class in ai.pipeline.connector.intake.pipedoc
Handles the unary UploadPipeDoc RPC.
UnaryPipeDocUploadService() - Constructor for class ai.pipeline.connector.intake.pipedoc.UnaryPipeDocUploadService
 
UNAUTHENTICATED - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
undeterminableDocId() - Static method in exception class ai.pipeline.connector.intake.error.HttpIntakeException
None of the identity-bearing headers were sufficient to derive a doc_id.
UNPROCESSABLE - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
UNSUPPORTED_MEDIA_TYPE - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
updatedAt - Variable in class ai.pipeline.connector.intake.entity.UploadReceipt
 
updatedAt() - Method in record class ai.pipeline.connector.intake.http.UploadStatusResource.StatusResponse
Returns the value of the updatedAt record component.
updatedAt() - Method in record class ai.pipeline.connector.intake.status.UploadStatusService.StatusView
Returns the value of the updatedAt record component.
updateHeartbeat(String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Update the last heartbeat timestamp for a session to the current time.
updateHeartbeat(String) - Method in class ai.pipeline.connector.intake.service.SessionManager
 
updateState(String, String) - Method in class ai.pipeline.connector.intake.repository.CrawlSessionRepository
Update the persisted state for a session.
UploadAcceptedResponse - Record Class in ai.pipeline.connector.intake.http
Accepted-upload response body.
UploadAcceptedResponse(String, String, String, String) - Constructor for record class ai.pipeline.connector.intake.http.UploadAcceptedResponse
Creates an instance of a UploadAcceptedResponse record class.
uploadBlob(UploadBlobRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.pipedoc.GrpcBlobUploadService
 
uploadBlob(UploadBlobRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
uploadPipeDoc(UploadPipeDocRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.pipedoc.UnaryPipeDocUploadService
 
uploadPipeDoc(UploadPipeDocRequest, StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
uploadPipeDocStream(StreamObserver) - Method in class ai.pipeline.connector.intake.service.ConnectorIntakeServiceImpl
 
uploadRaw(InputStream, long, int, Map) - Method in class ai.pipeline.connector.intake.http.RepositoryUploadClient
Forwards the raw upload to repository-service synchronously.
uploadRaw(InputStream, Long, String, String, String, String, String, String, String, String, String, String, String, String) - Method in class ai.pipeline.connector.intake.http.RawUploadResource
Synchronous proxy of a raw upload to repository-service.
uploadRaw(InputStream, String, long, String, String, String, String, String, String, String, String, String, String) - Method in interface ai.pipeline.connector.intake.http.RepositoryUploadRestClient
 
UploadReceipt - Class in ai.pipeline.connector.intake.entity
Per-document intake status, keyed by doc_id.
UploadReceipt() - Constructor for class ai.pipeline.connector.intake.entity.UploadReceipt
 
UploadReceiptRepository - Class in ai.pipeline.connector.intake.repository
Repository for UploadReceipt, keyed by doc_id.
UploadReceiptRepository() - Constructor for class ai.pipeline.connector.intake.repository.UploadReceiptRepository
 
UploadState - Enum Class in ai.pipeline.connector.intake.status
Intake outcome for a document, as recorded on an UploadReceipt and reported by the status lookup.
UploadStatusGrpcService - Class in ai.pipeline.connector.intake.status
gRPC handler for GetUploadStatus — the parity of GET /uploads/status/{token}.
UploadStatusGrpcService() - Constructor for class ai.pipeline.connector.intake.status.UploadStatusGrpcService
 
UploadStatusResource - Class in ai.pipeline.connector.intake.http
Status lookup for an upload, addressed by the opaque tracking token returned at upload time (GET /uploads/status/{token}).
UploadStatusResource() - Constructor for class ai.pipeline.connector.intake.http.UploadStatusResource
 
UploadStatusResource.StatusResponse - Record Class in ai.pipeline.connector.intake.http
Client-safe status projection — only curated fields, never internal detail.
UploadStatusService - Class in ai.pipeline.connector.intake.status
Projects the intake lifecycle event stream — DocumentAccepted, DocumentRejected, DocumentError — into the UploadReceipt read-model (upsert by doc_id) and resolves it for the status lookup.
UploadStatusService() - Constructor for class ai.pipeline.connector.intake.status.UploadStatusService
 
UploadStatusService.StatusView - Record Class in ai.pipeline.connector.intake.status
Client-safe status projection shared by the HTTP and gRPC status surfaces.
UploadTokenClaims - Record Class in ai.pipeline.connector.intake.token
The tenant-scoped identity carried inside an UploadTrackingToken.
UploadTokenClaims(String, String, String, long) - Constructor for record class ai.pipeline.connector.intake.token.UploadTokenClaims
Creates an instance of a UploadTokenClaims record class.
UploadTrackingToken - Class in ai.pipeline.connector.intake.token
Mints and verifies the opaque, HMAC-SHA256-signed tracking token returned from every upload.
UploadTrackingToken(String, ObjectMapper) - Constructor for class ai.pipeline.connector.intake.token.UploadTrackingToken
 
UPSTREAM_ERROR - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
UPSTREAM_TIMEOUT - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
UPSTREAM_UNAVAILABLE - Enum constant in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
 
UriCanonicalizer - Class in ai.pipeline.connector.intake.util
Utility for canonicalizing URIs to create stable document IDs.
UriCanonicalizer() - Constructor for class ai.pipeline.connector.intake.util.UriCanonicalizer
 

V

validateDataSource(String, String) - Method in class ai.pipeline.connector.intake.service.ConnectorValidationService
Validate a datasource's API key and fetch its configuration.
valueOf(String) - Static method in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipeline.connector.intake.status.UploadState
Returns the enum constant of this class with the specified name.
values() - Static method in enum class ai.pipeline.connector.intake.error.IntakeErrorCode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class ai.pipeline.connector.intake.status.UploadState
Returns an array containing the constants of this enum class, in the order they are declared.
verify(String) - Method in class ai.pipeline.connector.intake.token.UploadTrackingToken
Verify a token's signature and return its claims.
verifyApiKey(String, String) - Method in class ai.pipeline.connector.util.ApiKeyUtil
Verify an API key against a stored hash.

W

withIngressMode(IngressMode) - Method in record class ai.pipeline.connector.intake.service.ConfigResolutionService.ResolvedConfig
Get a copy of ingestionConfig with the specified ingress mode.
withTrackingToken(String) - Method in exception class ai.pipeline.connector.intake.error.IntakeException
Attach the status-tracking token (when a doc_id was derived).
A B C D E F G H I L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form