Enum ExternalDB 

pub enum ExternalDB {
    SqliteLocal(SqliteLocal),
}

Variants

SqliteLocal(SqliteLocal)

Implementations

impl ExternalDB

pub async fn build( ext_db: AveExternalDBFeatureConfig, durability: bool, manager: ActorRef<DBManager>, spec: Option<MachineSpec>, ) -> Result<Self, DatabaseError>

pub fn get_subject(&self) -> impl Subscriber<Ledger>

pub fn get_sink_data(&self) -> impl Subscriber<SinkDataEvent>

pub fn get_request_tracking(&self) -> impl Subscriber<RequestTrackingEvent>

pub fn get_register(&self) -> impl Subscriber<RegisterEvent>

pub fn metrics_snapshot(&self) -> DbMetricsSnapshot

pub fn register_prometheus_metrics(&self, registry: &mut Registry)

pub async fn delete_subject( &self, subject_id: &str, ) -> Result<(), DatabaseError>

pub async fn shutdown(&self) -> Result<(), DatabaseError>

Trait Implementations

impl Clone for ExternalDB

fn clone(&self) -> ExternalDB

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ReadStore for ExternalDB

fn get_aborts<'life0, 'life1, 'async_trait>( &'life0 self, subject_id: &'life1 str, query: AbortsQuery, ) -> Pin<Box<dyn Future<Output = Result<PaginatorAborts, DatabaseError>> + Send + 'async_trait>>

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

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

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

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, subject_id: &'life1 str, query: EventsQuery, ) -> Pin<Box<dyn Future<Output = Result<PaginatorEvents, DatabaseError>> + Send + 'async_trait>>

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

fn get_event_sn<'life0, 'life1, 'async_trait>( &'life0 self, subject_id: &'life1 str, sn: u64, ) -> Pin<Box<dyn Future<Output = Result<LedgerDB, DatabaseError>> + Send + 'async_trait>>

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

fn get_first_or_end_events<'life0, 'life1, 'async_trait>( &'life0 self, subject_id: &'life1 str, quantity: Option<u64>, reverse: Option<bool>, event_type: Option<EventRequestType>, ) -> Pin<Box<dyn Future<Output = Result<Vec<LedgerDB>, DatabaseError>> + Send + 'async_trait>>

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

fn get_governances<'life0, 'async_trait>( &'life0 self, active: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<Vec<GovsData>, DatabaseError>> + Send + 'async_trait>>

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

fn get_subjects<'life0, 'life1, 'async_trait>( &'life0 self, governance_id: &'life1 str, active: Option<bool>, schema_id: Option<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<SubjsData>, DatabaseError>> + Send + 'async_trait>>

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