vecboost 0.2.1

High-performance embedding vector service written in Rust
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

// Copyright (c) 2025-2026 Kirky.X
//
// Licensed under the MIT License
// See LICENSE file in the project root for full license information

//! 请求流水线模块
//!
//! 实现请求流水线处理，包括优先级队列、动态 Worker 管理等

pub mod config;
// handler 依赖 axum::Json，仅在 http feature 下编译
#[cfg(feature = "http")]
pub(crate) mod handler;
mod priority;
mod queue;
mod response_channel;
mod scheduler;
mod worker;

pub use config::{PipelineConfig, PriorityConfig, QueueConfig, WorkerConfig};
#[cfg(feature = "http")]
pub use handler::handle_pipeline_request;
pub use priority::{Priority, PriorityCalculator, PriorityInput, RequestSource};
pub use queue::{PriorityRequestQueue, QueuedRequest};
pub use response_channel::ResponseChannel;
pub use scheduler::PipelineScheduler;
pub use worker::WorkerManager;