diff --git a/src/indexer/index_writer.rs b/src/indexer/index_writer.rs index f3dfe6f7d..5eec4443d 100644 --- a/src/indexer/index_writer.rs +++ b/src/indexer/index_writer.rs @@ -605,7 +605,7 @@ impl IndexWriter { /// It is also possible to add a payload to the `commit` /// using this API. /// See [`PreparedCommit::set_payload()`](PreparedCommit.html) - pub fn prepare_commit(&mut self) -> crate::Result { + pub(crate) fn prepare_commit(&mut self) -> crate::Result { // Here, because we join all of the worker threads, // all of the segment update for this commit have been // sent. diff --git a/src/indexer/mod.rs b/src/indexer/mod.rs index c2505c738..8b5250f7c 100644 --- a/src/indexer/mod.rs +++ b/src/indexer/mod.rs @@ -23,7 +23,7 @@ pub use self::index_writer::IndexWriter; pub use self::log_merge_policy::LogMergePolicy; pub use self::merge_operation::MergeOperation; pub use self::merge_policy::{MergeCandidate, MergePolicy, NoMergePolicy}; -pub use self::prepared_commit::PreparedCommit; +pub(crate) use self::prepared_commit::PreparedCommit; pub use self::segment_entry::SegmentEntry; pub use self::segment_manager::SegmentManager; pub use self::segment_serializer::SegmentSerializer; diff --git a/src/indexer/prepared_commit.rs b/src/indexer/prepared_commit.rs index dad89710b..b8fc78a87 100644 --- a/src/indexer/prepared_commit.rs +++ b/src/indexer/prepared_commit.rs @@ -3,7 +3,7 @@ use crate::Opstamp; use futures::executor::block_on; /// A prepared commit -pub struct PreparedCommit<'a> { +pub(crate) struct PreparedCommit<'a> { index_writer: &'a mut IndexWriter, payload: Option, opstamp: Opstamp, @@ -18,19 +18,19 @@ impl<'a> PreparedCommit<'a> { } } - pub fn opstamp(&self) -> Opstamp { + pub(crate) fn opstamp(&self) -> Opstamp { self.opstamp } - pub fn set_payload(&mut self, payload: &str) { + pub(crate) fn set_payload(&mut self, payload: &str) { self.payload = Some(payload.to_string()) } - pub fn abort(self) -> crate::Result { + pub(crate) fn abort(self) -> crate::Result { self.index_writer.rollback() } - pub fn commit(self) -> crate::Result { + pub(crate) fn commit(self) -> crate::Result { info!("committing {}", self.opstamp); let _ = block_on( self.index_writer diff --git a/src/lib.rs b/src/lib.rs index f1d14a5be..1cd236530 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -174,7 +174,6 @@ pub use crate::indexer::demuxer::*; pub use crate::indexer::merge_filtered_segments; pub use crate::indexer::merge_indices; pub use crate::indexer::operation::UserOperation; -pub use crate::indexer::prepared_commit::PreparedCommit; pub use crate::indexer::IndexWriter; pub use crate::postings::Postings; pub use crate::reader::LeasedItem;