Struct DamlSimpleExecutor 

pub struct DamlSimpleExecutor<'a> { /* private fields */ }

A simple async Daml command executor.

Implementations

impl<'a> DamlSimpleExecutor<'a>

pub fn new( ledger_client: &'a DamlGrpcClient, act_as: Vec<String>, read_as: Vec<String>, workflow_id: &str, user_id: &str, deduplication_period: Option<DamlCommandsDeduplicationPeriod>, min_ledger_time: Option<DamlMinLedgerTime>, auth_token: Option<&'a str>, ) -> Self

pub fn act_as(&self) -> &[String]

pub fn read_as(&self) -> &[String]

Trait Implementations

impl CommandExecutor for DamlSimpleExecutor<'_>

fn execute_exercise<'life0, 'async_trait>( &'life0 self, exercise_command: DamlExerciseCommand, ) -> Pin<Box<dyn Future<Output = Result<DamlValue, DamlError>> + Send + 'async_trait>>

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

Submit an exercise command and return the result of the first Exercised event whose exercise_result is populated.

Returns DamlError::MissingRequiredField if the transaction contains no Exercised event (e.g. a mis-routed Create command) or if every Exercised event has an empty result. In practice the participant populates exercise_result for every choice — even non-consuming, unit-returning ones (as Some(DamlValue::Unit)) — so this path only fires for malformed responses.

fn execute_for_transaction<'life0, 'async_trait>( &'life0 self, command: DamlCommand, ) -> Pin<Box<dyn Future<Output = DamlResult<DamlTransaction>> + Send + 'async_trait>>

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

fn execute_for_transaction_with_effects<'life0, 'async_trait>( &'life0 self, command: DamlCommand, ) -> Pin<Box<dyn Future<Output = DamlResult<DamlTransaction>> + Send + 'async_trait>>

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

fn execute_create<'life0, 'async_trait>( &'life0 self, create_command: DamlCreateCommand, ) -> Pin<Box<dyn Future<Output = Result<DamlCreatedEvent, DamlError>> + Send + 'async_trait>>

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