Struct tvix_castore::import::archive::IngestionEntryGraph

source ·
struct IngestionEntryGraph {
    graph: DiGraph<IngestionEntry, ()>,
    path_to_index: HashMap<PathBuf, NodeIndex>,
    root_node: Option<NodeIndex>,
}
Expand description

Keep track of the directory structure of a file tree being ingested. This is used for ingestion sources which do not provide any ordering or uniqueness guarantees like tarballs.

If we ingest multiple entries with the same paths and both entries are not directories, the newer entry will replace the latter entry, disconnecting the old node’s children from the graph.

Once all nodes are ingested a call to IngestionEntryGraph::finalize will return a list of entries compute by performaing a DFS post order traversal of the graph from the top-level directory entry.

This expects the directory structure to contain a single top-level directory entry. An error is returned if this is not the case and ingestion will fail.

Fields§

§graph: DiGraph<IngestionEntry, ()>§path_to_index: HashMap<PathBuf, NodeIndex>§root_node: Option<NodeIndex>

Implementations§

source§

impl IngestionEntryGraph

source

pub fn new() -> Self

Creates a new ingestion entry graph.

source

pub fn add(&mut self, entry: IngestionEntry) -> Result<NodeIndex, Error>

Adds a new entry to the graph. Parent directories are automatically inserted. If a node exists in the graph with the same name as the new entry and both the old and new nodes are not directories, the node is replaced and is disconnected from its children.

source

pub fn finalize(self) -> Result<Vec<IngestionEntry>, Error>

Traverses the graph in DFS post order and collects the entries into a Vec.

Unreachable parts of the graph are not included in the result.

source

fn replace_node(&mut self, index: NodeIndex, new_entry: IngestionEntry)

Replaces the node with the specified entry. The node’s children are disconnected.

This should never be called if both the old and new nodes are directories.

source

fn get_node(&self, index: NodeIndex) -> &IngestionEntry

Trait Implementations§

source§

impl Default for IngestionEntryGraph

source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> FutureExt for T

source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoRequest<T> for T

source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
source§

impl<T> Pointable for T

source§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

source§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more