Enum ibc_relayer::object::Object

pub enum Object {
    Client(Client),
    Connection(Connection),
    Channel(Channel),
    Packet(Packet),
    Wallet(Wallet),
    CrossChainQuery(CrossChainQuery),
}

An object determines the amount of parallelism that can be exercised when processing IbcEvent between two chains. For each Object, a corresponding WorkerHandle is spawned and all IbcEvents mapped to an Object are sent to the associated WorkerHandle for processing.

Variants

Client(Client)

See Client.

Connection(Connection)

See Connection.

Channel(Channel)

See Channel.

Packet(Packet)

See Packet.

Wallet(Wallet)

See Wallet

CrossChainQuery(CrossChainQuery)

See CrossChainQuery

Implementations

impl Object

pub fn notify_new_block(&self, src_chain_id: &ChainId) -> bool

Returns true if this Object is for a WorkerHandle which is interested in new block events originating from the chain with the given ChainId. Returns false otherwise.

pub fn for_chain(&self, chain_id: &ChainId) -> bool

Returns whether or not this object pertains to the given chain.

pub fn object_type(&self) -> ObjectType

Return the type of object

impl Object

pub fn src_chain_id(&self) -> &ChainId

pub fn dst_chain_id(&self) -> &ChainId

pub fn short_name(&self) -> String

pub fn for_update_client( e: &UpdateClient, dst_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given UpdateClient event.

pub fn client_from_chan_open_events( e: &Attributes, chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the client object associated with the given channel event attributes.

pub fn connection_from_conn_open_events( e: &ConnectionAttributes, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the Connection object associated with the given Open connection event.

pub fn channel_from_chan_open_events( attributes: &Attributes, src_chain: &impl ChainHandle, allow_non_open_connection: bool ) -> Result<Self, ObjectError>

Build the Channel object associated with the given Open channel event.

pub fn for_send_packet( e: &SendPacket, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given SendPacket event.

pub fn for_write_ack( e: &WriteAcknowledgement, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given WriteAcknowledgement event.

pub fn for_timeout_packet( e: &TimeoutPacket, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given TimeoutPacket event.

pub fn for_close_init_channel( e: &CloseInit, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given CloseInit event.

pub fn for_cross_chain_query_packet( p: &CrossChainQueryPacket, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given CrossChainQuery event.

pub fn for_incentivized_packet( e: &IncentivizedPacket, src_chain: &impl ChainHandle ) -> Result<Self, ObjectError>

Build the object associated with the given IncentivizedPacket event.

Trait Implementations

impl Clone for Object

fn clone(&self) -> Object

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Object

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Object

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<Channel> for Object

fn from(c: Channel) -> Self

Converts to this type from the input type.

impl From<Client> for Object

fn from(c: Client) -> Self

Converts to this type from the input type.

impl From<Connection> for Object

fn from(c: Connection) -> Self

Converts to this type from the input type.

impl From<CrossChainQuery> for Object

fn from(c: CrossChainQuery) -> Self

Converts to this type from the input type.

impl From<Packet> for Object

fn from(p: Packet) -> Self

Converts to this type from the input type.

impl From<Wallet> for Object

fn from(w: Wallet) -> Self

Converts to this type from the input type.

impl Hash for Object

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for Object

fn cmp(&self, other: &Object) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized + PartialOrd,

Restrict a value to a certain interval.

impl PartialEq for Object

fn eq(&self, other: &Object) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialOrd for Object

fn partial_cmp(&self, other: &Object) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

This method tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

This method tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

This method tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

This method tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for Object

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Object

impl StructuralEq for Object

impl StructuralPartialEq for Object