Struct L1WatcherRpc

pub struct L1WatcherRpc {
    pub inbound_queries: Receiver<L1WatcherQueries>,
    /* private fields */
}

An L1 chain watcher that checks for L1 block updates over RPC.

Fields

inbound_queries: Receiver<L1WatcherQueries>

The inbound queries to the L1 watcher.

Implementations

impl L1WatcherRpc

pub fn new(config: L1WatcherRpcState) -> (L1WatcherRpcInboundChannels, Self)

Creates a new L1WatcherRpc instance.

Trait Implementations

impl Debug for L1WatcherRpc

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

Formats the value using the given formatter.

impl NodeActor for L1WatcherRpc

type Error = L1WatcherRpcError<BlockInfo>

The error type for the actor.

type InboundData = L1WatcherRpcInboundChannels

The inbound communication channels used by the actor. These are the channels that the actor will use to receive messages from other actors.

type OutboundData = L1WatcherRpcContext

The communication context used by the actor. These are the channels that the actor will use to send messages to other actors.

type Builder = L1WatcherRpcState

The configuration needed to build the actor.

fn build(config: Self::Builder) -> (Self::InboundData, Self)

Builds the actor.

fn start<'async_trait>( self, __arg1: Self::OutboundData, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait,

Starts the actor.