Struct Closure

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

An OpDef which closes over zero or more States

Implementations

impl<Txn> Closure<Txn>

pub fn into_inner(self) -> (Map<State<Txn>>, OpDef)

Return the context and OpDef which define this Closure.

impl<Txn> Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

pub fn dereference_self(self, path: &TCPathBuf) -> Self

Replace references to $self with the given path.

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

Return true if this Closure may write to service other than where it’s defined

pub fn reference_self(self, path: &TCPathBuf) -> Self

Replace references to the given path with $self

pub async fn call(self, txn: &Txn, args: State<Txn>) -> TCResult<State<Txn>>

Execute this Closure with the given args

pub async fn call_owned( self, txn: Txn, args: State<Txn>, ) -> TCResult<State<Txn>>

Execute this Closure with an owned txn and the given args.

Trait Implementations

impl<Txn> AsyncHash for Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

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

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

Compute the hash of this state as of a given TxnId

impl<Txn> Clone for Closure<Txn>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Txn> ClosureInstance<State<Txn>> for Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

fn call<'async_trait>( self: Box<Self>, txn: Txn, args: State<Txn>, ) -> Pin<Box<dyn Future<Output = TCResult<State<Txn>>> + Send + 'async_trait>>

where Self: 'async_trait,

Execute this ClosureInstance with the given args

impl<Txn> Debug for Closure<Txn>

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

Formats the value using the given formatter.

impl<Txn> From<(Map<State<Txn>>, OpDef)> for Closure<Txn>

fn from(tuple: (Map<State<Txn>>, OpDef)) -> Self

Converts to this type from the input type.

impl<Txn> From<Closure<Txn>> for State<Txn>

fn from(closure: Closure<Txn>) -> Self

Converts to this type from the input type.

impl<Txn> From<OpDef> for Closure<Txn>

fn from(op: OpDef) -> Self

Converts to this type from the input type.

impl<Txn> FromStream for Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

type Context = Txn

The decoding context of this type, useful in situations where the stream to be decoded may be too large to hold in main memory.

fn from_stream<'life0, 'async_trait, D>( txn: Txn, decoder: &'life0 mut D, ) -> Pin<Box<dyn Future<Output = Result<Self, D::Error>> + Send + 'async_trait>>

where D: 'async_trait + Decoder, Self: 'async_trait, 'life0: 'async_trait,

Parse this value using the given Decoder.

impl<'a, Txn> Handler<'a, State<Txn>> for Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

fn get<'b>(self: Box<Self>) -> Option<GetHandler<'a, 'b, Txn, State<Txn>>>

where 'b: 'a,

fn put<'b>(self: Box<Self>) -> Option<PutHandler<'a, 'b, Txn, State<Txn>>>

where 'b: 'a,

fn post<'b>(self: Box<Self>) -> Option<PostHandler<'a, 'b, Txn, State<Txn>>>

where 'b: 'a,

fn delete<'b>(self: Box<Self>) -> Option<DeleteHandler<'a, 'b, Txn>>

where 'b: 'a,

impl<'en, Txn> IntoView<'en, CacheBlock> for Closure<Txn>

where Txn: Transaction<CacheBlock> + Gateway<State<Txn>>,

type Txn = Txn

The type of Transaction which this state supports

type View = (HashMap<Id, StateView<'en>>, OpDef)

The type of encodable view returned by into_view

fn into_view<'async_trait>( self, txn: Self::Txn, ) -> Pin<Box<dyn Future<Output = TCResult<Self::View>> + Send + 'async_trait>>

where Self: 'async_trait,

Return a View which can be encoded with en::IntoStream.

impl<Txn> TryCastFrom<Scalar> for Closure<Txn>

fn can_cast_from(scalar: &Scalar) -> bool

Test if value can be cast into Self.

fn opt_cast_from(scalar: Scalar) -> Option<Self>

Returns Some(Self) if the source value can be cast into Self, otherwise None.

fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err>

where OnErr: FnOnce(&T) -> Err,

Returns Ok(Self) if the source value can be cast into Self, otherwise calls on_err.

impl<Txn> TryCastFrom<State<Txn>> for Closure<Txn>

fn can_cast_from(state: &State<Txn>) -> bool

Test if value can be cast into Self.

fn opt_cast_from(state: State<Txn>) -> Option<Self>

Returns Some(Self) if the source value can be cast into Self, otherwise None.

fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err>

where OnErr: FnOnce(&T) -> Err,

Returns Ok(Self) if the source value can be cast into Self, otherwise calls on_err.