Struct DuckdbBackend 

pub struct DuckdbBackend { /* private fields */ }

A backend that uses DuckDB to query stac-geoparquet.

Implementations

impl DuckdbBackend

pub async fn new(href: impl ToString) -> Result<DuckdbBackend>

Creates a new DuckDB backend pointing to a single stac-geoparquet file.

Examples

use stac_server::DuckdbBackend;
let backend = DuckdbBackend::new("data/100-sentinel-2-items.parquet").await.unwrap();

Trait Implementations

impl Backend for DuckdbBackend

fn has_item_search(&self) -> bool

Returns true if this backend has item search capabilities.

fn has_filter(&self) -> bool

Returns true if this backend has filter capabilities.

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 CollectionsClient for DuckdbBackend

type Error = Error

The error type for this client.

async fn collections(&self) -> Result<Vec<Collection>>

Returns all collections.

async fn collection(&self, id: &str) -> Result<Option<Collection>>

Returns a single collection by ID.

impl Debug for DuckdbBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ItemsClient for DuckdbBackend

type Error = Error

The error type for this client.

async fn search(&self, search: Search) -> Result<ItemCollection>

Searches for STAC items matching the given parameters.

fn item( &self, collection_id: &str, item_id: &str, ) -> impl Future<Output = Result<Option<Item>, Self::Error>> + Send

where Self::Error: From<Error>,

Returns a single item from a collection.

fn items( &self, collection_id: &str, items: Items, ) -> impl Future<Output = Result<ItemCollection, Self::Error>> + Send

Returns items from a collection.

impl StreamItemsClient for DuckdbBackend

type Error = Error

The error type for this client.

async fn search_stream( &self, search: Search, ) -> Result<impl Stream<Item = Result<Item, Error>> + Send>

Searches for STAC items, returning a stream of items.

fn collect_items( &self, search: Search, ) -> impl Future<Output = Result<Vec<Map<String, Value>>, Self::Error>> + Send

Collects all items from all pages into a Vec.

fn item_count( &self, search: Search, ) -> impl Future<Output = Result<usize, Self::Error>> + Send

Counts all items across all pages without collecting them.

fn items_stream( &self, collection_id: &str, items: Items, ) -> impl Future<Output = Result<impl Stream<Item = Result<Map<String, Value>, Self::Error>> + Send, Self::Error>> + Send

Streams all items belonging to a collection, paginating through all pages.

impl TransactionClient for DuckdbBackend

type Error = Error

The error type for this client.

async fn add_collection(&mut self, _collection: Collection) -> Result<()>

Adds a collection.

async fn add_item(&mut self, _item: Item) -> Result<()>

Adds a single item.

fn add_items( &mut self, items: Vec<Item>, ) -> impl Future<Output = Result<(), Self::Error>> + Send

Adds multiple items.