Struct BackfillConfig 

pub struct BackfillConfig {
    pub batch_size: usize,
    pub max_concurrent: usize,
    pub dual_write: bool,
    pub target_query_threshold: f64,
    pub rollback_window_secs: u64,
}

Configuration for the backfill coordinator.

Controls batch sizing, concurrency, dual-write behavior, and the threshold at which queries switch to the target model.

Example

use lattice_embed::backfill::BackfillConfig;

let config = BackfillConfig {
    batch_size: 200,
    max_concurrent: 8,
    dual_write: true,
    target_query_threshold: 0.9,
    rollback_window_secs: 3600, // 1 hour
};

assert_eq!(config.batch_size, 200);

Fields

batch_size: usize

Batch size for backfill operations.

max_concurrent: usize

Maximum concurrent backfill batches.

dual_write: bool

Whether new documents should be dual-written during migration.

target_query_threshold: f64

Minimum progress fraction before allowing target-only queries [0.0, 1.0].

When the migration progress reaches this threshold, query routing switches from legacy to target embeddings.

rollback_window_secs: u64

Duration in seconds to continue dual-writing after cutover.

During the rollback window, queries use the new target model but writes continue to both models. This ensures atoms created after cutover exist in both indexes, enabling instant rollback without data loss.

Default: 86400 seconds (24 hours).

Trait Implementations

impl Clone for BackfillConfig

fn clone(&self) -> BackfillConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackfillConfig

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

Formats the value using the given formatter.

impl Default for BackfillConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for BackfillConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for BackfillConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.