Struct DerivationActor

pub struct DerivationActor<B>
where
    B: PipelineBuilder,
{ /* private fields */ }

The NodeActor for the derivation sub-routine.

This actor is responsible for receiving messages from NodeActors and stepping the derivation pipeline forward to produce new payload attributes. The actor then sends the payload to the NodeActor responsible for the execution sub-routine.

Implementations

impl<B> DerivationActor<B>

where B: PipelineBuilder,

pub fn new(state: B) -> (DerivationInboundChannels, Self)

Creates a new instance of the DerivationActor.

Trait Implementations

impl<B> Debug for DerivationActor<B>

where B: PipelineBuilder + Debug,

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

Formats the value using the given formatter.

impl<B> NodeActor for DerivationActor<B>

where B: PipelineBuilder,

type Error = DerivationError

The error type for the actor.

type OutboundData = DerivationContext

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

type Builder = B

The configuration needed to build the actor.

type InboundData = DerivationInboundChannels

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, __arg1: Self::OutboundData, ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>

where Self: 'async_trait,

Starts the actor.