Struct FCOHandle 

pub struct FCOHandle { /* private fields */ }

Implementations

impl FCOHandle

pub fn subscribe_progress(&self) -> Receiver<ProgressUpdate>

pub async fn add_lyquid(&self, msg: AddLyquid) -> Result<Option<u64>, Error>

pub async fn remove_lyquid(&self, msg: RemoveLyquid) -> Result<(), Error>

pub async fn init_deps(&self, msg: InitDeps) -> Result<(), Error>

pub async fn on_inter_call(&self, msg: OnInterCall) -> Result<Vec<u8>>

pub async fn submit_call(&self, msg: SubmitCall) -> Result<Vec<u8>>

pub async fn fetch_oracle_info( &self, msg: FetchOracleInfo, ) -> Result<Option<OracleEpochInfo>, Error>

pub async fn commit(&self) -> Result<(), KVStoreError>

Trait Implementations

impl Clone for FCOHandle

fn clone(&self) -> FCOHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Service<FetchOracleInfo> for FCOHandle

type Response = Option<OracleEpochInfo>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<FCOHandle as Service<FetchOracleInfo>>::Response, <FCOHandle as Service<FetchOracleInfo>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: FetchOracleInfo) -> Self::Future

Process the request and return the response asynchronously.

impl Service<OnInterCall> for FCOHandle

type Response = Vec<u8>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<FCOHandle as Service<OnInterCall>>::Response, <FCOHandle as Service<OnInterCall>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: OnInterCall) -> Self::Future

Process the request and return the response asynchronously.

impl Service<SubmitCall> for FCOHandle

type Response = Vec<u8>

Responses given by the service.

type Error = Error

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<FCOHandle as Service<SubmitCall>>::Response, <FCOHandle as Service<SubmitCall>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: SubmitCall) -> Self::Future

Process the request and return the response asynchronously.