npm install @reaatech/hybrid-rag-pipeline
# or
pnpm add @reaatech/hybrid-rag-pipeline

import { RAGPipeline } from '@reaatech/hybrid-rag-pipeline';
import { ChunkingStrategy } from '@reaatech/hybrid-rag';
 
const pipeline = new RAGPipeline({
  qdrantUrl: process.env.QDRANT_URL || 'http://localhost:6333',
  collectionName: 'knowledge-base',
 
  embeddingProvider: 'openai',
  embeddingModel: 'text-embedding-3-small',
  embeddingApiKey: process.env.OPENAI_API_KEY,
 
  chunkingStrategy: ChunkingStrategy.FIXED_SIZE,
  chunkSize: 512,
  chunkOverlap: 50,
 
  useHybrid: true,
  vectorWeight: 0.7,
  bm25Weight: 0.3,
  fusionStrategy: 'rrf',
 
  rerankerProvider: 'cohere',
  rerankerApiKey: process.env.COHERE_API_KEY,
  rerankTopK: 20,
  rerankFinalK: 10,
 
  topK: 10,
});
 
await pipeline.initialize();
 
// Ingest
const chunks = await pipeline.ingest([
  { id: 'doc-1', content: 'Password reset requires email verification...' },
  { id: 'doc-2', content: 'Refund policy: requests must be submitted within 14 days...' },
]);
 
// Query
const results = await pipeline.query('How do I reset my password?', {
  topK: 5,
  useReranker: true,
  filter: { department: 'engineering' },
});
 
for (const r of results) {
  console.log(`[${r.score.toFixed(3)}] ${r.content.substring(0, 80)}...`);
}
 
// Stats
const stats = await pipeline.getStats();
console.log(`Collection: ${stats.collectionName}, Docs: ${stats.totalDocuments}, Chunks: ${stats.totalChunks}`);
 
// Cleanup
await pipeline.close();

new RAGPipeline(config: RAGPipelineConfig)

const results = await pipeline.query('query', {
  retrievalMode: 'vector',
  topK: 10,
});

const pipeline = new RAGPipeline({
  qdrantUrl: process.env.QDRANT_URL,
  rerankerProvider: null, // skip reranker entirely
});
 
const results = await pipeline.query('query', { topK: 10 });

const results = await pipeline.query('API rate limits', {
  filter: {
    department: 'engineering',
    status: 'published',
    version: 'v2',
  },
});