Versions in this module Expand all Collapse all v0 v0.1.0 Sep 2, 2021 Changes in this version + const MaxMsgCountPerWave + type Peer struct + Conn *websocket.Conn + IP string + NodeKey string + Port uint64 + UserID common.Hash + Verified bool + func New(ip string, port uint64, nodeKey string) (*Peer, error) + func (p *Peer) Close() error + func (p *Peer) Connected() bool + func (p *Peer) Dial() error + func (p *Peer) ID() common.Hash + func (p *Peer) SendErr(waveID common.Hash, err error) error + func (p *Peer) SendMsg(waveID common.Hash, msg *core.Message) error + func (p *Peer) SendMsgs(waveID common.Hash, msgs []*core.Message) error + func (p *Peer) SendPeers(waveID common.Hash, pm map[common.Hash]*Peer, localPeer *Peer) error + func (p *Peer) SendPing(waveID common.Hash) error + func (p *Peer) SendPong(waveID common.Hash) error + func (p *Peer) SendQuestion(waveID common.Hash, cmd string, args ...interface{}) error + func (p *Peer) SendRoots(waveID common.Hash, user0, user1 *core.User) error + func (p *Peer) SetUserID(userID common.Hash) + func (p *Peer) SetVerified() + func (p Peer) Address() string + func (p Peer) Url() string