Struct TransactionTracker 

pub struct TransactionTracker { /* private fields */ }

Tracks oracle responses and execution outcomes of an ongoing transaction execution, as well as replayed oracle responses.

Implementations

impl TransactionTracker

pub fn new( local_time: Timestamp, transaction_index: u32, next_application_index: u32, next_chain_index: u32, oracle_responses: Option<Vec<OracleResponse>>, blobs: &[Vec<Blob>], ) -> Self

pub fn with_blobs(self, blobs: BTreeMap<BlobId, BlobContent>) -> Self

pub fn local_time(&self) -> Timestamp

pub fn set_local_time(&mut self, local_time: Timestamp)

pub fn transaction_index(&self) -> u32

pub fn next_application_index(&mut self) -> u32

pub fn next_chain_index(&mut self) -> u32

pub fn add_outgoing_message(&mut self, message: OutgoingMessage)

pub fn add_outgoing_messages( &mut self, messages: impl IntoIterator<Item = OutgoingMessage>, )

pub fn add_event(&mut self, stream_id: StreamId, index: u32, value: Vec<u8>)

pub fn get_blob_content(&self, blob_id: &BlobId) -> Option<&BlobContent>

pub fn add_created_blob(&mut self, blob: Blob)

pub fn add_published_blob(&mut self, blob_id: BlobId)

pub fn created_blobs(&self) -> &BTreeMap<BlobId, BlobContent>

pub fn add_oracle_response(&mut self, oracle_response: OracleResponse)

pub fn add_operation_result(&mut self, result: Option<Vec<u8>>)

pub fn add_stream_to_process( &mut self, application_id: ApplicationId, chain_id: ChainId, stream_id: StreamId, previous_index: u32, next_index: u32, )

pub fn remove_stream_to_process( &mut self, application_id: ApplicationId, chain_id: ChainId, stream_id: StreamId, )

pub fn take_streams_to_process( &mut self, ) -> BTreeMap<ApplicationId, Vec<StreamUpdate>>

pub fn replay_oracle_response( &mut self, oracle_response: OracleResponse, ) -> Result<bool, ExecutionError>

Adds the oracle response to the record. If replaying, it also checks that it matches the next replayed one and returns true.

pub fn next_replayed_oracle_response( &mut self, ) -> Result<Option<OracleResponse>, ExecutionError>

If in replay mode, returns the next oracle response, or an error if it is missing.

If not in replay mode, None is returned, and the caller must execute the actual oracle to obtain the value.

In both cases, the value (returned or obtained from the oracle) must be recorded using add_oracle_response.

pub fn into_outcome(self) -> Result<TransactionOutcome, ExecutionError>

Trait Implementations

impl Debug for TransactionTracker

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

Formats the value using the given formatter.

impl Default for TransactionTracker

fn default() -> TransactionTracker

Returns the “default value” for a type.