Struct Database 

pub struct Database(/* private fields */);

Implementations

impl Database

pub async fn get_bucket_info( &self, id: &Uuid, ) -> Result<Option<BucketInfo>, Error>

Get bucket info by ID from the latest bucket_log entry

pub async fn list_buckets( &self, prefix: Option<String>, limit: Option<u32>, ) -> Result<Vec<BucketInfo>, Error>

List all buckets from the latest bucket_log entries

pub async fn get_bucket_logs( &self, bucket_id: &Uuid, page: u32, page_size: u32, ) -> Result<Vec<BucketLogEntry>, Error>

Get paginated bucket log entries for a specific bucket

pub async fn get_all_bucket_logs( &self, bucket_id: &Uuid, ) -> Result<Vec<BucketLogEntry>, Error>

Get all bucket log entries for a specific bucket (unpaginated, for tree view)

pub async fn get_bucket_log_count(&self, bucket_id: &Uuid) -> Result<i64, Error>

Get total count of log entries for a bucket

impl Database

pub async fn connect(database_url: &Url) -> Result<Self, DatabaseSetupError>

pub fn new(pool: SqlitePool) -> Self

Trait Implementations

impl AsRef<Database> for State

fn as_ref(&self) -> &Database

Converts this type into a shared reference of the (usually inferred) input type.

impl BucketLogProvider for Database

type Error = Error

fn exists<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

fn heads<'life0, 'async_trait>( &'life0 self, id: Uuid, height: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<Link>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Get the possible heads for a bucket based on passed height

fn append<'life0, 'async_trait>( &'life0 self, id: Uuid, name: String, current: Link, previous: Option<Link>, height: u64, published: bool, ) -> Pin<Box<dyn Future<Output = Result<(), BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Append a version of the bucket to the log

fn height<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<u64, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Return the greatest height of the bucket version within the chain

fn has<'life0, 'async_trait>( &'life0 self, id: Uuid, link: Link, ) -> Pin<Box<dyn Future<Output = Result<Vec<u64>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Check if a link exists within a bucket

fn list_buckets<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

List all bucket IDs that have log entries

fn latest_published<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<(Link, u64)>, BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Get the latest published version of a bucket

fn head<'life0, 'async_trait>( &'life0 self, id: Uuid, height: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<(Link, u64), BucketLogError<Self::Error>>> + Send + 'async_trait>>

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

Get the peers canonical head based on its log entries

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Database

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

Formats the value using the given formatter.

impl Deref for Database

type Target = Pool<Sqlite>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.