Index (connector-intake-service 0.1.8 API)

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

B

badRequest(String) - Static method in exception class ai.pipestream.connector.intake.error.HttpIntakeException: Generic malformed request with an explicit, safe explanation.
BlobUploadHandoffService - Class in ai.pipestream.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.pipestream.connector.intake.pipedoc.BlobUploadHandoffService: Default constructor for CDI proxying.
body() - Method in record class ai.pipestream.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse: Returns the value of the body record component.
buildHandoffRequest(PipeDoc, String, String, IngestionConfig, String) - Static method in class ai.pipestream.connector.intake.service.EngineClient: Build an IntakeHandoffRequest for an inline document.
buildReferenceRequest(String, String, String, String, IngestionConfig, String) - Method in class ai.pipestream.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.pipestream.connector.intake.entity.CrawlSession: Total bytes processed.

C

callWithApiKey(String, Callable) - Static method in class ai.pipestream.connector.intake.grpc.ApiKeyServerInterceptor: Run body with apiKey bound as the call credential.
canonicalInput - Variable in class ai.pipestream.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult: Human-readable canonical source (pre-hash) for provenance/observability.
canonicalizeUri(String) - Static method in class ai.pipestream.connector.intake.util.UriCanonicalizer: Canonicalizes a URI, keeping query parameters.
canonicalizeUri(String, boolean) - Static method in class ai.pipestream.connector.intake.util.UriCanonicalizer: Transforms a source URI into a canonical ID string.
chunkSizeCalculator() - Method in class ai.pipestream.connector.intake.config.ChunkSizeCalculatorProducer: Produces a default ChunkSizeCalculator instance.
ChunkSizeCalculatorProducer - Class in ai.pipestream.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.pipestream.connector.intake.config.ChunkSizeCalculatorProducer: Default constructor for CDI proxying.
clientFacingMessage() - Method in exception class ai.pipestream.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.pipestream.connector.intake.error.IntakeException: Safe, client-facing message.
code - Variable in class ai.pipestream.connector.intake.entity.UploadReceipt: Client-safe outcome code for REJECTED/ERROR (e.g.
code() - Method in record class ai.pipestream.connector.intake.error.IntakeErrorResponse: Returns the value of the code record component.
code() - Method in exception class ai.pipestream.connector.intake.error.IntakeException
code() - Method in record class ai.pipestream.connector.intake.http.UploadStatusResource.StatusResponse: Returns the value of the code record component.
code() - Method in record class ai.pipestream.connector.intake.security.IntakeSecurityScanner.ScanVerdict: Returns the value of the code record component.
code() - Method in record class ai.pipestream.connector.intake.status.UploadStatusService.StatusView: Returns the value of the code record component.
completedAt - Variable in class ai.pipestream.connector.intake.entity.CrawlSession: Timestamp when session completed.
completeSession(String, String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Mark a session as completed and set its terminal state.
completeSession(String, String) - Method in class ai.pipestream.connector.intake.service.SessionManager
ConfigResolutionService - Class in ai.pipestream.connector.intake.service: Service for resolving Tier 1 configuration for a datasource.
ConfigResolutionService() - Constructor for class ai.pipestream.connector.intake.service.ConfigResolutionService: Default constructor for CDI.
ConfigResolutionService.ResolvedConfig - Record Class in ai.pipestream.connector.intake.service: Resolved configuration containing Tier 1 config and base IngestionConfig.
CONFLICT - Enum constant in enum class ai.pipestream.connector.intake.error.IntakeErrorCode
ConnectorIntakeServiceImpl - Class in ai.pipestream.connector.intake.service: Thin gRPC adapter for connector intake endpoints.
ConnectorIntakeServiceImpl() - Constructor for class ai.pipestream.connector.intake.service.ConnectorIntakeServiceImpl: Default constructor for gRPC service instantiation.
ConnectorMetadata - Class in ai.pipestream.connector.intake.util: Utility class for parsing and serializing connector metadata JSON.
ConnectorMetadata() - Constructor for class ai.pipestream.connector.intake.util.ConnectorMetadata: Create an instance with safe defaults.
connectorType - Variable in class ai.pipestream.connector.intake.entity.CrawlSession: Connector type identifier.
ConnectorValidationService - Class in ai.pipestream.connector.intake.service: Service for validating connector API keys and fetching connector configuration.
ConnectorValidationService() - Constructor for class ai.pipestream.connector.intake.service.ConnectorValidationService: Default constructor for CDI.
consumeIntakeRepoEvents(Message) - Method in class ai.pipestream.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.pipestream.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse: Returns the value of the contentType record component.
CrawlDocument - Class in ai.pipestream.connector.intake.entity: Document tracking entity for orphan detection.
CrawlDocument() - Constructor for class ai.pipestream.connector.intake.entity.CrawlDocument: Default constructor for JPA.
CrawlDocument(String, String, String) - Constructor for class ai.pipestream.connector.intake.entity.CrawlDocument: Create a new crawl document tracking entry.
CrawlDocument.CrawlDocumentId - Class in ai.pipestream.connector.intake.entity: Composite primary key for CrawlDocument.
CrawlDocumentId() - Constructor for class ai.pipestream.connector.intake.entity.CrawlDocument.CrawlDocumentId: Default constructor for JPA.
CrawlDocumentId(String, String) - Constructor for class ai.pipestream.connector.intake.entity.CrawlDocument.CrawlDocumentId: Create a composite identifier.
CrawlDocumentRepository - Class in ai.pipestream.connector.intake.repository: Repository for crawl document tracking operations.
CrawlDocumentRepository() - Constructor for class ai.pipestream.connector.intake.repository.CrawlDocumentRepository: Default constructor for CDI.
crawlId - Variable in class ai.pipestream.connector.intake.entity.CrawlSession: Client-provided crawl ID.
crawlId - Variable in class ai.pipestream.connector.intake.entity.UploadReceipt
crawlId() - Method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Returns the value of the crawlId record component.
CrawlSession - Class in ai.pipestream.connector.intake.entity: Crawl session entity tracking document ingestion sessions.
CrawlSession() - Constructor for class ai.pipestream.connector.intake.entity.CrawlSession: Default constructor for JPA.
CrawlSession(String, String, String, String, String) - Constructor for class ai.pipestream.connector.intake.entity.CrawlSession: Create a new crawl session.
crawlSessionId - Variable in class ai.pipestream.connector.intake.entity.CrawlDocument.CrawlDocumentId: Crawl session identifier (UUID of the session that processed the document).
CrawlSessionRepository - Class in ai.pipestream.connector.intake.repository: Repository for crawl session operations.
CrawlSessionRepository() - Constructor for class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Default constructor for CDI.
CrawlSessionRpcService - Class in ai.pipestream.connector.intake.session: RPC service for managing crawl session lifecycle and heartbeats.
CrawlSessionRpcService() - Constructor for class ai.pipestream.connector.intake.session.CrawlSessionRpcService: Default constructor for CDI proxying.
createdAt - Variable in class ai.pipestream.connector.intake.entity.UploadReceipt
createSession(String, String, String, String, String, String, boolean, boolean) - Method in class ai.pipestream.connector.intake.service.SessionManager

D

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

E

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

F

failed(String, String, String, String, String, IntakeErrorCode, String, String) - Method in class ai.pipestream.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.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_ACCOUNT_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_CRAWL_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_DATASOURCE_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_DOC_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_PAYLOAD_MODE - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_REQUEST - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_RETRY_COUNT - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_SCHEMA_VERSION - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_SOURCE_DOC_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
FIELD_STREAM_ID - Static variable in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope
findByAccountId(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find all sessions for an account.
findByDatasourceAndCrawl(String, String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find a session by datasource ID and crawl ID.
findByDatasourceId(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find all sessions for a datasource.
findByDocId(String) - Method in class ai.pipestream.connector.intake.repository.UploadReceiptRepository
findByDocumentId(String) - Method in class ai.pipestream.connector.intake.repository.CrawlDocumentRepository: Find all tracked entries referencing the given repository document ID across sessions.
findById(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find a session by its unique identifier.
findBySessionAndSource(String, String) - Method in class ai.pipestream.connector.intake.repository.CrawlDocumentRepository: Find a tracked document by session and source ID.
findBySessionId(String) - Method in class ai.pipestream.connector.intake.repository.CrawlDocumentRepository: Find all tracked documents for a given session.
findByState(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find sessions by state.
findStaleSessions(OffsetDateTime) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Find running sessions whose last heartbeat is older than the cutoff time.
fromJson(String) - Static method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Parse a ConnectorMetadata instance from its JSON representation.
fromRedisFields(Map) - Static method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Reconstruct an envelope from a map of Redis Stream fields.
fromRequest(IntakeHandoffRequest, String) - Static method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Create an envelope from a gRPC request and source document ID.
fromUpstream(Throwable) - Static method in exception class ai.pipestream.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.pipestream.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.pipestream.connector.util.ApiKeyUtil: Generate a new secure random API key.
getDefaultMetadata() - Method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Get default metadata applied to every stored document.
getMaxFileSize() - Method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Get the maximum allowed file size for uploads.
getRateLimitPerMinute() - Method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Get the allowed ingestion rate.
getS3BasePath() - Method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Get the base path within the S3 bucket where documents are stored.
getS3Bucket() - Method in class ai.pipestream.connector.intake.util.ConnectorMetadata: Get the S3 bucket name used for storage.
getSession(String) - Method in class ai.pipestream.connector.intake.service.SessionManager
getStatus(String) - Method in class ai.pipestream.connector.intake.http.UploadStatusResource
getUploadStatus(GetUploadStatusRequest, StreamObserver) - Method in class ai.pipestream.connector.intake.service.ConnectorIntakeServiceImpl
getUploadStatus(GetUploadStatusRequest, StreamObserver) - Method in class ai.pipestream.connector.intake.status.UploadStatusGrpcService
GrpcBlobUploadService - Class in ai.pipestream.connector.intake.pipedoc: Handles the unary UploadBlob RPC.
GrpcBlobUploadService() - Constructor for class ai.pipestream.connector.intake.pipedoc.GrpcBlobUploadService

H

handoffReferenceToEngine(String, String, String, String, IngestionConfig) - Method in class ai.pipestream.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.pipestream.connector.intake.service.EngineClient: Hands off a repository-staged document reference to engine.
handoffToEngine(PipeDoc, String, String, IngestionConfig) - Method in class ai.pipestream.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.pipestream.connector.intake.service.EngineClient: Hands off an inline document through the streaming engine path.
handoffToEngineUnary(PipeDoc, String, String, IngestionConfig, String) - Method in class ai.pipestream.connector.intake.service.EngineClient: Hands off an inline document to the engine through the legacy unary RPC.
hashApiKey(String) - Method in class ai.pipestream.connector.util.ApiKeyUtil: Hash an API key for secure storage.
hashCode() - Method in class ai.pipestream.connector.intake.entity.CrawlDocument.CrawlDocumentId
hashCode() - Method in record class ai.pipestream.connector.intake.error.IntakeErrorResponse: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.http.UploadAcceptedResponse: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.http.UploadStatusResource.StatusResponse: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.ingress.IntakeIngressProducer.EnqueueResult: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.security.IntakeSecurityScanner.ScanVerdict: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.security.SecurityScanTarget: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.service.ConfigResolutionService.ResolvedConfig: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.status.UploadStatusService.StatusView: Returns a hash code value for this object.
hashCode() - Method in record class ai.pipestream.connector.intake.token.UploadTokenClaims: Returns a hash code value for this object.
heartbeat(HeartbeatRequest, StreamObserver) - Method in class ai.pipestream.connector.intake.service.ConnectorIntakeServiceImpl
heartbeat(HeartbeatRequest, StreamObserver) - Method in class ai.pipestream.connector.intake.session.CrawlSessionRpcService: Sends a heartbeat to keep a crawl session alive.
HttpIntakeException - Exception Class in ai.pipestream.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.pipestream.connector.intake.error.IntakeErrorCode
httpStatus() - Method in exception class ai.pipestream.connector.intake.error.IntakeException

I

id - Variable in class ai.pipestream.connector.intake.entity.CrawlDocument: Composite primary key.
id - Variable in class ai.pipestream.connector.intake.entity.CrawlSession: Unique session identifier (primary key).
incrementDocumentsFailed(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Increment the counter of documents that failed processing for the session.
incrementDocumentsFailed(String) - Method in class ai.pipestream.connector.intake.service.SessionManager
incrementDocumentsFound(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Increment the counter of documents discovered for the session.
incrementDocumentsFound(String) - Method in class ai.pipestream.connector.intake.service.SessionManager
incrementDocumentsProcessed(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Increment the counter of documents successfully processed for the session.
incrementDocumentsProcessed(String) - Method in class ai.pipestream.connector.intake.service.SessionManager
incrementDocumentsSkipped(String) - Method in class ai.pipestream.connector.intake.repository.CrawlSessionRepository: Increment the counter of documents skipped (not processed) for the session.
incrementDocumentsSkipped(String) - Method in class ai.pipestream.connector.intake.service.SessionManager
ingestionConfig() - Method in record class ai.pipestream.connector.intake.service.ConfigResolutionService.ResolvedConfig: Returns the value of the ingestionConfig record component.
input - Variable in class ai.pipestream.connector.intake.pipedoc.PipeDocIdDeriver.DocIdDerivationResult
INTAKE_ROLE - Static variable in class ai.pipestream.connector.intake.security.OidcBypassAugmentor: The single application role required by every secured intake endpoint.
IntakeErrorCode - Enum Class in ai.pipestream.connector.intake.error: Stable, client-facing error taxonomy for the intake HTTP surface.
IntakeErrorResponse - Record Class in ai.pipestream.connector.intake.error: Uniform, client-safe error body.
IntakeErrorResponse(String, String, String, String, String) - Constructor for record class ai.pipestream.connector.intake.error.IntakeErrorResponse: Creates an instance of a IntakeErrorResponse record class.
IntakeEventKeyExtractors - Class in ai.pipestream.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.pipestream.connector.intake.event
IntakeEventKeyExtractors.DocumentErrorExtractor - Class in ai.pipestream.connector.intake.event
IntakeEventKeyExtractors.DocumentRejectedExtractor - Class in ai.pipestream.connector.intake.event
IntakeEventProducer - Class in ai.pipestream.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.pipestream.connector.intake.event.IntakeEventProducer
IntakeEvents - Class in ai.pipestream.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.pipestream.connector.intake.error: Base type for every failure the intake HTTP surface deliberately surfaces.
IntakeException(IntakeErrorCode, String, Throwable) - Constructor for exception class ai.pipestream.connector.intake.error.IntakeException
IntakeExceptionMapper - Class in ai.pipestream.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.pipestream.connector.intake.error.IntakeExceptionMapper
IntakeExceptions - Class in ai.pipestream.connector.intake.error: Normalizes any failure into a client-safe IntakeException.
intakeHandoff(IntakeHandoffRequest) - Method in class ai.pipestream.connector.intake.service.EngineClient: Hands off one document to the engine.
intakeHandoff(IntakeHandoffRequest) - Method in class ai.pipestream.connector.intake.service.IntakeHandoffStreamClient: Sends one intake handoff over the lane.
IntakeHandoffStreamClient - Class in ai.pipestream.connector.intake.service: intake-service → engine streaming intake-handoff lane.
IntakeHandoffStreamClient() - Constructor for class ai.pipestream.connector.intake.service.IntakeHandoffStreamClient
intakeHandoffUnary(IntakeHandoffRequest) - Method in class ai.pipestream.connector.intake.service.EngineClient: Sends one already-built intake handoff request over the legacy unary engine RPC.
IntakeIngressEnvelope - Record Class in ai.pipestream.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.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Creates an instance of a IntakeIngressEnvelope record class.
IntakeIngressProducer - Interface in ai.pipestream.connector.intake.ingress
IntakeIngressProducer.EnqueueResult - Record Class in ai.pipestream.connector.intake.ingress
IntakeOutcomeRecorder - Class in ai.pipestream.connector.intake.status: Single place where an intake outcome is published.
IntakeOutcomeRecorder() - Constructor for class ai.pipestream.connector.intake.status.IntakeOutcomeRecorder
IntakeReceiptProjector - Class in ai.pipestream.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.pipestream.connector.intake.event.IntakeReceiptProjector
IntakeReplayPersister - Class in ai.pipestream.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.pipestream.connector.intake.pipedoc.IntakeReplayPersister
IntakeRepoEventConsumer - Class in ai.pipestream.connector.intake.service: Consumes IntakeRepoEvent messages and initiates intake handoff.
IntakeRepoEventConsumer() - Constructor for class ai.pipestream.connector.intake.service.IntakeRepoEventConsumer
IntakeSecurityScanner - Class in ai.pipestream.connector.intake.security: Pre-acceptance security screening for uploads.
IntakeSecurityScanner() - Constructor for class ai.pipestream.connector.intake.security.IntakeSecurityScanner
IntakeSecurityScanner.ScanVerdict - Record Class in ai.pipestream.connector.intake.security: Outcome of a security scan: allowed, or a client-safe rejection code + message.
IntakeServiceException - Exception Class in ai.pipestream.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.pipestream.connector.intake.error.IntakeServiceException
interceptCall(ServerCall, Metadata, ServerCallHandler) - Method in class ai.pipestream.connector.intake.grpc.ApiKeyServerInterceptor
internal(String, Throwable) - Static method in exception class ai.pipestream.connector.intake.error.IntakeServiceException: An internal fault in the intake service itself (misconfig, bug, invariant break).
INTERNAL - Enum constant in enum class ai.pipestream.connector.intake.error.IntakeErrorCode
INVALID_REQUEST - Enum constant in enum class ai.pipestream.connector.intake.error.IntakeErrorCode
isError() - Method in exception class ai.pipestream.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.pipestream.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.pipestream.connector.intake.token.UploadTokenClaims: Returns the value of the issuedAt record component.

L

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

M

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

N

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

O

of(IntakeErrorCode, Throwable) - Static method in exception class ai.pipestream.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.pipestream.connector.intake.security.SecurityScanTarget
ofPipeDoc(PipeDoc) - Static method in record class ai.pipestream.connector.intake.security.SecurityScanTarget: Build a target from a PipeDoc: its blob filename + MIME, plus source path/URI.
OidcBypassAugmentor - Class in ai.pipestream.connector.intake.security: Makes the intake security annotations (@RolesAllowed(INTAKE_ROLE) on the HTTP resources and the gRPC service) inert while OIDC is disabled, which is the default.
OidcBypassAugmentor() - Constructor for class ai.pipestream.connector.intake.security.OidcBypassAugmentor: CDI.
onAccepted(Record) - Method in class ai.pipestream.connector.intake.event.IntakeReceiptProjector
onCompleted() - Method in class ai.pipestream.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
onError(Record) - Method in class ai.pipestream.connector.intake.event.IntakeReceiptProjector
onError(Throwable) - Method in class ai.pipestream.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
onNext(UploadPipeDocStreamRequest) - Method in class ai.pipestream.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
onRejected(Record) - Method in class ai.pipestream.connector.intake.event.IntakeReceiptProjector
open(StreamObserver) - Method in class ai.pipestream.connector.intake.pipedoc.streaming.StreamingPipeDocUploadService

P

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

R

RATE_LIMITED - Enum constant in enum class ai.pipestream.connector.intake.error.IntakeErrorCode
RawUploadResource - Class in ai.pipestream.connector.intake.http: HTTP endpoint for raw binary uploads from connectors (POST /uploads/raw).
RawUploadResource() - Constructor for class ai.pipestream.connector.intake.http.RawUploadResource
reasonFor(IntakeErrorCode) - Static method in class ai.pipestream.connector.intake.event.IntakeEvents: Map the client-facing error taxonomy onto the proto rejection reason (4xx-class).
RedisStreamIntakeIngressProducer - Class in ai.pipestream.connector.intake.ingress
RedisStreamIntakeIngressProducer() - Constructor for class ai.pipestream.connector.intake.ingress.RedisStreamIntakeIngressProducer
rejected() - Method in record class ai.pipestream.connector.intake.security.IntakeSecurityScanner.ScanVerdict
rejected(IntakeErrorCode, String) - Static method in exception class ai.pipestream.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.pipestream.connector.intake.event.IntakeEvents
REJECTED - Enum constant in enum class ai.pipestream.connector.intake.status.UploadState: Rejected at the boundary — the client's fault (4xx-class); see code.
RepositoryClient - Class in ai.pipestream.connector.intake.service: Client for repository-service integration.
RepositoryClient() - Constructor for class ai.pipestream.connector.intake.service.RepositoryClient
RepositoryUploadClient - Class in ai.pipestream.connector.intake.http: Synchronous HTTP client for proxying raw uploads to repository-service.
RepositoryUploadClient() - Constructor for class ai.pipestream.connector.intake.http.RepositoryUploadClient
RepositoryUploadClient.RepositoryUploadResponse - Record Class in ai.pipestream.connector.intake.http
RepositoryUploadResponse(int, String, String) - Constructor for record class ai.pipestream.connector.intake.http.RepositoryUploadClient.RepositoryUploadResponse: Creates an instance of a RepositoryUploadResponse record class.
RepositoryUploadRestClient - Interface in ai.pipestream.connector.intake.http: Declarative REST client for proxying raw uploads to repository-service.
request() - Method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Returns the value of the request record component.
requestId() - Method in record class ai.pipestream.connector.intake.error.IntakeErrorResponse: Returns the value of the requestId record component.
requestId() - Method in record class ai.pipestream.connector.intake.http.UploadAcceptedResponse: Returns the value of the requestId record component.
requestNext() - Method in class ai.pipestream.connector.intake.pipedoc.streaming.StreamingPipeDocObserver
resolve(UploadTokenClaims) - Method in class ai.pipestream.connector.intake.status.UploadStatusService: Resolve the status a signed token points at.
resolveConfig(String, String) - Method in class ai.pipestream.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.pipestream.connector.intake.service.ConfigResolutionService.ResolvedConfig: Creates an instance of a ResolvedConfig record class.
retryCount() - Method in record class ai.pipestream.connector.intake.ingress.IntakeIngressEnvelope: Returns the value of the retryCount record component.

S

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

T

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

U

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

V

validateDataSource(String, String) - Method in class ai.pipestream.connector.intake.service.ConnectorValidationService: Validate a datasource's API key and fetch its configuration.
valueOf(String) - Static method in enum class ai.pipestream.connector.intake.error.IntakeErrorCode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class ai.pipestream.connector.intake.status.UploadState: Returns the enum constant of this class with the specified name.
values() - Static method in enum class ai.pipestream.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.pipestream.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.pipestream.connector.intake.token.UploadTrackingToken: Verify a token's signature and return its claims.
verifyApiKey(String, String) - Method in class ai.pipestream.connector.util.ApiKeyUtil: Verify an API key against a stored hash.

W

withIngressMode(IngressMode) - Method in record class ai.pipestream.connector.intake.service.ConfigResolutionService.ResolvedConfig: Get a copy of ingestionConfig with the specified ingress mode.
withTrackingToken(String) - Method in exception class ai.pipestream.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