Method new

src/models/collection.rs:151–310

(
        name: String,
        description: Option<String>,
        dense_vector_options: DenseVectorOptions,
        sparse_vector_options: SparseVectorOptions,
        tf_idf_options: TFIDFOptions,

impl Collection {
    #[allow(clippy::too_many_arguments)]
    pub fn new(
        name: String,
        description: Option<String>,
        dense_vector_options: DenseVectorOptions,
        sparse_vector_options: SparseVectorOptions,
        tf_idf_options: TFIDFOptions,
        key_value_options: KeyValueOptions,
        usv_options: USVOptions,
        metadata_schema: Option<MetadataSchema>,
        collection_config: CollectionConfig,
        store_raw_text: bool,
        lmdb: MetaDb,
        current_version: VersionNumber,
        vcs: VersionControl,
        ctx: &AppContext,
    ) -> Result<Arc<Self>, WaCustomError> {
        if name.is_empty() {
            return Err(WaCustomError::InvalidParams);
        }

        let collection_path: Arc<Path> = get_collections_path().join(&name).into();
        fs::create_dir_all(&collection_path).map_err(|e| WaCustomError::FsError(e.to_string()))?;

        let internal_to_external_map_dim_file = OpenOptions::new()
            .read(true)
            .write(true)
            .truncate(false)
            .create(true)
            .open(collection_path.join("itoe.dim"))
            .map_err(BufIoError::Io)?;

        let internal_to_external_map_dim_bufman =
            BufferManager::new(internal_to_external_map_dim_file, 8192).map_err(BufIoError::Io)?;

        let internal_to_external_map_data_bufmans = BufferManagerFactory::new(
            collection_path.clone(),
            |root, version: &VersionNumber| root.join(format!("itoe.{}.data", **version)),
            8192,
        );

        let external_to_internal_map_dim_file = OpenOptions::new()
            .read(true)
            .write(true)
            .truncate(false)
            .create(true)
            .open(collection_path.join("etoi.dim"))
            .map_err(BufIoError::Io)?;

        let external_to_internal_map_dim_bufman =
            BufferManager::new(external_to_internal_map_dim_file, 8192).map_err(BufIoError::Io)?;

        let external_to_internal_map_data_bufmans = BufferManagerFactory::new(
            collection_path.clone(),
            |root, version: &VersionNumber| root.join(format!("etoi.{}.data", **version)),
            8192,
        );

        let document_to_internals_map_dim_file = OpenOptions::new()