Versions in this module Expand all Collapse all v0 v0.2.0 May 19, 2022 v0.1.2 May 19, 2022 Changes in this version + func Contains(s []*btss.PartyID, e *btss.PartyID) bool + func GetMsgRound(msg []byte, partyID *btss.PartyID, isBroadcast bool) (blame.RoundInfo, error) + func InitLog(level string, pretty bool, serviceValue string) + func MsgToHashInt(msg []byte) (*big.Int, error) + func MsgToHashString(msg []byte) (string, error) + type BulkWireMsg struct + MsgIdentifier string + Routing *btss.MessageRouting + WiredBulkMsgs []byte + func NewBulkWireMsg(msg []byte, id string, r *btss.MessageRouting) BulkWireMsg + type LocalCacheItem struct + ConfirmedList map[string]string + Hash string + Msg *messages.WireMessage + func NewLocalCacheItem(msg *messages.WireMessage, hash string) *LocalCacheItem + func (l *LocalCacheItem) GetPeers() []string + func (l *LocalCacheItem) TotalConfirmParty() int + func (l *LocalCacheItem) UpdateConfirmList(P2PID, hash string) + type PartyInfo struct + PartyIDMap map[string]*btss.PartyID + PartyMap *sync.Map + type Status byte + const Fail + const NA + const Success + type TssCommon struct + P2PPeers []peer.ID + P2PPeersLock *sync.RWMutex + PartyIDtoP2PID map[string]peer.ID + TssMsg chan *p2p.Message + func NewTssCommon(peerID string, broadcastChannel chan *messages.BroadcastMsgChan, ...) *TssCommon + func (t *TssCommon) GetBlameMgr() *blame.Manager + func (t *TssCommon) GetConf() TssConfig + func (t *TssCommon) GetLocalPeerID() string + func (t *TssCommon) GetTaskDone() chan struct{} + func (t *TssCommon) NotifyTaskDone() error + func (t *TssCommon) ProcessInboundMessages(finishChan chan struct{}, wg *sync.WaitGroup) + func (t *TssCommon) ProcessOneMessage(wrappedMsg *messages.WrappedMessage, peerID string) error + func (t *TssCommon) ProcessOutCh(msg btss.Message, msgType messages.THORChainTSSMessageType) error + func (t *TssCommon) SetLocalPeerID(peerID string) + func (t *TssCommon) SetPartyInfo(partyInfo *PartyInfo) + func (t *TssCommon) TryGetAllLocalCached() []*LocalCacheItem + func (t *TssCommon) TryGetLocalCacheItem(key string) *LocalCacheItem + type TssConfig struct + EnableMonitor bool + KeyGenTimeout time.Duration + KeySignTimeout time.Duration + PartyTimeout time.Duration + PreParamTimeout time.Duration
Go to main page