Struct TelemetryState

pub struct TelemetryState { /* private fields */ }

Implementations

impl TelemetryState

pub fn new( tx_latency_submitted_range: Range<u64>, tx_latency_submitted_buckets: u64, tx_latency_confirmed_range: Range<u64>, tx_latency_confirmed_buckets: u64, namespace: &str, ) -> Self

pub fn gather(&self) -> Vec<MetricFamily>

Gather the metrics for export

pub fn init_worker_by_type(&self, worker_type: WorkerType)

pub fn init_per_chain(&self, chain_id: &ChainId)

pub fn init_per_channel( &self, src_chain: &ChainId, dst_chain: &ChainId, src_channel: &ChannelId, dst_channel: &ChannelId, src_port: &PortId, dst_port: &PortId, )

pub fn init_per_path( &self, chain: &ChainId, counterparty: &ChainId, channel: &ChannelId, port: &PortId, clear_packets: bool, )

pub fn init_per_client( &self, src_chain: &ChainId, dst_chain: &ChainId, client: &ClientId, misbehaviour: bool, )

pub fn worker(&self, worker_type: WorkerType, count: i64)

Update the number of workers per object

pub fn client_updates_submitted( &self, src_chain: &ChainId, dst_chain: &ChainId, client: &ClientId, count: u64, )

Update the number of client updates per client

pub fn client_updates_skipped( &self, src_chain: &ChainId, dst_chain: &ChainId, client: &ClientId, count: u64, )

Update the number of client updates skipped per client

pub fn client_misbehaviours_submitted( &self, src_chain: &ChainId, dst_chain: &ChainId, client: &ClientId, count: u64, )

Number of client misbehaviours per client

pub fn receive_packets_confirmed( &self, src_chain: &ChainId, dst_chain: &ChainId, src_channel: &ChannelId, dst_channel: &ChannelId, src_port: &PortId, dst_port: &PortId, count: u64, )

Number of receive packets relayed, per channel

pub fn acknowledgment_packets_confirmed( &self, src_chain: &ChainId, dst_chain: &ChainId, src_channel: &ChannelId, dst_channel: &ChannelId, src_port: &PortId, dst_port: &PortId, count: u64, )

Number of acknowledgment packets relayed, per channel

pub fn timeout_packets_confirmed( &self, src_chain: &ChainId, dst_chain: &ChainId, src_channel: &ChannelId, dst_channel: &ChannelId, src_port: &PortId, dst_port: &PortId, count: u64, )

Number of timeout packets relayed, per channel

pub fn query(&self, chain_id: &ChainId, query_type: &'static str)

Number of queries emitted by the relayer, per chain and query type

pub fn queries_cache_hits(&self, chain_id: &ChainId, query_type: &'static str)

Number of cache hits for queries emitted by the relayer, per chain and query type

pub fn ws_reconnect(&self, chain_id: &ChainId)

Number of time the relayer had to reconnect to the WebSocket endpoint, per chain

pub fn ws_events(&self, chain_id: &ChainId, count: u64)

How many IBC events did Hermes receive via the WebSocket subscription, per chain

pub fn messages_submitted(&self, chain_id: &ChainId, count: u64)

How many messages Hermes submitted to the chain

pub fn wallet_balance( &self, chain_id: &ChainId, account: &str, amount: f64, denom: &str, )

The balance in each wallet that Hermes is using, per account, denom and chain. The amount given is of unit: 10^6 * denom

pub fn received_event_batch(&self, tracking_id: impl ToString)

pub fn tx_submitted( &self, tx_count: usize, tracking_id: impl ToString, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn tx_confirmed( &self, tx_count: usize, tracking_id: impl ToString, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn send_packet_events( &self, _seq_nr: u64, _height: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn acknowledgement_events( &self, _seq_nr: u64, _height: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn timeout_events( &self, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn cleared_send_packet_events( &self, _seq_nr: u64, _height: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn cleared_acknowledgment_events( &self, _seq_nr: u64, _height: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

pub fn backlog_insert( &self, seq_nr: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

Inserts in the backlog a new event for the given sequence number. This happens when the relayer observed a new SendPacket event.

pub fn update_backlog( &self, sequences: Vec<u64>, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

Inserts in the backlog a new event for the given sequence number. This happens when the relayer observed a new SendPacket event.

pub fn backlog_remove( &self, seq_nr: u64, chain_id: &ChainId, channel_id: &ChannelId, port_id: &PortId, counterparty_chain_id: &ChainId, )

Evicts from the backlog the event for the given sequence number. Removing events happens when the relayer observed either an acknowledgment or a timeout for a packet sequence number, which means that the corresponding packet was relayed.

pub fn fees_amount( &self, chain_id: &ChainId, receiver: &Signer, fee_amounts: Coin<String>, )

Record the rewarded fee from ICS29 if the address is in the registered addresses list.

pub fn update_period_fees( &self, chain_id: &ChainId, receiver: &String, denom: &String, )

pub fn add_visible_fee_address(&self, address: String)

pub fn broadcast_errors( &self, address: &String, error_code: u32, error_description: &str, )

Add an error and its description to the list of errors observed after broadcasting a Tx with a specific account.

pub fn simulate_errors( &self, address: &String, recoverable: bool, error_description: String, )

Add an error and its description to the list of errors observed after simulating a Tx with a specific account.

pub fn dynamic_gas_queried_fees(&self, chain_id: &ChainId, amount: f64)

pub fn dynamic_gas_paid_fees(&self, chain_id: &ChainId, amount: f64)

pub fn dynamic_gas_queried_success_fees(&self, chain_id: &ChainId, amount: f64)

pub fn filtered_packets( &self, src_chain: &ChainId, dst_chain: &ChainId, src_channel: &ChannelId, dst_channel: &ChannelId, src_port: &PortId, dst_port: &PortId, count: u64, )

Increment number of packets filtered because the memo field is too big

pub fn cross_chain_queries( &self, src_chain: &ChainId, dst_chain: &ChainId, count: usize, )

pub fn cross_chain_query_responses( &self, src_chain: &ChainId, dst_chain: &ChainId, ccq_responses_codes: Vec<Code>, )