Struct DuckDbBackend 

pub struct DuckDbBackend { /* private fields */ }

DuckDB-based storage backend for metrics.

Implementations

impl DuckDbBackend

pub fn new( connection_string: String, options: HashMap<String, String>, ttl: Option<u64>, ) -> Result<Self, Status>

Creates a new DuckDB backend instance.

pub fn new_in_memory() -> Result<Self, Status>

Creates a new DuckDB backend with an in-memory database.

Trait Implementations

impl CacheEviction for DuckDbBackend

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

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

Executes the eviction query in the background.

impl Clone for DuckDbBackend

fn clone(&self) -> DuckDbBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl StorageBackend for DuckDbBackend

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

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

Initialize the storage backend.

fn insert_metrics<'life0, 'async_trait>( &'life0 self, metrics: Vec<MetricRecord>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>

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

Insert metrics into storage.

fn query_metrics<'life0, 'async_trait>( &'life0 self, from_timestamp: i64, ) -> Pin<Box<dyn Future<Output = Result<Vec<MetricRecord>, Status>> + Send + 'async_trait>>

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

Query metrics from storage.

fn prepare_sql<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, Status>> + Send + 'async_trait>>

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

Prepare a SQL query and return a handle. The handle is backend-specific and opaque to the caller.

fn query_sql<'life0, 'life1, 'async_trait>( &'life0 self, statement_handle: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<Vec<MetricRecord>, Status>> + Send + 'async_trait>>

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

Execute a prepared SQL query using its handle. The handle must have been obtained from prepare_sql.

fn aggregate_metrics<'life0, 'life1, 'async_trait>( &'life0 self, function: AggregateFunction, group_by: &'life1 GroupBy, from_timestamp: i64, to_timestamp: Option<i64>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregateResult>, Status>> + Send + 'async_trait>>

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

Aggregate metrics using the specified function and grouping.

fn new_with_options( connection_string: &str, options: &HashMap<String, String>, credentials: Option<&Credentials>, ) -> Result<Self, Status>

Create a new instance with the given options. The connection string and options are backend-specific.

fn create_table<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, table_name: &'life1 str, schema: &'life2 Schema, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>

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

Create a new table with the given schema

fn insert_into_table<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, batch: RecordBatch, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>

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

Insert data into a table

fn query_table<'life0, 'life1, 'async_trait>( &'life0 self, table_name: &'life1 str, projection: Option<Vec<String>>, ) -> Pin<Box<dyn Future<Output = Result<RecordBatch, Status>> + Send + 'async_trait>>

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

Query data from a table

fn create_aggregation_view<'life0, 'life1, 'async_trait>( &'life0 self, view: &'life1 AggregationView, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>

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

Create an aggregation view

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

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

Query data from an aggregation view

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

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

Drop a table

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

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

Drop an aggregation view

fn table_manager(&self) -> &TableManager

Get the table manager instance

fn update_batch_aggregations<'life0, 'life1, 'async_trait>( &'life0 self, batch: &'life1 [MetricRecord], window: TimeWindow, ) -> Pin<Box<dyn Future<Output = Result<Vec<BatchAggregation>, Status>> + Send + 'async_trait>>

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

Update batch-level aggregations. This is called during batch writes to maintain running aggregations.

fn insert_batch_aggregations<'life0, 'async_trait>( &'life0 self, aggregations: Vec<BatchAggregation>, ) -> Pin<Box<dyn Future<Output = Result<(), Status>> + Send + 'async_trait>>

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

Insert batch-level aggregations. This is called after update_batch_aggregations to persist the aggregations.