LanceNamespace

lance_namespace::namespace

Trait LanceNamespace 

Source 
pub trait LanceNamespace: Send + Sync {

Show 24 methods    // Provided methods
    fn list_namespaces<'life0, 'async_trait>(
        &'life0 self,
        _request: ListNamespacesRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ListNamespacesResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn describe_namespace<'life0, 'async_trait>(
        &'life0 self,
        _request: DescribeNamespaceRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DescribeNamespaceResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn create_namespace<'life0, 'async_trait>(
        &'life0 self,
        _request: CreateNamespaceRequest,
    ) -> Pin<Box<dyn Future<Output = Result<CreateNamespaceResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn drop_namespace<'life0, 'async_trait>(
        &'life0 self,
        _request: DropNamespaceRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DropNamespaceResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn namespace_exists<'life0, 'async_trait>(
        &'life0 self,
        _request: NamespaceExistsRequest,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_tables<'life0, 'async_trait>(
        &'life0 self,
        _request: ListTablesRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ListTablesResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    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 register_table<'life0, 'async_trait>(
        &'life0 self,
        _request: RegisterTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<RegisterTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn table_exists<'life0, 'async_trait>(
        &'life0 self,
        _request: TableExistsRequest,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn drop_table<'life0, 'async_trait>(
        &'life0 self,
        _request: DropTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DropTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn deregister_table<'life0, 'async_trait>(
        &'life0 self,
        _request: DeregisterTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DeregisterTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn count_table_rows<'life0, 'async_trait>(
        &'life0 self,
        _request: CountTableRowsRequest,
    ) -> Pin<Box<dyn Future<Output = Result<i64>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn create_table<'life0, 'async_trait>(
        &'life0 self,
        _request: CreateTableRequest,
        _request_data: Bytes,
    ) -> Pin<Box<dyn Future<Output = Result<CreateTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn create_empty_table<'life0, 'async_trait>(
        &'life0 self,
        _request: CreateEmptyTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<CreateEmptyTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn insert_into_table<'life0, 'async_trait>(
        &'life0 self,
        _request: InsertIntoTableRequest,
        _request_data: Bytes,
    ) -> Pin<Box<dyn Future<Output = Result<InsertIntoTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn merge_insert_into_table<'life0, 'async_trait>(
        &'life0 self,
        _request: MergeInsertIntoTableRequest,
        _request_data: Bytes,
    ) -> Pin<Box<dyn Future<Output = Result<MergeInsertIntoTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn update_table<'life0, 'async_trait>(
        &'life0 self,
        _request: UpdateTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<UpdateTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn delete_from_table<'life0, 'async_trait>(
        &'life0 self,
        _request: DeleteFromTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DeleteFromTableResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn query_table<'life0, 'async_trait>(
        &'life0 self,
        _request: QueryTableRequest,
    ) -> Pin<Box<dyn Future<Output = Result<Bytes>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn create_table_index<'life0, 'async_trait>(
        &'life0 self,
        _request: CreateTableIndexRequest,
    ) -> Pin<Box<dyn Future<Output = Result<CreateTableIndexResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn list_table_indices<'life0, 'async_trait>(
        &'life0 self,
        _request: ListTableIndicesRequest,
    ) -> Pin<Box<dyn Future<Output = Result<ListTableIndicesResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn describe_table_index_stats<'life0, 'async_trait>(
        &'life0 self,
        _request: DescribeTableIndexStatsRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DescribeTableIndexStatsResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn describe_transaction<'life0, 'async_trait>(
        &'life0 self,
        _request: DescribeTransactionRequest,
    ) -> Pin<Box<dyn Future<Output = Result<DescribeTransactionResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn alter_transaction<'life0, 'async_trait>(
        &'life0 self,
        _request: AlterTransactionRequest,
    ) -> Pin<Box<dyn Future<Output = Result<AlterTransactionResponse>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }

}
Expand description

Base trait for Lance Namespace implementations.

This trait defines the interface that all Lance namespace implementations must provide. Each method corresponds to a specific operation on namespaces or tables.

Provided Methods§

Source

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

List namespaces.

Source

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

Describe a namespace.

Source

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

Create a new namespace.

Source

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

Drop a namespace.

Source

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

Check if a namespace exists.

Source

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

List tables in a namespace.

Source

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,

Describe a table.

Source

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

Register a table.

Source

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

Check if a table exists.

Source

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

Drop a table.

Source

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

Deregister a table.

Source

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

Count rows in a table.

Source

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

Create a new table with data from Arrow IPC stream.

Source

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

Create an empty table (metadata only operation).

Source

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

Insert data into a table.

Source

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

Merge insert data into a table.

Source

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

Update a table.

Source

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

Delete from a table.

Source

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

Query a table.

Source

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

Create a table index.

Source

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

List table indices.

Source

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

Describe table index statistics.

Source

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

Describe a transaction.

Source

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

Alter a transaction.

Implementors§