Struct DragonflyStore 

pub struct DragonflyStore { /* private fields */ }

Redis/DragonflyDB storage implementation.

Implementations

impl DragonflyStore

pub fn new(url: &str) -> Result<Self>

Create a new store with default configuration.

pub fn with_config(url: &str, config: StoreConfig) -> Result<Self>

Create a new store with custom configuration.

pub fn key_prefix(&self) -> &str

Get the key prefix for this store.

Trait Implementations

impl AdvisoryStore for DragonflyStore

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.

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.

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.