Struct EllaContext

pub struct EllaContext { /* private fields */ }

Implementations

impl EllaContext

pub fn new(state: EllaState) -> Result<Self>

pub fn use_catalog<'a>(self, catalog: impl Into<Id<'a>>) -> Result<Self>

pub fn use_schema<'a>(self, schema: impl Into<Id<'a>>) -> Result<Self>

pub async fn query(&self, sql: impl AsRef<str>) -> Result<Lazy>

pub async fn execute(&self, sql: &str) -> Result<()>

pub async fn create_topic<'a>( &self, table: impl Into<TableRef<'a>>, info: impl Into<TopicInfo>, if_not_exists: bool, or_replace: bool, ) -> Result<Arc<EllaTopic>>

pub async fn create_view<'a>( &self, table: impl Into<TableRef<'a>>, info: impl Into<ViewInfo>, if_not_exists: bool, or_replace: bool, ) -> Result<Arc<EllaView>>

pub async fn create_table<'a>( &self, table: impl Into<TableRef<'a>>, info: impl Into<TableInfo>, if_not_exists: bool, or_replace: bool, ) -> Result<Arc<EllaTable>>

pub async fn create_schema<'a>( &self, schema: impl Into<SchemaRef<'a>>, if_not_exists: bool, ) -> Result<Arc<EllaSchema>>

pub async fn create_catalog<'a>( &self, catalog: impl Into<Id<'a>>, if_not_exists: bool, ) -> Result<Arc<EllaCatalog>>

pub fn table<'a>( &self, table: impl Into<TableRef<'a>>, ) -> Option<Arc<EllaTable>>

pub async fn shutdown(self) -> Result<()>

pub fn config(&self) -> &EllaConfig

pub fn cluster(&self) -> &Arc<EllaCluster>

pub fn default_catalog(&self) -> &Id<'static>

pub fn default_schema(&self) -> &Id<'static>

pub fn state(&self) -> &EllaState

Trait Implementations

impl Clone for EllaContext

fn clone(&self) -> EllaContext

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for EllaContext

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

Formats the value using the given formatter.