Struct ForeignConnection 

pub struct ForeignConnection {
    pub config: Config,
    /* private fields */
}

Fields

config: Config

Implementations

impl ForeignConnection

pub fn prepare( mode: &str, address: Option<String>, id: Option<u8>, peers: Option<Vec<String>>, directory: Option<String>, ) -> Result<Self>

pub fn prepare_with( mode: &str, address: Option<String>, id: Option<u8>, peers: Option<Vec<String>>, directory: Option<String>, flush: Option<String>, metrics: Option<ReplicaMetrics>, ) -> Result<Self>

address is the server’s address in server mode. In replicated mode it is optional and carries only this member’s connection options, as ?cert=PATH&key=PATH&ca=PATH&token-file=PATH (Security::from_options).

pub fn next_call_json(&mut self) -> Result<Option<String>>

pub fn server(addr: &str) -> Result<Self>

May wait for the previous worker to relinquish its lease.

pub fn replica(id: u8, peers: Vec<String>, dir: PathBuf) -> Result<Self>

Every peer runs the protocol while its SDK waits to become primary.

pub fn set_notify(&self, notify: Notify)

pub fn check(&self) -> Result<()>

pub fn next_call(&mut self) -> Option<RelayedCall>

pub fn invocation_state(&self, awaiting: &[String]) -> Option<&'static str>

An invoked worker (crate::invoke): running, idle, expired or lost (see crate::invoke::Progress); None for any other connection. awaiting: workflow types the host has runs of and no code for. Poll every few milliseconds; once it is not running, close the engine and drop this connection, which reports to the server and leaves.

pub fn reply(&self, relay: u64, payload: Vec<u8>) -> Result<()>

Trait Implementations

impl Drop for ForeignConnection

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.