Struct AppendLog

pub struct AppendLog<ResourceAdaptor: LoadStore> {
    persisted_sync: Arc<RwLock<VersionSyncHandle>>,
    file_path: PathBuf,
    file_pattern: String,
    file_fill_size: u64,
    write_to_file: Option<File>,
    write_pos: u64,
    write_file_counter: u32,
    index_log: FixedAppendLog<StorageLocationLoadStore>,
    adaptor: ResourceAdaptor,
}

Fields

persisted_sync: Arc<RwLock<VersionSyncHandle>>

file_path: PathBuf

file_pattern: String

file_fill_size: u64

write_to_file: Option<File>

write_pos: u64

write_file_counter: u32

index_log: FixedAppendLog<StorageLocationLoadStore>

adaptor: ResourceAdaptor

Implementations

impl<ResourceAdaptor: LoadStore> AppendLog<ResourceAdaptor>

pub(crate) fn open_impl( loader: &mut AtomicStoreLoader, adaptor: ResourceAdaptor, location: Option<StorageLocation>, file_path: &Path, file_pattern: &str, file_fill_size: u64, ) -> Result<AppendLog<ResourceAdaptor>>

pub fn load( loader: &mut AtomicStoreLoader, adaptor: ResourceAdaptor, file_pattern: &str, file_fill_size: u64, ) -> Result<AppendLog<ResourceAdaptor>>

pub fn create( loader: &mut AtomicStoreLoader, adaptor: ResourceAdaptor, file_pattern: &str, file_fill_size: u64, ) -> Result<AppendLog<ResourceAdaptor>>

fn open_write_file(&mut self) -> Result<()>

pub fn store_resource( &mut self, resource: &ResourceAdaptor::ParamType, ) -> Result<StorageLocation>

pub fn commit_version(&mut self) -> Result<()>

pub fn skip_version(&mut self) -> Result<()>

pub fn revert_version(&mut self) -> Result<()>

pub fn load_latest(&self) -> Result<ResourceAdaptor::ParamType>

pub fn load_specified( &self, location: &StorageLocation, ) -> Result<ResourceAdaptor::ParamType>

pub fn iter(&self) -> Iter<'_, ResourceAdaptor>

Trait Implementations

impl<ResourceAdaptor: Debug + LoadStore> Debug for AppendLog<ResourceAdaptor>

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

Formats the value using the given formatter.