tycho_common::storage

Trait EntryPointGateway

Source 
pub trait EntryPointGateway {
    // Required methods
    fn insert_entry_points<'life0, 'life1, 'async_trait>(
        &'life0 self,
        entry_points: &'life1 HashMap<ComponentId, HashSet<EntryPoint>>,
    ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn insert_entry_point_tracing_params<'life0, 'life1, 'async_trait>(
        &'life0 self,
        entry_points_params: &'life1 HashMap<EntryPointId, HashSet<(TracingParams, Option<ComponentId>)>>,
    ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_entry_points<'life0, 'life1, 'async_trait>(
        &'life0 self,
        filter: EntryPointFilter,
        pagination_params: Option<&'life1 PaginationParams>,
    ) -> Pin<Box<dyn Future<Output = Result<WithTotal<HashMap<ComponentId, HashSet<EntryPoint>>>, StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_entry_points_tracing_params<'life0, 'life1, 'async_trait>(
        &'life0 self,
        filter: EntryPointFilter,
        pagination_params: Option<&'life1 PaginationParams>,
    ) -> Pin<Box<dyn Future<Output = Result<WithTotal<HashMap<ComponentId, HashSet<EntryPointWithTracingParams>>>, StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn upsert_traced_entry_points<'life0, 'life1, 'async_trait>(
        &'life0 self,
        traced_entry_points: &'life1 [TracedEntryPoint],
    ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_traced_entry_points<'life0, 'life1, 'async_trait>(
        &'life0 self,
        entry_points: &'life1 HashSet<EntryPointId>,
    ) -> Pin<Box<dyn Future<Output = Result<HashMap<EntryPointId, HashMap<TracingParams, TracingResult>>, StorageError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods§

Source

fn insert_entry_points<'life0, 'life1, 'async_trait>( &'life0 self, entry_points: &'life1 HashMap<ComponentId, HashSet<EntryPoint>>, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Inserts a list of entry points into the database.

§Arguments
  • entry_points - The map of component ids to their entry points to insert.

Note: This function ignores conflicts on inserts.

Source

fn insert_entry_point_tracing_params<'life0, 'life1, 'async_trait>( &'life0 self, entry_points_params: &'life1 HashMap<EntryPointId, HashSet<(TracingParams, Option<ComponentId>)>>, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Inserts a list of entry points with their tracing params into the database.

§Arguments
  • entry_points_params - The map of entry points to their tracing params to insert and optionally a component id used for debugging only.

Note: This function ignores conflicts on inserts.

Source

fn get_entry_points<'life0, 'life1, 'async_trait>( &'life0 self, filter: EntryPointFilter, pagination_params: Option<&'life1 PaginationParams>, ) -> Pin<Box<dyn Future<Output = Result<WithTotal<HashMap<ComponentId, HashSet<EntryPoint>>>, StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves a map of component ids to a set of entry points from the database.

§Arguments
  • filter - The EntryPointFilter to apply to the query.
  • pagination_params - The pagination parameters to apply to the query, if None, all results are returned.
§Returns

A map of component ids to a set of entry points.

Source

fn get_entry_points_tracing_params<'life0, 'life1, 'async_trait>( &'life0 self, filter: EntryPointFilter, pagination_params: Option<&'life1 PaginationParams>, ) -> Pin<Box<dyn Future<Output = Result<WithTotal<HashMap<ComponentId, HashSet<EntryPointWithTracingParams>>>, StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves a map of component ids to a set of entry points with their tracing data from the database.

§Arguments
  • filter - The EntryPointFilter to apply to the query.
  • pagination_params - The pagination parameters to apply to the query, if None, all results are returned.
§Returns

A map of component ids to a set of entry points with their tracing params.

Source

fn upsert_traced_entry_points<'life0, 'life1, 'async_trait>( &'life0 self, traced_entry_points: &'life1 [TracedEntryPoint], ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Upserts a list of traced entry points into the database. Updates the result if it already exists for the same entry point and tracing params.

§Arguments
  • traced_entry_points - The list of traced entry points to upsert.
Source

fn get_traced_entry_points<'life0, 'life1, 'async_trait>( &'life0 self, entry_points: &'life1 HashSet<EntryPointId>, ) -> Pin<Box<dyn Future<Output = Result<HashMap<EntryPointId, HashMap<TracingParams, TracingResult>>, StorageError>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves all tracing results for a set of entry points from the database.

§Arguments
  • entry_points - The set of entry points to retrieve tracing results for.
§Returns

A map of entry point ids to a map of tracing params to tracing results.

Implementors§