Struct TxnsRead

pub struct TxnsRead<T> {
    txns_id: ShardId,
    tx: UnboundedSender<TxnsReadCmd<T>>,
    _read_task: Arc<AbortOnDropHandle<()>>,
    _subscribe_task: Arc<AbortOnDropHandle<()>>,
}

A shared TxnsCache running in a task and communicated with over a channel.

Fields

txns_id: ShardId

tx: UnboundedSender<TxnsReadCmd<T>>

_read_task: Arc<AbortOnDropHandle<()>>

_subscribe_task: Arc<AbortOnDropHandle<()>>

Implementations

impl<T: Timestamp + Lattice + Codec64 + Sync> TxnsRead<T>

pub async fn start<C>(client: PersistClient, txns_id: ShardId) -> Self

where T: TotalOrder + StepForward, C: TxnsCodec + 'static,

Starts the task worker and returns a handle for communicating with it.

pub fn txns_id(&self) -> &ShardId

Returns the ShardId of the txns shard.

pub async fn data_snapshot(&self, data_id: ShardId, as_of: T) -> DataSnapshot<T>

See crate::txn_cache::TxnsCacheState::data_snapshot.

pub(crate) async fn data_subscribe( &self, data_id: ShardId, as_of: T, unblock: Box<dyn UnblockRead<T>>, ) -> UnboundedReceiver<DataRemapEntry<T>>

Initiate a subscription to data_id.

Returns a channel that DataRemapEntrys are sent over.

pub async fn update_ge(&self, ts: T)

See TxnsCache::update_ge.

pub async fn update_gt(&self, ts: T)

See TxnsCache::update_gt.

async fn update(&self, wait: WaitTs<T>)

async fn send<R: Debug>( &self, cmd: impl FnOnce(Sender<R>) -> TxnsReadCmd<T>, ) -> R

Trait Implementations

impl<T: Clone> Clone for TxnsRead<T>

fn clone(&self) -> TxnsRead<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for TxnsRead<T>

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

Formats the value using the given formatter.