Documentation ¶
Index ¶
- Constants
- type Peer
- func (p Peer) Address() string
- 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) Url() string
Constants ¶
View Source
const (
// MaxMsgCountPerWave is the max number of msg per wave
MaxMsgCountPerWave = 2
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Peer ¶
type Peer struct { IP string `json:"ip"` Port uint64 `json:"port"` NodeKey string `json:"nodeKey"` UserID common.Hash `json:"userID"` Verified bool `json:"verified"` Conn *websocket.Conn }
Peer contain the info of websocket connection
func (*Peer) SendQuestion ¶
SendQuestion is used to send question to peer
Click to show internal directories.
Click to hide internal directories.