fixup! Add edge crate

ffuugoo · ffuugoo · commit 68d72503f2b6 · 2025-09-25T16:24:57.000+02:00
Create appendable segment when loading/initializing edge shard
diff --git a/lib/edge/src/lib.rs b/lib/edge/src/lib.rs
@@ -6,6 +6,7 @@ use std::{fmt, fs};
 
 use common::counter::hardware_accumulator::HwMeasurementAcc;
 use common::counter::hardware_counter::HardwareCounterCell;
+use common::save_on_disk::SaveOnDisk;
 use parking_lot::Mutex;
 use segment::common::operation_error::{OperationError, OperationResult};
 use segment::data_types::query_context::QueryContext;
@@ -125,6 +126,31 @@ impl Shard {
             segments.add_new(segment);
         }
 
+        if !segments.has_appendable_segment() {
+            let Some(config) = &config else {
+                return Err(OperationError::service_error(
+                    "segment config is not provided and no segments were loaded",
+                ));
+            };
+
+            let payload_index_schema_path = path.join("payload_index.json");
+            let payload_index_schema = SaveOnDisk::load_or_init_default(&payload_index_schema_path)
+                .map_err(|err| {
+                    OperationError::service_error(format!(
+                        "failed to initialize temporary payload index schema file {}: {err}",
+                        payload_index_schema_path.display(),
+                    ))
+                })?;
+
+            segments.create_appendable_segment(
+                &segments_path,
+                config.clone(),
+                Arc::new(payload_index_schema),
+            )?;
+
+            debug_assert!(segments.has_appendable_segment());
+        }
+
         let shard = Self {
             _path: path.into(),
             config: config.expect("config was provided or at least one segment was loaded"),
diff --git a/lib/segment/src/types.rs b/lib/segment/src/types.rs
@@ -1619,6 +1619,7 @@ impl VectorDataConfig {
 fn is_opt_compatible<T, F: Fn(T, T) -> bool>(this: Option<T>, other: Option<T>, check: F) -> bool {
     match (this, other) {
         (Some(this), Some(other)) => check(this, other),
+        (None, None) => true,
         _ => false,
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -1619,6 +1619,7 @@ impl VectorDataConfig {`
`1619`	`1619`	`fn is_opt_compatible<T, F: Fn(T, T) -> bool>(this: Option<T>, other: Option<T>, check: F) -> bool {`
`1620`	`1620`	`match (this, other) {`
`1621`	`1621`	`(Some(this), Some(other)) => check(this, other),`
	`1622`	`+ (None, None) => true,`
`1622`	`1623`	`_ => false,`
`1623`	`1624`	`}`
`1624`	`1625`	`}`