Struct VersionManager 

pub struct VersionManager<T: Versionable> { /* private fields */ }

Implementations

impl<T: Versionable> VersionManager<T>

pub fn new(oracle: Arc<TimestampOracle>) -> Self

새로운 VersionManager를 생성합니다.

Arguments

• oracle - 타임스탬프 오라클 (선택적)

pub fn new_without_oracle() -> Self

타임스탬프 오라클 없이 VersionManager를 생성합니다.

이 경우 타임스탬프는 외부에서 직접 관리해야 합니다.

pub fn add_version( &self, key: Vec<u8>, value: T, commit_ts: u64, ) -> DbxResult<()>

새로운 버전을 추가합니다.

Arguments

• key - 버전 키 (동일한 엔티티의 여러 버전을 식별)
• value - 저장할 값
• commit_ts - 커밋 타임스탬프

Returns

성공 시 Ok(()), 실패 시 에러

pub fn get_at_snapshot(&self, key: &[u8], read_ts: u64) -> DbxResult<Option<T>>

특정 스냅샷 시점의 버전을 조회합니다.

Arguments

• key - 조회할 키
• read_ts - 읽기 타임스탬프 (스냅샷 시점)

Returns

• Ok(Some(value)) - 해당 시점에 보이는 값이 존재
• Ok(None) - 해당 시점에 보이는 값이 없음
• Err(_) - 에러 발생

pub fn collect_garbage(&self, min_active_ts: u64) -> DbxResult<usize>

가비지 컬렉션을 수행합니다.

min_active_ts보다 오래된 버전 중 최신 버전이 아닌 것들을 삭제합니다. 각 키당 최소 1개의 버전은 유지합니다.

Arguments

• min_active_ts - 최소 활성 타임스탬프 (이보다 오래된 버전은 GC 대상)

Returns

삭제된 버전의 개수

pub fn version_count(&self, key: &[u8]) -> DbxResult<usize>

특정 키의 모든 버전 개수를 반환합니다.

pub fn key_count(&self) -> DbxResult<usize>

전체 키 개수를 반환합니다.

pub fn total_version_count(&self) -> DbxResult<usize>

전체 버전 개수를 반환합니다.

Trait Implementations

impl<T: Clone + Versionable> Clone for VersionManager<T>

fn clone(&self) -> VersionManager<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.