Struct SequencerActor

pub struct SequencerActor<AB: AttributesBuilderConfig> {
    pub builder: AB,
    pub unsafe_head_rx: Receiver<L2BlockInfo>,
    pub admin_query_rx: Receiver<SequencerAdminQuery>,
}

The SequencerActor is responsible for building L2 blocks on top of the current unsafe head and scheduling them to be signed and gossipped by the P2P layer, extending the L2 chain with new blocks.

Fields

builder: AB

The AttributesBuilderConfig.

unsafe_head_rx: Receiver<L2BlockInfo>

Watch channel to observe the unsafe head of the engine.

admin_query_rx: Receiver<SequencerAdminQuery>

Channel to receive admin queries from the sequencer actor.

Implementations

impl<AB: AttributesBuilderConfig> SequencerActor<AB>

pub fn new(state: AB) -> (SequencerInboundData, Self)

Creates a new instance of the SequencerActor.

Trait Implementations

impl<AB: Debug + AttributesBuilderConfig> Debug for SequencerActor<AB>

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

Formats the value using the given formatter.

impl NodeActor for SequencerActor<SequencerBuilder>

type Error = SequencerActorError

The error type for the actor.

type OutboundData = SequencerContext

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

type Builder = SequencerBuilder

The configuration needed to build the actor.

type InboundData = SequencerInboundData

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

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

Builds the actor.

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

where Self: 'async_trait,

Starts the actor.