Trait tc_collection::tensor::TensorPermitWrite

pub trait TensorPermitWrite: Send + Sync {
    // Required method
    fn write_permit<'life0, 'async_trait>(
        &'life0 self,
        txn_id: TxnId,
        range: Range
    ) -> Pin<Box<dyn Future<Output = TCResult<PermitWrite<Range>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Method to lock a tensor for writing.

Required Methods

fn write_permit<'life0, 'async_trait>( &'life0 self, txn_id: TxnId, range: Range ) -> Pin<Box<dyn Future<Output = TCResult<PermitWrite<Range>>> + Send + 'async_trait>>

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

Acquire a write lock on the given range of this tensor.

Implementors

impl<FE, S> TensorPermitWrite for DenseCow<FE, S>

where FE: Send + Sync, S: TensorPermitWrite,

impl<FE, T> TensorPermitWrite for DenseVersion<FE, T>

where FE: Send + Sync, T: CType + DType,

impl<FE, T> TensorPermitWrite for SparseVersion<FE, T>

where FE: Send + Sync, T: CType + DType,

impl<FE, T, S> TensorPermitWrite for SparseCow<FE, T, S>

where FE: Send + Sync, T: CType + DType, S: TensorPermitWrite,

impl<S: TensorPermitWrite> TensorPermitWrite for DenseSlice<S>

impl<S: TensorPermitWrite> TensorPermitWrite for SparseSlice<S>

impl<Txn, FE, T> TensorPermitWrite for DenseAccess<Txn, FE, T>

where Txn: ThreadSafe, FE: ThreadSafe, T: CType + DType,

impl<Txn, FE, T> TensorPermitWrite for SparseAccess<Txn, FE, T>

where Txn: ThreadSafe, FE: ThreadSafe, T: CType + DType,