Struct ckb_testkit::connector::Connector

pub struct Connector { /* fields omitted */ }

Connector is a fake node

Implementations

impl Connector

pub fn send_relay_transaction(
    &self,
    node: &Node,
    relay_protocol: SupportProtocols,
    transaction: &TransactionView,
    cycles: Cycle
) -> Result<(), String>

pub fn send_relay_transaction_hash(
    &self,
    node: &Node,
    relay_protocol: SupportProtocols,
    hashes: Vec<Byte32>
) -> Result<(), String>

pub fn send_identify_message(
    &self,
    node: &Node,
    network_identifier: &str,
    client_version: &str,
    listening_addresses: Vec<Multiaddr>,
    observed_address: Multiaddr
) -> Result<(), String>

pub fn send_discovery_get_nodes(
    &self,
    node: &Node,
    listening_port: Option<u16>,
    max_nodes: u32,
    self_defined_flag: u32
) -> Result<(), String>

pub fn send_discovery_nodes(
    &self,
    node: &Node,
    active_push: bool,
    addresses: Vec<Multiaddr>
) -> Result<(), String>

pub fn recv(
    &self,
    node: &Node,
    protocol: &SupportProtocols
) -> Result<Bytes, String>

pub fn recv_timeout(
    &self,
    timeout: Duration,
    node: &Node,
    protocol: &SupportProtocols
) -> Result<Bytes, String>

impl Connector

pub fn connect(&mut self, node: &Node) -> Result<(), String>

Try to establish connection with node. This function blocks until all protocols opened.

pub fn send(
    &self,
    node: &Node,
    protocol: SupportProtocols,
    data: Bytes
) -> Result<(), String>

Send data through the protocol of the session

pub fn get_session(&self, node: &Node) -> Option<SessionContext>

Return the session corresponding to the node if connected.

pub fn get_opened_protocol_ids(&self, node: &Node) -> Option<Vec<ProtocolId>>

Return the opened protocols of the session corresponding to the node if connected

pub fn shared(&self) -> &Arc<RwLock<SharedState>>

Return the shared state