Struct linera_execution::ExecutionStateView

pub struct ExecutionStateView<C> {
    pub system: SystemExecutionStateView<C>,
    pub simple_users: ReentrantCollectionView<C, UserApplicationId, RegisterView<C, Vec<u8>>>,
    pub view_users: ReentrantCollectionView<C, UserApplicationId, KeyValueStoreView<C>>,
}

A view accessing the execution state of a chain.

Fields

system: SystemExecutionStateView<C>

System application.

simple_users: ReentrantCollectionView<C, UserApplicationId, RegisterView<C, Vec<u8>>>

User applications (Simple based).

view_users: ReentrantCollectionView<C, UserApplicationId, KeyValueStoreView<C>>

User applications (View based).

Implementations

impl<C> ExecutionStateView<C>where C: Context + Clone + Send + Sync + 'static, ViewError: From<C::Error>, C::Extra: ExecutionRuntimeContext,

pub async fn execute_operation( &mut self, context: &OperationContext, operation: &Operation, remaining_fuel: &mut u64 ) -> Result<Vec<ExecutionResult>, ExecutionError>

pub async fn execute_message( &mut self, context: &MessageContext, message: &Message, remaining_fuel: &mut u64 ) -> Result<Vec<ExecutionResult>, ExecutionError>

pub async fn query_application( &mut self, context: &QueryContext, query: &Query ) -> Result<Response, ExecutionError>

pub async fn list_applications( &self ) -> Result<Vec<(UserApplicationId, UserApplicationDescription)>, ExecutionError>

Trait Implementations

impl<C: Send + Sync + Context> ContainerType for ExecutionStateView<C>where ViewError: From<C::Error>,

fn resolve_field<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 Context<'life2> ) -> Pin<Box<dyn Future<Output = ServerResult<Option<Value>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Resolves a field value and outputs it as a json value async_graphql::Value.

fn find_entity<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 Context<'life2>, params: &'life3 Value ) -> Pin<Box<dyn Future<Output = ServerResult<Option<Value>>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Find the GraphQL entity with the given name from the parameter.

fn collect_all_fields<'a>( &'a self, ctx: &ContextBase<'a, &'a Positioned<SelectionSet>>, fields: &mut Fields<'a> ) -> Result<(), ServerError>where Self: Send + Sync,

Collect all the fields of the container that are queried in the selection set.

impl<C> CryptoHashView<C> for ExecutionStateView<C>where C: Context + Send + Sync + Clone + 'static, ViewError: From<C::Error>,

fn crypto_hash<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<CryptoHash, ViewError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Computing the hash and attributing the type to it.

impl<C: Debug> Debug for ExecutionStateView<C>

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

Formats the value using the given formatter.

impl<C> HashableView<C> for ExecutionStateView<C>where C: Context + Send + Sync + Clone + 'static, ViewError: From<C::Error>,

type Hasher = CoreWrapper<Sha3_256Core>

How to compute hashes.

fn hash_mut<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<<Self::Hasher as Hasher>::Output, ViewError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Computes the hash of the values.

fn hash<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<<Self::Hasher as Hasher>::Output, ViewError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Computes the hash of the values.

impl<C: Send + Sync + Context> OutputType for ExecutionStateView<C>where ViewError: From<C::Error>,

fn type_name() -> Cow<'static, str>

Type the name.

fn create_type_info(registry: &mut Registry) -> String

Create type information in the registry and return qualified typename.

fn resolve<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, ctx: &'life1 ContextSelectionSet<'life2>, _field: &'life3 Positioned<Field> ) -> Pin<Box<dyn Future<Output = ServerResult<Value>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Resolve an output value to async_graphql::Value.

fn qualified_type_name() -> String

Qualified typename.

fn introspection_type_name(&self) -> Cow<'static, str>

Introspection type name

impl<C> View<C> for ExecutionStateView<C>where C: Context + Send + Sync + Clone + 'static, ViewError: From<C::Error>,

fn context(&self) -> &C

Obtains a mutable reference to the internal context.

fn load<'async_trait>( context: C ) -> Pin<Box<dyn Future<Output = Result<Self, ViewError>> + Send + 'async_trait>>where Self: 'async_trait,

Creates a view or a subview.

fn rollback(&mut self)

Discards all pending changes. After that flush should have no effect to storage.

fn flush(&mut self, batch: &mut Batch) -> Result<(), ViewError>

Persists changes to storage. This leaves the view still usable and is essentially neutral to the program running. Crash-resistant storage implementations are expected to accumulate the desired changes in the batch variable first. If the view is dropped without calling flush, staged changes are simply lost.

fn delete(self, batch: &mut Batch)

Instead of persisting changes, clears all the data that belong to this view and its subviews. Crash-resistant storage implementations are expected to accumulate the desired changes into the batch variable first. No data/metadata at all is left after deletion. The view is consumed by delete.

fn clear(&mut self)

Clears the view. That can be seen as resetting to default. In the case of a RegisterView this means setting the value to T::default(). For LogView, QueueView, this leaves the range data to be left in the database.

impl<C: Send + Sync + Context> ObjectType for ExecutionStateView<C>where ViewError: From<C::Error>,