Struct FCO

pub struct FCO { /* private fields */ }

Fate-Constrained Ordering

Implementations

impl FCO

pub fn new<S: SequenceBackend + 'static>( backend: S, store: Arc<dyn KVStore>, default_pos: Option<ChainPos>, ) -> Result<Self, Error>

Create Fate-Constrained Ordering subsystem.

default_pos will only be used when it’s not None and FCO is initialized for the first time. Once initialized in the store, FCO will disregard this value.

Trait Implementations

impl Actor for FCO

type Context = Context<FCO>

Actor execution context type

fn started(&mut self, _ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopped(&mut self, _ctx: &mut Self::Context)

Called after an actor is stopped.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn start(self) -> Addr<Self>

where Self: Actor<Context = Context<Self>>,

Start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn create<F>(f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self,

Start a new asynchronous actor given a Context.

impl Debug for FCO

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 Handler<Commit> for FCO

type Result = Result<(), KVStoreError>

The type of value that this handler will return.

fn handle(&mut self, _: Commit, _ctx: &mut Context<Self>) -> Self::Result

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

impl Handler<InitDeps> for FCO

type Result = ()

The type of value that this handler will return.

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

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

impl Handler<OnInterCall> for FCO

type Result = Pin<Box<dyn Future<Output = Result<Vec<u8>, Error>>>>

The type of value that this handler will return.

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

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

impl Handler<RemoveLyquid> for FCO

type Result = Pin<Box<dyn Future<Output = Result<(), Error>>>>

The type of value that this handler will return.

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

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

impl Handler<Stop> for FCO

type Result = ()

The type of value that this handler will return.

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

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

impl Handler<SubscribeProgressUpdate> for FCO

type Result = ()

The type of value that this handler will return.

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

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