p2p

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

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

type HandshakeConfig struct {
	Magic           uint32
	ProtocolVersion uint32
	Peer            Peer
	Signer          crypto.Signer
}

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

type Peer interface {
	Direction() PeerDirection
	LocalAddr() string
	RemoteIP() string
	RemoteAddr() string
	RemotePort() int
	SendCtx(ctx context.Context, envelope *wire.Envelope) error
	Send(envelope *wire.Envelope) error
	ReceiveCtx(ctx context.Context) (*wire.Envelope, error)
	Receive() (*wire.Envelope, error)
	CloseChan() <-chan struct{}
	Close() error
	BandwidthUsage() (uint64, uint64)
	CloseReason() error
}

type PeerDialer interface {
	DialPeer(id crypto.Hash, ip string, verify bool) error
}

type PeerDirection int

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

type PeerManager interface {
	service.Service
	PeerDialer
	AcceptPeer(conn *net.TCPConn) error
}

type PeerManagerOpts struct {
	Mux         *PeerMuxer
	DB          *leveldb.DB
	SeedPeers   []SeedPeer
	Signer      crypto.Signer
	ListenHost  string
	MaxInbound  int
	MaxOutbound int
}

type PeerMessageHandler func(peerID crypto.Hash, envelope *wire.Envelope)

type PeerMeta struct {
	ID        crypto.Hash
	IP        string
	Port      int
	SentBytes int64
	RecvBytes int64
}

type PeerMuxer struct {
	GossipTimeoutMS int
	// contains filtered or unexported fields
}

type PeerStateHandler func(peerID crypto.Hash)

type SeedPeer struct {
	ID crypto.Hash
	IP string
}