Struct SealedSegment

pub struct SealedSegment<F> { /* private fields */ }

an immutable, wal segment

Implementations

impl<F> SealedSegment<F>

pub fn empty(f: F) -> Self

impl<F: FileExt> SealedSegment<F>

pub fn open( file: Arc<F>, path: PathBuf, read_locks: Arc<AtomicU64>, now: DateTime<Utc>, ) -> Result<Option<Self>>

pub fn path(&self) -> &Path

pub fn read_page_offset(&self, offset: u32, buf: &mut [u8]) -> Result<()>

pub fn read_frame_offset(&self, offset: u32, frame: &mut Frame) -> Result<()>

impl<F> SealedSegment<F>

pub fn header(&self) -> &SegmentHeader

pub async fn read_page_offset_async<B>( &self, offset: u32, buf: B, ) -> (B, Result<()>)

where B: IoBufMut + Send + 'static, F: FileExt,

Trait Implementations

impl<F> Clone for SealedSegment<F>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<F: Debug> Debug for SealedSegment<F>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<F> Deref for SealedSegment<F>

type Target = SealedSegmentInner<F>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<F> Segment for SealedSegment<F>

where F: FileExt,

async fn compact(&self, out_file: &impl FileExt, id: Uuid) -> Result<Vec<u8>>

fn start_frame_no(&self) -> u64

fn last_committed(&self) -> u64

fn index(&self) -> &Map<Arc<[u8]>>

fn read_page( &self, page_no: u32, max_frame_no: u64, buf: &mut [u8], ) -> Result<bool>

fn is_checkpointable(&self) -> bool

returns the number of readers currently holding a reference to this log. The read count must monotonically decrease.

fn size_after(&self) -> u32

The size of the database after applying this segment.

async fn read_frame_offset_async<B>( &self, offset: u32, buf: B, ) -> (B, Result<()>)

where B: IoBufMut + Send + 'static,

fn destroy<IO: Io>(&self, io: &IO) -> impl Future<Output = ()>

fn timestamp(&self) -> DateTime<Utc>