Method new_with_path

graphlite/src/txn/wal.rs:395–428

Create a new persistent WAL instance with a specific path This is the internal method that requires a path. All WAL instances must be associated with a database directory to ensure proper data organization.

(db_path: PathBuf)

    /// This is the internal method that requires a path. All WAL instances must be
    /// associated with a database directory to ensure proper data organization.
    pub fn new_with_path(db_path: PathBuf) -> Result<Self, WALError> {
        let wal_dir = db_path.join("wal");

        // Create WAL directory if it doesn't exist
        create_dir_all(&wal_dir)
            .map_err(|e| WALError::IOError(format!("Failed to create WAL directory: {}", e)))?;

        // Create catalog WAL directory
        let catalog_wal_dir = wal_dir.join("catalog");
        create_dir_all(&catalog_wal_dir).map_err(|e| {
            WALError::IOError(format!("Failed to create catalog WAL directory: {}", e))
        })?;

        let catalog_wal = CatalogWAL {
            catalog_wal_dir,
            writer: Arc::new(Mutex::new(None)),
            file_number: Arc::new(Mutex::new(0)),
        };

        let mut wal = Self {
            wal_dir,
            current_writer: Arc::new(Mutex::new(None)),
            current_file_number: Arc::new(Mutex::new(0)),
            global_sequence: Arc::new(Mutex::new(0)),
            current_file_path: Arc::new(Mutex::new(None)),
            current_file_size: Arc::new(Mutex::new(0)),
            catalog_wal: Some(Arc::new(catalog_wal)),
        };

        // Initialize WAL by finding the latest file and sequence numbers
        wal.initialize()?;

        Ok(wal)
    }

    /// Initialize WAL by scanning existing files
    fn initialize(&mut self) -> Result<(), WALError> {