Skip to main content

TypeDBRuntime

Struct TypeDBRuntime 

Source
pub struct TypeDBRuntime { /* private fields */ }
Expand description

Real TypeDB backend wrapping an internal band-tagged driver handle.

Implementations§

Source§

impl TypeDBRuntime

Source

pub fn force_close(&self) -> Result<()>

Make the selected driver terminal and dispatch upstream shutdown.

Bindings call this at their public connection-close boundary instead of relying on field drop ordering. While any transaction handle is retained, close returns resource_in_use and leaves the connection available. After those handles are released, the first call prevents new operations, invalidates in-flight work through upstream shutdown, and leaves the runtime permanently unavailable even if shutdown reports an error. A later call retries incomplete upstream dispatch without reopening the connection; calls after successful dispatch are harmless. Final callback-worker release remains lease-aware and occurs when the last driver handle drops.

Source§

impl TypeDBRuntime

Source

pub async fn connect( address: &str, username: &str, password: &str, options: ConnectOptions, ) -> Result<Self>

Connect to a TypeDB server.

Validates the supplied server version, or probes via HTTP before opening any gRPC connection when no version is supplied. Returns RuntimeError::UnsupportedVersion when the server is outside the supported window or on a different protocol band than the driver.

Source

pub async fn connect_secure( address: &str, username: &str, password: &str, options: SecureConnectOptions, ) -> SecureResult<Self>

Connect using an explicit typed TLS policy.

Custom trust material is validated before the HTTP version probe or any gRPC host is constructed. An enabled mode remains enabled through HTTP failure, driver-band discovery, and native-band upgrade.

Source

pub fn server_version(&self) -> Option<Version>

The server version detected by the connect gate, when known.

When this is None, callers must use the negotiated driver band rather than inferring a server version from a failed HTTP probe.

Source

pub fn supports_given_rows(&self) -> bool

Return whether the connection actually negotiated a driver that can transport given input rows.

This is deliberately separate from the reported server version. A 3.12 server may accept the band-8 discovery connection when a later band-9 upgrade fails; advertising given in that state would select an execution path the active driver cannot carry.

Source§

impl TypeDBRuntime

Source

pub fn open_transaction( &self, database: &str, tx_type: TxType, ) -> BoxFuture<'_, Result<RuntimeTransaction>>

Open a TypeDB transaction against database.

Source

pub fn open_transaction_with_timeout( &self, database: &str, tx_type: TxType, timeout: Duration, ) -> BoxFuture<'_, Result<RuntimeTransaction>>

Open a TypeDB transaction with an explicit server-side lifetime bound.

Higher layers use this for transactions that hold schema exclusion: a lost client must not leave the server-side fence unbounded while the transport is still detecting terminal closure.

Source

pub fn is_open(&self) -> bool

Check whether the underlying driver is open.

Source

pub fn database_exists(&self, database: &str) -> BoxFuture<'_, Result<bool>>

Check whether a database exists.

Source

pub fn create_database(&self, database: &str) -> BoxFuture<'_, Result<()>>

Create a database.

Source

pub fn delete_database(&self, database: &str) -> BoxFuture<'_, Result<()>>

Delete a database.

Source

pub fn schema_text(&self, database: &str) -> BoxFuture<'_, Result<String>>

Export a database schema as TypeQL text.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self> ⓘ

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more