Package ai.pipeline.connector.intake.service

package ai.pipeline.connector.intake.service

Class	Description
ConfigResolutionService	Service for resolving Tier 1 configuration for a datasource.
ConfigResolutionService.ResolvedConfig	Resolved configuration containing Tier 1 config and base IngestionConfig.
ConnectorIntakeServiceImpl	Thin gRPC adapter for connector intake endpoints.
ConnectorValidationService	Service for validating connector API keys and fetching connector configuration.
EngineClient	Builds engine intake handoff requests and sends them over the configured engine transport.
IntakeHandoffStreamClient	intake-service → engine streaming intake-handoff lane.
IntakeRepoEventConsumer	Consumes IntakeRepoEvent messages and initiates intake handoff.
RepositoryClient	Client for repository-service integration.
SessionManager	Service for managing crawl session lifecycle.