ingestion_service.go