Struct Importer 

pub(crate) struct Importer {
    repo: Repo,
    remote: Option<String>,
    verify_text: Option<String>,
    xattrs: HashMap<String, Variant>,
    next_xattrs: Option<(String, String)>,
    buf: Vec<u8>,
    stats: ImportStats,
    data: ImporterMode,
}

Importer machine.

Fields

repo: Repo

remote: Option<String>

verify_text: Option<String>

xattrs: HashMap<String, Variant>

next_xattrs: Option<(String, String)>

buf: Vec<u8>

stats: ImportStats

data: ImporterMode

Additional state depending on whether we’re importing an object set or a commit.

Implementations

impl Importer

pub(crate) fn new_for_commit(repo: &Repo, remote: Option<String>) -> Self

Create an importer which will import an OSTree commit object.

pub(crate) fn new_for_object_set(repo: &Repo) -> Self

Create an importer to write an “object set”; a chunk of objects which is usually streamed from a separate storage system, such as an OCI container image layer.

fn filter_entry<R: Read>( e: Entry<'_, R>, ) -> Result<Option<(Entry<'_, R>, Utf8PathBuf)>>

pub(crate) fn parse_metadata_entry( path: &Utf8Path, ) -> Result<(String, ObjectType)>

fn import_metadata<R: Read>( &mut self, entry: Entry<'_, R>, checksum: &str, objtype: ObjectType, ) -> Result<()>

Import a metadata object.

fn import_large_regfile_object<R: Read>( &mut self, entry: Entry<'_, R>, size: usize, checksum: &str, xattrs: Variant, cancellable: Option<&Cancellable>, ) -> Result<()>

Import a content object, large regular file flavour.

fn import_small_regfile_object<R: Read>( &mut self, entry: Entry<'_, R>, size: usize, checksum: &str, xattrs: Variant, cancellable: Option<&Cancellable>, ) -> Result<()>

Import a content object, small regular file flavour.

fn import_symlink_object<R: Read>( &mut self, entry: Entry<'_, R>, checksum: &str, xattrs: Variant, ) -> Result<()>

Import a content object, symlink flavour.

fn import_content_object<R: Read>( &mut self, entry: Entry<'_, R>, checksum: &str, cancellable: Option<&Cancellable>, ) -> Result<()>

Import a content object.

fn import_object<R: Read>( &mut self, entry: Entry<'_, R>, path: &Utf8Path, cancellable: Option<&Cancellable>, ) -> Result<()>

Given a tar entry that looks like an object (its path is under ostree/repo/objects/), determine its type and import it.

fn process_file_xattrs( &mut self, entry: Entry<'_, impl Read>, checksum: String, ) -> Result<()>

Process a .file-xattrs object (v1).

fn process_file_xattrs_link( &mut self, entry: Entry<'_, impl Read>, checksum: String, ) -> Result<()>

Process a .file-xattrs-link object (v1).

This is an hardlink that contains extended attributes for a content object. When the max hardlink count is reached, this object may also be encoded as a regular file instead.

fn process_xattr_ref<R: Read>( &mut self, entry: Entry<'_, R>, target: String, ) -> Result<()>

Process a .file.xattrs entry (v0).

This is an hardlink that contains extended attributes for a content object.

fn process_split_xattrs_content<R: Read>( &mut self, entry: Entry<'_, R>, ) -> Result<()>

Process a special /xattrs/ entry, with checksum of xattrs content (v0).

fn cache_xattrs_content<R: Read>( &mut self, entry: Entry<'_, R>, expected_checksum: Option<String>, ) -> Result<String>

Read an xattrs entry and cache its content, optionally validating its checksum.

This returns the computed checksum for the successfully cached content.

fn import_objects_impl<'a>( &mut self, ents: impl Iterator<Item = Result<(Entry<'a, impl Read + Send + Unpin + 'a>, Utf8PathBuf)>>, cancellable: Option<&Cancellable>, ) -> Result<()>

pub(crate) fn import_objects( &mut self, archive: &mut Archive<impl Read + Send + Unpin>, cancellable: Option<&Cancellable>, ) -> Result<()>

pub(crate) fn import_commit( &mut self, archive: &mut Archive<impl Read + Send + Unpin>, cancellable: Option<&Cancellable>, ) -> Result<()>

pub(crate) fn finish_import_commit(self) -> (String, Option<String>)

pub(crate) fn default_dirmeta() -> Variant

pub(crate) fn finish_import_object_set(self) -> Result<String>