Trait AdvisoryStore 

pub trait AdvisoryStore: Send + Sync {
    // Required methods
    fn upsert_batch<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        advisories: &'life1 [Advisory],
        source: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn get<'life0, 'life1, 'async_trait>(
        &'life0 self,
        id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<Advisory>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_by_package<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        ecosystem: &'life1 str,
        package: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Advisory>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn last_sync<'life0, 'life1, 'async_trait>(
        &'life0 self,
        source: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn health_check<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<HealthStatus>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_by_package_stream<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        ecosystem: &'life1 str,
        package: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Advisory>> + Send + '_>>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn get_batch<'life0, 'life1, 'async_trait>(
        &'life0 self,
        ids: &'life1 [String],
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Advisory>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn store_enrichment<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        cve_id: &'life1 str,
        data: &'life2 EnrichmentData,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn get_enrichment<'life0, 'life1, 'async_trait>(
        &'life0 self,
        cve_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<EnrichmentData>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_enrichment_batch<'life0, 'life1, 'async_trait>(
        &'life0 self,
        cve_ids: &'life1 [String],
    ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, EnrichmentData)>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn update_sync_timestamp<'life0, 'life1, 'async_trait>(
        &'life0 self,
        source: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn reset_sync_timestamp<'life0, 'life1, 'async_trait>(
        &'life0 self,
        source: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn advisory_count<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn store_ossindex_cache<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        purl: &'life1 str,
        cache: &'life2 OssIndexCache,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn get_ossindex_cache<'life0, 'life1, 'async_trait>(
        &'life0 self,
        purl: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<OssIndexCache>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn invalidate_ossindex_cache<'life0, 'life1, 'async_trait>(
        &'life0 self,
        purl: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn invalidate_all_ossindex_cache<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Trait for advisory storage backends.

Required Methods

fn upsert_batch<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, advisories: &'life1 [Advisory], source: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Insert or update a batch of advisories.

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Advisory>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a single advisory by ID.

fn get_by_package<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ecosystem: &'life1 str, package: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Advisory>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get all advisories affecting a specific package.

fn last_sync<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the timestamp of the last sync for a source.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<HealthStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check the health of the store connection.

fn get_by_package_stream<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ecosystem: &'life1 str, package: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<Advisory>> + Send + '_>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Get advisories as a stream for memory-efficient processing.

fn get_batch<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<Vec<Advisory>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get multiple advisories by IDs in a batch.

fn store_enrichment<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, cve_id: &'life1 str, data: &'life2 EnrichmentData, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store enrichment data (EPSS/KEV) for a CVE.

fn get_enrichment<'life0, 'life1, 'async_trait>( &'life0 self, cve_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<EnrichmentData>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get enrichment data for a CVE.

fn get_enrichment_batch<'life0, 'life1, 'async_trait>( &'life0 self, cve_ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, EnrichmentData)>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get enrichment data for multiple CVEs.

fn update_sync_timestamp<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Update the last sync timestamp for a source.

fn reset_sync_timestamp<'life0, 'life1, 'async_trait>( &'life0 self, source: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reset (delete) the sync timestamp for a source, forcing a full re-sync.

fn advisory_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the count of stored advisories.

fn store_ossindex_cache<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, purl: &'life1 str, cache: &'life2 OssIndexCache, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Store an OSS Index component report in cache.

Arguments

• purl - The Package URL that was queried
• cache - The cached component report with metadata

fn get_ossindex_cache<'life0, 'life1, 'async_trait>( &'life0 self, purl: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<OssIndexCache>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get a cached OSS Index component report.

Returns None if not cached or if the cache has expired.

fn invalidate_ossindex_cache<'life0, 'life1, 'async_trait>( &'life0 self, purl: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Invalidate (delete) a cached OSS Index component report.

fn invalidate_all_ossindex_cache<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Invalidate all OSS Index cache entries.

Implementors

impl AdvisoryStore for DragonflyStore