Versions in this module Expand all Collapse all v0 v0.1.1 Mar 3, 2022 v0.1.0 Mar 3, 2022 Changes in this version + type Error struct + Culprits []party.ID + Err error + func (e Error) Error() string + func (e Error) Unwrap() error + type Handler interface + Accept func(msg *Message) + CanAccept func(msg *Message) bool + Listen func() <-chan *Message + Result func() (interface{}, error) + Stop func() + type Message struct + Broadcast bool + BroadcastVerification []byte + Data []byte + From party.ID + Protocol string + RoundNumber round.Number + SSID []byte + To party.ID + func (m *Message) Hash() []byte + func (m *Message) MarshalBinary() ([]byte, error) + func (m *Message) UnmarshalBinary(data []byte) error + func (m Message) IsFor(id party.ID) bool + func (m Message) String() string + type MultiHandler struct + func NewMultiHandler(create StartFunc, sessionID []byte) (*MultiHandler, error) + func (h *MultiHandler) Accept(msg *Message) + func (h *MultiHandler) CanAccept(msg *Message) bool + func (h *MultiHandler) Listen() <-chan *Message + func (h *MultiHandler) Result() (interface{}, error) + func (h *MultiHandler) Stop() + func (h *MultiHandler) String() string + type StartFunc func(sessionID []byte) (round.Session, error) + type TwoPartyHandler struct + func NewTwoPartyHandler(create StartFunc, sessionID []byte, leader bool) (*TwoPartyHandler, error) + func (h *TwoPartyHandler) Accept(msg *Message) + func (h *TwoPartyHandler) CanAccept(msg *Message) bool + func (h *TwoPartyHandler) Listen() <-chan *Message + func (h *TwoPartyHandler) Result() (interface{}, error) + func (h *TwoPartyHandler) Stop() + func (h *TwoPartyHandler) String() string
Go to main page