Package ai.pipeline.connector.intake.service

package ai.pipeline.connector.intake.service

Classes

Class	Description
ChunkAssembler	Service for assembling streaming chunks into complete documents.
ConnectorIntakeServiceImpl	gRPC service implementation for Connector-Intake.
ConnectorValidationService	Service for validating connector API keys and fetching connector configuration.
DocumentProcessor	Service for processing individual documents.
RepositoryClient	Client for repository-service integration.
SessionManager	Service for managing crawl session lifecycle.
StreamingChunkProcessor	Processor for handling streaming chunks from large file uploads.
StreamingChunkProcessor.ProcessingResult	Result of processing a chunk.
StreamingChunkProcessor.UploadResult	Upload result containing metadata about the uploaded file.