Struct Txn

pub struct Txn<State> { /* private fields */ }

A transaction context.

Implementations

impl<State> Txn<State>

where State: StateInstance<FE = CacheBlock, Txn = Self>,

pub fn host(&self) -> &Host

Return this Host

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 fn grant( &self, actor: &Actor, cluster_path: TCPathBuf, scopes: Vec<TCPathBuf>, ) -> TCResult<Self>

Return a new Txn which grants the given [Scope]s to the given Actor.

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

Claim ownership of this transaction.

pub fn has_owner(&self) -> bool

Check if this transaction has an owner.

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 fn owner(&self) -> Option<&Link>

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

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

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

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

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

pub 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.

Trait Implementations

impl<State: Clone> Clone for Txn<State>

fn clone(&self) -> Txn<State>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<State> Hash for Txn<State>

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, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<State> RPCClient<State> for Txn<State>

where State: StateInstance<FE = CacheBlock, Txn = Self>,

fn get<'a, 'async_trait, L, V>( &'a self, link: L, key: V, ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where L: Into<ToUrl<'a>> + Send + 'async_trait, V: CastInto<Value> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait,

Resolve a GET op within this transaction context.

fn put<'a, 'async_trait, L, K, V>( &'a self, link: L, key: K, value: V, ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where L: Into<ToUrl<'a>> + Send + 'async_trait, K: CastInto<Value> + Send + 'async_trait, V: CastInto<State> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait,

Resolve a PUT op within this transaction context.

fn post<'a, 'async_trait, L, P>( &'a self, link: L, params: P, ) -> Pin<Box<dyn Future<Output = TCResult<State>> + Send + 'async_trait>>

where L: Into<ToUrl<'a>> + Send + 'async_trait, P: CastInto<State> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait,

Resolve a POST op within this transaction context.

fn delete<'a, 'async_trait, L, V>( &'a self, link: L, key: V, ) -> Pin<Box<dyn Future<Output = TCResult<()>> + Send + 'async_trait>>

where L: Into<ToUrl<'a>> + Send + 'async_trait, V: CastInto<Value> + Send + 'async_trait, Self: 'async_trait, 'a: 'async_trait,

Resolve a DELETE op within this transaction context.

impl<State: Clone + 'static> Transaction<CacheBlock> for Txn<State>

fn id(&self) -> &TxnId

The TxnId of this transaction context.

fn context<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = TCResult<DirLock<CacheBlock>>> + Send + 'async_trait>>

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

Allows locking the filesystem directory of this transaction context, e.g. to cache un-committed state or to compute an intermediate result.

fn subcontext<I: Into<Id> + Send>(&self, id: I) -> Self

Create a new transaction context with the given id.

fn subcontext_unique(&self) -> Self

Create a new transaction subcontext with its own unique [Dir].