Struct DirNamespace

pub struct DirNamespace { /* private fields */ }

Expand description

A namespace that resolves table names relative to a base directory or URI.

Implementations§

Create a new directory-backed namespace rooted at base_uri.

The URI is normalized so that it does not end with a trailing slash.

Return the normalized base URI.

Trait Implementations§

Returns a duplicate of the value. Read more

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

Return a human-readable unique identifier for this namespace instance. Read more

Describe a table.

List namespaces.

Describe a namespace.

Create a new namespace.

Drop a namespace.

Check if a namespace exists.

List tables in a namespace.

Register a table.

Check if a table exists.

Drop a table.

Deregister a table.

Count rows in a table.

Create a new table with data from Arrow IPC stream.

Create an empty table (metadata only operation).

Insert data into a table.

Merge insert data into a table.

Update a table.

Delete from a table.

Query a table.

Create a table index.

List table indices.

Describe table index statistics.

Describe a transaction.

Alter a transaction.

Auto Trait Implementations§

Blanket Implementations§

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

Returns the argument unchanged.

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

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

Calls U::from(self).

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

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

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

The alignment of pointer.

The type for initializers.

Initializes a with the given initializer. Read more

Dereferences the given pointer. Read more

Mutably dereferences the given pointer. Read more

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

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

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

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

DirNamespace

Struct DirNamespace Copy item path

Implementations§

impl DirNamespace

pub fn new(base_uri: impl Into<String>) -> Self

pub fn base_uri(&self) -> &str

Trait Implementations§

impl Clone for DirNamespace

fn clone(&self) -> DirNamespace

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

impl Debug for DirNamespace

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

impl LanceNamespace for DirNamespace

fn namespace_id(&self) -> String

fn describe_table<'life0, 'async_trait>( &'life0 self, request: DescribeTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTableResponse>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn list_namespaces<'life0, 'async_trait>( &'life0 self, _request: ListNamespacesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListNamespacesResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn describe_namespace<'life0, 'async_trait>( &'life0 self, _request: DescribeNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeNamespaceResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn create_namespace<'life0, 'async_trait>( &'life0 self, _request: CreateNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateNamespaceResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn drop_namespace<'life0, 'async_trait>( &'life0 self, _request: DropNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<DropNamespaceResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn namespace_exists<'life0, 'async_trait>( &'life0 self, _request: NamespaceExistsRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn list_tables<'life0, 'async_trait>( &'life0 self, _request: ListTablesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTablesResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn register_table<'life0, 'async_trait>( &'life0 self, _request: RegisterTableRequest, ) -> Pin<Box<dyn Future<Output = Result<RegisterTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn table_exists<'life0, 'async_trait>( &'life0 self, _request: TableExistsRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn drop_table<'life0, 'async_trait>( &'life0 self, _request: DropTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DropTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn deregister_table<'life0, 'async_trait>( &'life0 self, _request: DeregisterTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DeregisterTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn count_table_rows<'life0, 'async_trait>( &'life0 self, _request: CountTableRowsRequest, ) -> Pin<Box<dyn Future<Output = Result<i64, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn create_table<'life0, 'async_trait>( &'life0 self, _request: CreateTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<CreateTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn create_empty_table<'life0, 'async_trait>( &'life0 self, _request: CreateEmptyTableRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateEmptyTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn insert_into_table<'life0, 'async_trait>( &'life0 self, _request: InsertIntoTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<InsertIntoTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn merge_insert_into_table<'life0, 'async_trait>( &'life0 self, _request: MergeInsertIntoTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<MergeInsertIntoTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn update_table<'life0, 'async_trait>( &'life0 self, _request: UpdateTableRequest, ) -> Pin<Box<dyn Future<Output = Result<UpdateTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn delete_from_table<'life0, 'async_trait>( &'life0 self, _request: DeleteFromTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DeleteFromTableResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn query_table<'life0, 'async_trait>( &'life0 self, _request: QueryTableRequest, ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn create_table_index<'life0, 'async_trait>( &'life0 self, _request: CreateTableIndexRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateTableIndexResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn list_table_indices<'life0, 'async_trait>( &'life0 self, _request: ListTableIndicesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTableIndicesResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn describe_table_index_stats<'life0, 'async_trait>( &'life0 self, _request: DescribeTableIndexStatsRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTableIndexStatsResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn describe_transaction<'life0, 'async_trait>( &'life0 self, _request: DescribeTransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTransactionResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

fn alter_transaction<'life0, 'async_trait>( &'life0 self, _request: AlterTransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<AlterTransactionResponse, Error>> + Send + 'async_trait>>where 'life0: 'async_trait, Self: 'async_trait,

Auto Trait Implementations§

impl Freeze for DirNamespace

impl RefUnwindSafe for DirNamespace

impl Send for DirNamespace

impl Sync for DirNamespace

impl Unpin for DirNamespace

impl UnwindSafe for DirNamespace

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

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

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

impl<T> Pointable for T

const ALIGN: usize

type Init = T

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

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

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

unsafe fn drop(ptr: usize)

impl<T> PolicyExt for Twhere T: ?Sized,

fn and<P, B, E>(self, other: P) -> And<T, P>where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>where T: Policy<B, E>, P: Policy<B, E>,

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

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

type Error = Infallible

Struct DirNamespace

fn describe_table<'life0, 'async_trait>( &'life0 self, request: DescribeTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTableResponse>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

fn list_namespaces<'life0, 'async_trait>( &'life0 self, _request: ListNamespacesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListNamespacesResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn describe_namespace<'life0, 'async_trait>( &'life0 self, _request: DescribeNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeNamespaceResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn create_namespace<'life0, 'async_trait>( &'life0 self, _request: CreateNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateNamespaceResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn drop_namespace<'life0, 'async_trait>( &'life0 self, _request: DropNamespaceRequest, ) -> Pin<Box<dyn Future<Output = Result<DropNamespaceResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn namespace_exists<'life0, 'async_trait>( &'life0 self, _request: NamespaceExistsRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn list_tables<'life0, 'async_trait>( &'life0 self, _request: ListTablesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTablesResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn register_table<'life0, 'async_trait>( &'life0 self, _request: RegisterTableRequest, ) -> Pin<Box<dyn Future<Output = Result<RegisterTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn table_exists<'life0, 'async_trait>( &'life0 self, _request: TableExistsRequest, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn drop_table<'life0, 'async_trait>( &'life0 self, _request: DropTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DropTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn deregister_table<'life0, 'async_trait>( &'life0 self, _request: DeregisterTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DeregisterTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn count_table_rows<'life0, 'async_trait>( &'life0 self, _request: CountTableRowsRequest, ) -> Pin<Box<dyn Future<Output = Result<i64, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn create_table<'life0, 'async_trait>( &'life0 self, _request: CreateTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<CreateTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn create_empty_table<'life0, 'async_trait>( &'life0 self, _request: CreateEmptyTableRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateEmptyTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn insert_into_table<'life0, 'async_trait>( &'life0 self, _request: InsertIntoTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<InsertIntoTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn merge_insert_into_table<'life0, 'async_trait>( &'life0 self, _request: MergeInsertIntoTableRequest, _request_data: Bytes, ) -> Pin<Box<dyn Future<Output = Result<MergeInsertIntoTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn update_table<'life0, 'async_trait>( &'life0 self, _request: UpdateTableRequest, ) -> Pin<Box<dyn Future<Output = Result<UpdateTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn delete_from_table<'life0, 'async_trait>( &'life0 self, _request: DeleteFromTableRequest, ) -> Pin<Box<dyn Future<Output = Result<DeleteFromTableResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn query_table<'life0, 'async_trait>( &'life0 self, _request: QueryTableRequest, ) -> Pin<Box<dyn Future<Output = Result<Bytes, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn create_table_index<'life0, 'async_trait>( &'life0 self, _request: CreateTableIndexRequest, ) -> Pin<Box<dyn Future<Output = Result<CreateTableIndexResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn list_table_indices<'life0, 'async_trait>( &'life0 self, _request: ListTableIndicesRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTableIndicesResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn describe_table_index_stats<'life0, 'async_trait>( &'life0 self, _request: DescribeTableIndexStatsRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTableIndexStatsResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn describe_transaction<'life0, 'async_trait>( &'life0 self, _request: DescribeTransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<DescribeTransactionResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

fn alter_transaction<'life0, 'async_trait>( &'life0 self, _request: AlterTransactionRequest, ) -> Pin<Box<dyn Future<Output = Result<AlterTransactionResponse, Error>> + Send + 'async_trait>>
where 'life0: 'async_trait, Self: 'async_trait,

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

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

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

impl<T> CloneToUninit for T
where T: Clone,

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

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

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

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

impl<T> ToOwned for T
where T: Clone,

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

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

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

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

impl<T> Allocation for T
where T: RefUnwindSafe + Send + Sync,

impl<T> ErasedDestructor for T
where T: 'static,