Struct DkgRunner

pub struct DkgRunner<T> {
    peers: Vec<PeerId>,
    our_id: PeerId,
    dkg_config: HashMap<T, usize>,
}

Fields

peers: Vec<PeerId>

our_id: PeerId

dkg_config: HashMap<T, usize>

Implementations

impl<T> DkgRunner<T>

where T: Serialize + DeserializeOwned + Unpin + Send + Clone + Eq + Hash,

Helper for running multiple DKGs over the same peer connections

Messages are (T, DkgMessage) for creating a DKG for every T

pub fn multi( keys: Vec<T>, threshold: usize, our_id: &PeerId, peers: &[PeerId], ) -> Self

Create multiple DKGs with the same threshold signatures required

pub fn new(key: T, threshold: usize, our_id: &PeerId, peers: &[PeerId]) -> Self

Create a single DKG with threshold signatures required

pub fn add(&mut self, key: T, threshold: usize)

Create another DKG with threshold signatures required

pub async fn run_g2( &mut self, module_id: ModuleInstanceId, connections: &MuxPeerConnections<(ModuleInstanceId, String), DkgPeerMsg>, ) -> DkgResult<HashMap<T, DkgKeys<G2Projective>>>

Create keys from G2 (96B keys, 48B messages) used in tbs

pub async fn run_g1( &mut self, module_id: ModuleInstanceId, connections: &MuxPeerConnections<(ModuleInstanceId, String), DkgPeerMsg>, ) -> DkgResult<HashMap<T, DkgKeys<G1Projective>>>

Create keys from G1 (48B keys, 96B messages) used in threshold_crypto

pub async fn run<G: DkgGroup>( &mut self, module_id: ModuleInstanceId, group: G, connections: &MuxPeerConnections<(ModuleInstanceId, String), DkgPeerMsg>, ) -> DkgResult<HashMap<T, DkgKeys<G>>>

where DkgMessage<G>: ISupportedDkgMessage,

Runs the DKG algorithms with our peers

WARNING: Currently we do not handle any unexpected messages, all peers are expected to be cooperative

async fn run_dkg_key<G: DkgGroup>( key_id: (ModuleInstanceId, String), connections: MuxPeerConnections<(ModuleInstanceId, String), DkgPeerMsg>, dkg: Dkg<G>, initial_step: DkgStep<G>, ) -> DkgResult<DkgKeys<G>>

where DkgMessage<G>: ISupportedDkgMessage,

Runs the DKG algorithms for a given key and module id