Struct EmbeddingRoutingConfig 

pub struct EmbeddingRoutingConfig {
    pub query_model: EmbeddingModel,
    pub write_models: Vec<EmbeddingModel>,
    pub phase: RoutingPhase,
    pub migration_id: Option<String>,
}

Configuration for embedding request routing.

Separates query routing from write routing to enable true rollback. During the rollback window after cutover, queries use the new model but writes continue to both models, ensuring atoms created after cutover are present in both indexes.

Example

use lattice_embed::backfill::{EmbeddingRoutingConfig, RoutingPhase};
use lattice_embed::EmbeddingModel;

let config = EmbeddingRoutingConfig {
    query_model: EmbeddingModel::BgeBaseEnV15,
    write_models: vec![EmbeddingModel::BgeSmallEnV15, EmbeddingModel::BgeBaseEnV15],
    phase: RoutingPhase::RollbackWindow,
    migration_id: Some("mig-001".to_string()),
};

assert!(config.write_models.len() > 1); // dual-write active

Fields

query_model: EmbeddingModel

Which model to query against.

write_models: Vec<EmbeddingModel>

Which models to write to (may be multiple for dual-write).

phase: RoutingPhase

Current routing phase.

migration_id: Option<String>

Migration ID if in migration/rollback phase.

Trait Implementations

impl Clone for EmbeddingRoutingConfig

fn clone(&self) -> EmbeddingRoutingConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EmbeddingRoutingConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EmbeddingRoutingConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EmbeddingRoutingConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.