Struct AddLyquid

pub struct AddLyquid {
    pub id: LyquidID,
    pub high_mark: usize,
    pub low_mark: usize,
    pub consumer: Recipient<SequenceItem>,
}

Start sequencing slots for the given lyquid.

Always make sure all dependencies have already been added before a lyquid is added through this request, otherwise liveness is not guaranteed.

When a lyquid sequence is added, there are two kinds of possible slots that matter since it was last removed:

1. Inbound Calls: Any other lyquids’ execution that directly or indirectly calls this lyquid.
2. Outbound Calls: Any execution for this lyquid that can direclty or indirectly call others.

For inbound calls, these lyquids must have been removed before this lyquid was removed and added back after this lyquid is added back, so no slots are missed.

For outbound calls, those called lyquids must have been added before this lyquid is added. Before this lyquid is added, the calls are retrieved from the archival node for them so they can run properly. After this lyquid is added, the calls are directly injected by this lyquid locally.

TODO: We should perhaps allow adding a “bulk” of lyquids that includes all dependencies, before starting the their backend slots retrieval and execution, so there is no need to consult the archival node in the middle of adding the entire dependencies.

Fields

id: LyquidID

high_mark: usize

low_mark: usize

consumer: Recipient<SequenceItem>

Trait Implementations

impl Debug for AddLyquid

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

Formats the value using the given formatter.

impl Handler<AddLyquid> for FCO

type Result = Result<Option<u64>, Error>

The type of value that this handler will return.

fn handle(&mut self, msg: AddLyquid, ctx: &mut Context<Self>) -> Self::Result

This method is called for every message received by this actor.

impl Message for AddLyquid

type Result = Result<Option<u64>, Error>

The type of value that this message will resolved with if it is successful.