p2p

type Config struct {
	PrivateKey     *ecdsa.PrivateKey
	MaxPeers       int `mapstructure:"p2p-maxpeers"`
	MaxAcceptConns int
	Name           string
	NetworkID      uint64
	BootNodeStrs   []string `mapstructure:"�p2p-bootnodes"`
	BootNodes      []*discover.Node
	ListenAddr     string `mapstructure:"p2p-listenaddr"`
	Protocols      []*Protocol
	NodeDatabase   string `mapstructure:"p2p-nodes"`
}

type Dialer interface {
	Dial(*discover.Node) (net.Conn, error)
}

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

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

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

type Message struct {
	Code    uint64
	Payload []byte

	ReceivedAt time.Time
}

type MsgReadWriter interface {
	MsgReader
	MsgWriter
}

type MsgReader interface {
	ReadMsg() (*Message, error)
}

type MsgWriter interface {
	WriteMsg(*Message) error
}

type NodeInfo struct {
	ID    string `json:"id"`
	Name  string `json:"name"`
	Enode string `json:"enode"`
	IP    string `json:"ip"`
	Ports struct {
		Discovery int `json:"discovery"`
		Listener  int `json:"listener"`
	} `json:"ports"`
	ListenAddr string                 `json:"listenAddr"`
	Protocols  map[string]interface{} `json:"protocols"`
}

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

type PeerInfo struct {
	ID      string   `json:"id"`
	Name    string   `json:"name"`
	Caps    []string `json:"caps"`
	Network struct {
		LocalAddress  string `json:"localAddress"`
		RemoteAddress string `json:"remoteAddress"`
	} `json:"network"`
	Protocols map[string]interface{} `json:"protocols"`
}

type ProtoHandshake struct {
	Version    uint64
	Name       string
	Protocols  []*ProtocolKey
	ListenPort uint64
	ID         discover.NodeID
}

type Protocol struct {
	Name string

	Version uint

	Offset uint64

	Size uint64

	Run func(peer *Peer, rw MsgReadWriter) error

	NodeInfo func() interface{}

	PeerInfo func(id discover.NodeID) interface{}
}

type ProtocolKey struct {
	Name    string
	Version uint
}

type ProtocolKeys []*ProtocolKey

type QuitReason uint

type Server struct {
	Config
	sync.RWMutex
	// contains filtered or unexported fields
}

type TCPDialer struct {
	*net.Dialer
}

type Task interface {
	Do(*Server) error
}