Documentation
¶
Index ¶
- func ComputeReliability(interactions []float64) float64
- func SharePeerDataUpdate(data *PeerData)
- func ShareReport(data *ReportStruct)
- type Peer
- type PeerData
- type PeerStore
- func (ps *PeerStore) ActivatePeer(peerId string) (peerData *PeerData, isNew bool)
- func (ps *PeerStore) CreateNewPeer(peerId string) *PeerData
- func (ps *PeerStore) DeactivatePeer(peerId string)
- func (ps *PeerStore) IsActivePeer(peerId string) *PeerData
- func (ps *PeerStore) IsKnown(peerId string) *PeerData
- func (ps *PeerStore) ReadFromFile(privateKey crypto.PrivKey)
- func (ps *PeerStore) SaveToFile(key crypto.PrivKey) error
- type PeerUpdateStruct
- type ReportMessage
- type ReportStruct
- type UpdateMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ComputeReliability ¶
func SharePeerDataUpdate ¶
func SharePeerDataUpdate(data *PeerData)
func ShareReport ¶
func ShareReport(data *ReportStruct)
Types ¶
type Peer ¶
type Peer struct {
// contains filtered or unexported fields
}
func (*Peer) PeerShutdown ¶
func (p *Peer) PeerShutdown()
func (*Peer) SendMessageToPeerId ¶
send a string message to a peer identified by peerId (or to all peers) If the given peerid doesn't exist, doesn't reply etc, it is skipped message: the string to send peerid: the peerid of the peer. Or * to broadcast to multiple peers
type PeerData ¶
type PeerData struct {
PeerID string
LastUsedIP string
Version string
Reliability float64
LastInteraction time.Time
LastGoodPing time.Time
LastMultiAddress string
BasicInteractions []float64
BasicInteractionTimes []time.Time
}
func (*PeerData) AddBasicInteraction ¶
func (*PeerData) CanHePingMe ¶
func (*PeerData) SetMultiaddr ¶
func (*PeerData) SetVersion ¶
func (*PeerData) ShouldIDeactivatePeer ¶
func (*PeerData) ShouldIPingPeer ¶
type PeerStore ¶
type PeerStore struct {
Store peerstore.Peerstore
SaveFile string
AllPeers map[string]*PeerData
ActivePeers map[string]*PeerData
}
func (*PeerStore) ActivatePeer ¶
func (*PeerStore) CreateNewPeer ¶
func (*PeerStore) DeactivatePeer ¶
func (*PeerStore) IsActivePeer ¶
func (*PeerStore) ReadFromFile ¶
type PeerUpdateStruct ¶
type ReportMessage ¶
type ReportMessage struct {
MessageType string `json:"message_type"`
MessageContents ReportStruct `json:"message_contents"`
}
type ReportStruct ¶
type UpdateMessage ¶
type UpdateMessage struct {
MessageType string `json:"message_type"`
MessageContents PeerUpdateStruct `json:"message_contents"`
}
Click to show internal directories.
Click to hide internal directories.