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.