Struct tinychain::txn::Txn

pub struct Txn { /* fields omitted */ }

A transaction context.

Implementations

impl Txn

pub fn ref_count(&self) -> usize

Return the current number of strong references to this Txn.

pub async fn claim(
    self,
    actor: &Actor,
    cluster_path: TCPathBuf
) -> TCResult<Self>

Claim ownership of this transaction.

pub async fn grant(
    &self,
    actor: &Actor,
    cluster_path: TCPathBuf,
    scopes: Vec<Scope>
) -> TCResult<Self>

Return a new Txn which grants the given Scopes to the given Actor.

pub fn has_leader(&self, cluster_path: &[PathSegment]) -> bool

Check if this transaction has a leader for the given cluster.

pub fn has_owner(&self) -> bool

Check if this transaction has an owner.

pub fn is_leader(&self, cluster_path: &[PathSegment]) -> bool

Check if this host is leading the transaction for the specified cluster.

pub fn is_owner(&self, cluster_path: &[PathSegment]) -> bool

Check if the cluster at the specified path on this host is the owner of the transaction.

pub async fn lead(
    self,
    actor: &Actor,
    cluster_path: TCPathBuf
) -> TCResult<Self>

Claim leadership of this transaction for the given cluster.

pub fn leader(&self, cluster_path: &[PathSegment]) -> Option<&Link>

Return the leader of this transaction for the given cluster, if there is one.

pub fn owner(&self) -> Option<&Link>

Return the owner of this transaction, if there is one.

pub fn link(&self, path: TCPathBuf) -> Link

Return a link to the given path on this host.

pub fn request(&self) -> &Request

Return the Request which initiated this transaction on this host.

pub async fn get(&self, link: Link, key: Value) -> TCResult<State>

Resolve a GET op within this transaction context.

pub async fn put(&self, link: Link, key: Value, value: State) -> TCResult<()>

Resolve a PUT op within this transaction context.

pub async fn post(&self, link: Link, params: State) -> TCResult<State>

Resolve a POST op within this transaction context.

pub async fn delete(&self, link: Link, key: Value) -> TCResult<()>

Resolve a DELETE op within this transaction context.

Trait Implementations

impl Clone for Txn

fn clone(&self) -> Txn

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Hash for Txn

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H) where
    H: Hasher, 

Feeds a slice of this type into the given Hasher.

impl Transaction<Dir> for Txn

fn id(&self) -> &TxnId

The TxnId of this transaction context.

fn context(&self) -> &Dir

Borrow the fs::Dir of this transaction context.

fn into_context(self) -> Dir

Consume this Txn and return its fs::Dir.

fn subcontext<'life0, 'async_trait>(
    &'life0 self,
    id: Id
) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Return a transaction subcontext with its own fs::Dir.

fn subcontext_tmp<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = TCResult<Self>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Return a transaction subcontext with its own unique fs::Dir.