Struct OffChainCoordinatorClient 

pub struct OffChainCoordinatorClient<F, S>
where
    F: FftField,
    S: ShareBound<F>,
{ /* private fields */ }

Implementations

impl<F, S> OffChainCoordinatorClient<F, S>

where F: FftField, S: ShareBound<F>,

pub async fn start_rpc_client_from_cert( addr: &str, port: u16, t: u64, n_parties: u64, n_outputs: u64, client_cert: Arc<CertifiedKey<KeyPair>>, ) -> Result<OffChainCoordinatorClient<F, S>, CoordinatorError>

pub async fn start_rpc_client( addr: &str, port: u16, t: u64, n_parties: u64, n_outputs: u64, cert_der: Vec<u8>, key_der: Vec<u8>, ) -> Result<OffChainCoordinatorClient<F, S>, CoordinatorError>

pub async fn start_rpc_client_with_parties( addr: &str, port: u16, t: u64, n_parties: u64, n_outputs: u64, cert_der: Vec<u8>, key_der: Vec<u8>, ) -> Result<OffChainCoordinatorClient<F, S>, CoordinatorError>

pub async fn trigger_round(&self, round: Round) -> Result<(), CoordinatorError>

Trait Implementations

impl<F, S> Coordinator<F, S> for OffChainCoordinatorClient<F, S>

where F: FftField, S: ShareBound<F>,

type ClientIdentity = Vec<u8>

async fn start_preprocessing(&self) -> Result<(), CoordinatorError>

async fn reserve_input_masks(&self) -> Result<(), CoordinatorError>

async fn collect_inputs(&self) -> Result<(), CoordinatorError>

async fn start_mpc(&self) -> Result<(), CoordinatorError>

async fn send_output(&self) -> Result<(), CoordinatorError>

async fn finalize(&self) -> Result<(), CoordinatorError>

async fn reset_coord(&self) -> Result<(), CoordinatorError>

async fn wait_for_indices( &self, n_inputs: u64, ) -> Result<HashMap<Vec<u8>, Vec<u64>>, CoordinatorError>

async fn wait_for_inputs( &self, n_inputs: u64, mask_shares: Vec<S>, ) -> Result<HashMap<Vec<u8>, Vec<S>>, CoordinatorError>

async fn wait_for_round(&self, round: Round) -> Result<(), CoordinatorError>

async fn send_masked_input( &self, masked_input: <S as ShareBound<F>>::ValueType, i: u64, ) -> Result<(), CoordinatorError>

async fn reserve_mask_index(&mut self, i: u64) -> Result<(), CoordinatorError>

async fn obtain_outputs( &self, ) -> Result<Vec<<S as ShareBound<F>>::ValueType>, CoordinatorError>

async fn send_output_shares( &self, client_id: <OffChainCoordinatorClient<F, S> as Coordinator<F, S>>::ClientIdentity, key: Vec<u8>, output_shares: Vec<S>, ) -> Result<(), CoordinatorError>