Struct Txn

pub struct Txn { /* private fields */ }

Implementations

impl Txn

pub const DEFAULT_MODE: Mode

pub fn grant( &self, actor: &Actor, link: Link, path: TCPathBuf, mode: Mode, ) -> TCResult<Self>

Grant mode permissions on the resource at path to the bearer of this Txn’s token. path is relative to the cluster at link whose actor will sign the token.

pub fn mode<Keyring>( &self, _keyring: Keyring, _resource: &[PathSegment], ) -> Mode

where Keyring: Deref<Target = HashMap<Host, VerifyingKey>>,

Get the set of permissions authorized by hosts in the keyring for the given resource.

pub fn locked_by(&self) -> TCResult<Option<VerifyingKey>>

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

pub fn lock(self, actor: &Actor) -> TCResult<Self>

pub fn has_claims(&self) -> bool

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

pub fn owner(&self) -> TCResult<Option<VerifyingKey>>

Trait Implementations

impl Clone for Txn

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Gateway<State<Txn>> for Txn

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<Map<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 Transaction<CacheBlock> for Txn

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 workspace directory.