core

type Heartbeat struct {
	Delay  float64 `json:"delay"`
	Health uint8   `json:"health"`
	// contains filtered or unexported fields
}

type Peer struct {
	Guid      []byte     `json:"guid"`
	Node      *dht.Node  `json:"node"`
	Heartbeat *Heartbeat `json:"heartbeat"`
	// contains filtered or unexported fields
}

type PeerManager struct {
	// contains filtered or unexported fields
}

type Protocol struct {
	Header     global.MessageType
	PeerID     []byte
	ProtocolID int64
	Payload    []byte
	RemoteAddr net.Addr
}

type ProtocolHandler struct {
	Type   global.MessageType
	Runner ProtocolRunner
}

type ProtocolManager struct {
	// contains filtered or unexported fields
}

type ProtocolRunner func(t *dht.Transport, msg *Protocol) error