Struct ColumnUpsertRequest 

pub struct ColumnUpsertRequest {
    pub ids: Vec<String>,
    pub vectors: Vec<Vec<f32>>,
    pub attributes: HashMap<String, Vec<Value>>,
    pub ttl_seconds: Option<u64>,
    pub dimension: Option<usize>,
}

Column-based upsert request (Turbopuffer-inspired)

This format is more efficient for bulk upserts as it avoids repeating field names for each vector. All arrays must have equal length.

Example

use dakera_client::ColumnUpsertRequest;
use std::collections::HashMap;

let request = ColumnUpsertRequest::new(
    vec!["id1".to_string(), "id2".to_string()],
    vec![vec![0.1, 0.2, 0.3], vec![0.4, 0.5, 0.6]],
);

Fields

ids: Vec<String>

Array of vector IDs (required)

vectors: Vec<Vec<f32>>

Array of vectors (required for vector namespaces)

attributes: HashMap<String, Vec<Value>>

Additional attributes as columns (optional) Each key is an attribute name, value is array of attribute values

ttl_seconds: Option<u64>

TTL in seconds for all vectors (optional)

dimension: Option<usize>

Expected dimension (optional, for validation)

Implementations

impl ColumnUpsertRequest

pub fn new(ids: Vec<String>, vectors: Vec<Vec<f32>>) -> Self

Create a new column upsert request

pub fn with_attribute(self, name: impl Into<String>, values: Vec<Value>) -> Self

Add an attribute column

pub fn with_ttl(self, seconds: u64) -> Self

Set TTL for all vectors

pub fn with_dimension(self, dim: usize) -> Self

Set expected dimension for validation

pub fn len(&self) -> usize

Get the number of vectors in this request

pub fn is_empty(&self) -> bool

Check if the request is empty

Trait Implementations

impl Clone for ColumnUpsertRequest

fn clone(&self) -> ColumnUpsertRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ColumnUpsertRequest

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ColumnUpsertRequest

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ColumnUpsertRequest

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

where __S: Serializer,

Serialize this value into the given Serde serializer.