Struct DaemonAsync 

pub struct DaemonAsync {
    pub sender: Arc<Sender<All>>,
    pub state: Arc<DaemonState>,
}

Represents a blockchain node. It’s constructed using DaemonAsyncBuilder.

Usage

use cw_orch_daemon::{DaemonAsync, networks};

let daemon: DaemonAsync = DaemonAsync::builder()
    .chain(networks::JUNO_1)
    .build()
    .await.unwrap();

Environment Execution

The DaemonAsync implements async methods of TxHandler which allows you to perform transactions on the chain.

Querying

Different Cosmos SDK modules can be queried through the daemon by calling the [DaemonAsync::query_client<Querier>] method with a specific querier. See Querier for examples.

Warning

This daemon is thread safe and can be used between threads. However, please make sure that you are not trying to broadcast multiple transactions at once when using this Daemon on different threads. If you do so, you WILL get account sequence errors and your transactions won’t get broadcasted. Use a Mutex on top of this DaemonAsync to avoid such errors.

Fields

sender: Arc<Sender<All>>

Sender to send transactions to the chain

state: Arc<DaemonState>

State of the daemon

Implementations

impl DaemonAsync

pub fn builder() -> DaemonAsyncBuilder

Get the daemon builder

pub fn channel(&self) -> Channel

Get the channel configured for this DaemonAsync.

impl DaemonAsync

pub fn sender(&self) -> Addr

Get the sender address

pub fn rebuild(&self) -> DaemonAsyncBuilder

Returns a new DaemonAsyncBuilder with the current configuration. Does not consume the original DaemonAsync.

pub async fn execute<E>( &self, exec_msg: &E, coins: &[Coin], contract_address: &Addr, ) -> Result<CosmTxResponse, DaemonError>

where E: Serialize,

Execute a message on a contract.

pub async fn instantiate<I>( &self, code_id: u64, init_msg: &I, label: Option<&str>, admin: Option<&Addr>, coins: &[Coin], ) -> Result<CosmTxResponse, DaemonError>

where I: Serialize + Debug,

Instantiate a contract.

pub async fn instantiate2<I>( &self, code_id: u64, init_msg: &I, label: Option<&str>, admin: Option<&Addr>, coins: &[Coin], salt: Binary, ) -> Result<CosmTxResponse, DaemonError>

where I: Serialize + Debug,

Instantiate a contract.

pub async fn query<Q, T>( &self, query_msg: &Q, contract_address: &Addr, ) -> Result<T, DaemonError>

where Q: Serialize + Debug, T: Serialize + DeserializeOwned,

Query a contract.

pub async fn migrate<M>( &self, migrate_msg: &M, new_code_id: u64, contract_address: &Addr, ) -> Result<CosmTxResponse, DaemonError>

where M: Serialize + Debug,

Migration a contract.

pub async fn wait_blocks(&self, amount: u64) -> Result<(), DaemonError>

Wait for a given amount of blocks.

pub async fn wait_seconds(&self, secs: u64) -> Result<(), DaemonError>

Wait for a given amount of seconds.

pub async fn next_block(&self) -> Result<(), DaemonError>

Wait for the next block.

pub async fn block_info(&self) -> Result<BlockInfo, DaemonError>

Get the current block info.

pub async fn upload<T>( &self, _uploadable: &T, ) -> Result<CosmTxResponse, DaemonError>

where T: Uploadable,

Upload a contract to the chain.

pub fn set_sender(&mut self, sender: &Arc<Sender<All>>)

Set the sender to use with this DaemonAsync to be the given wallet

Trait Implementations

impl ChainState for DaemonAsync

type Out = Arc<DaemonState>

The type of the underlying state.

fn state(&self) -> <DaemonAsync as ChainState>::Out

Get the underlying state.

impl Clone for DaemonAsync

fn clone(&self) -> DaemonAsync

Returns a duplicate of the value.

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

Performs copy-assignment from source.