diff --git a/src/indexer/index_writer.rs b/src/indexer/index_writer.rs index 1ba92d6de..4ce5e1db5 100644 --- a/src/indexer/index_writer.rs +++ b/src/indexer/index_writer.rs @@ -128,7 +128,7 @@ fn compute_deleted_bitset( /// is `==` target_opstamp. /// For instance, there was no delete operation between the state of the `segment_entry` and /// the `target_opstamp`, `segment_entry` is not updated. -pub(crate) fn advance_deletes( +pub fn advance_deletes( mut segment: Segment, segment_entry: &mut SegmentEntry, target_opstamp: Opstamp, diff --git a/src/indexer/mod.rs b/src/indexer/mod.rs index ee53bdc7a..a6d3cab38 100644 --- a/src/indexer/mod.rs +++ b/src/indexer/mod.rs @@ -4,7 +4,7 @@ //! `IndexWriter` is the main entry point for that, which created from //! [`Index::writer`](crate::Index::writer). -pub(crate) mod delete_queue; +pub mod delete_queue; pub(crate) mod path_to_unordered_id; pub(crate) mod doc_id_mapping; @@ -32,11 +32,11 @@ mod stamper; use crossbeam_channel as channel; use smallvec::SmallVec; -pub use self::index_writer::{IndexWriter, IndexWriterOptions}; +pub use self::index_writer::{advance_deletes, IndexWriter, IndexWriterOptions}; pub use self::log_merge_policy::LogMergePolicy; pub use self::merge_operation::MergeOperation; pub use self::merge_policy::{MergeCandidate, MergePolicy, NoMergePolicy}; -pub use self::operation::{AddOperation, UserOperation}; +pub use self::operation::{AddOperation, DeleteOperation, UserOperation}; pub use self::prepared_commit::PreparedCommit; pub use self::segment_entry::SegmentEntry; pub(crate) use self::segment_serializer::SegmentSerializer;