Struct AddLyquid 

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

Start sequencing slots for the given lyquid.

To keep outbound execution fully local, add this lyquid’s dependencies before adding the lyquid itself. If some dependencies are still unhosted, outbound calls may still make progress through side-effect fallback/prefill, but liveness then depends on that external side-effect path rather than on the local hosted closure alone.

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, hosted dependencies should ideally be added before this lyquid is added. Otherwise their results may need to be recovered from the archival/side-effect provider until those dependencies are hosted too. Once both sides are hosted, the calls are directly injected 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>

oracle: Option<OracleEndpoints>

Oracle sync endpoints for this lyquid.

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.