p2p

Dec 13, 2018

Changes in this version

+ var LoggerHandler = HandlerFunc(func(envelope *Envelope) { ... })

+ var StringLoggerHandler = HandlerFunc(func(envelope *Envelope) { ... })

+ func DecodeHex(hexString string) (data []byte)

+ func EnableP2PLogging()

+ func SyncLogger()

+ type Catchup struct

+ IsCatchingUp bool

+ type Client struct

+ func NewClient(peer *Peer, catchup bool) *Client

+ func (c *Client) CloseConnection() error

+ func (c *Client) RegisterHandler(handler Handler)

+ func (c *Client) SetReadTimeout(readTimeout time.Duration)

+ func (c *Client) Start() error

+ type Envelope struct

+ Packet *eos.Packet

+ Receiver *Peer

+ Sender *Peer

+ func NewEnvelope(sender *Peer, receiver *Peer, packet *eos.Packet) *Envelope

+ type Handler interface

+ Handle func(envelope *Envelope)

+ type HandlerFunc func(envelope *Envelope)

+ func (f HandlerFunc) Handle(envelope *Envelope)

+ type HandshakeInfo struct

+ ChainID eos.Checksum256

+ HeadBlockID eos.Checksum256

+ HeadBlockNum uint32

+ HeadBlockTime time.Time

+ LastIrreversibleBlockID eos.Checksum256

+ LastIrreversibleBlockNum uint32

+ func (h *HandshakeInfo) String() string

+ func (h HandshakeInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type Peer struct

+ Address string

+ Name string

+ NodeID []byte

+ func NewIncommingPeer(address string, agent string) *Peer

+ func NewOutgoingPeer(address string, agent string, handshakeInfo *HandshakeInfo) *Peer

+ func (p *Peer) Connect(errChan chan error) (ready chan bool)

+ func (p *Peer) Read() (*eos.Packet, error)

+ func (p *Peer) SendHandshake(info *HandshakeInfo) (err error)

+ func (p *Peer) SendNotice(headBlockNum uint32, libNum uint32, mode byte) (err error)

+ func (p *Peer) SendRequest(startBlockNum uint32, endBlockNumber uint32) (err error)

+ func (p *Peer) SendSyncRequest(startBlockNum uint32, endBlockNumber uint32) (err error)

+ func (p *Peer) SendTime() (err error)

+ func (p *Peer) SetConnection(conn net.Conn)

+ func (p *Peer) SetConnectionTimeout(timeout time.Duration)

+ func (p *Peer) SetHandshakeTimeout(timeout time.Duration)

+ func (p *Peer) Write(bytes []byte) (int, error)

+ func (p *Peer) WriteP2PMessage(message eos.P2PMessage) (err error)

+ func (p Peer) MarshalLogObject(enc zapcore.ObjectEncoder) error

+ type Proxy struct

+ Peer1 *Peer

+ Peer2 *Peer

+ func NewProxy(peer1 *Peer, peer2 *Peer) *Proxy

+ func (p *Proxy) ConnectAndStart() error

+ func (p *Proxy) RegisterHandler(handler Handler)

+ func (p *Proxy) RegisterHandlers(handlers []Handler)

+ func (p *Proxy) Start() error

+ type Relay struct

+ func NewRelay(listeningAddress string, destinationPeerAddress string) *Relay

+ func (r *Relay) RegisterHandler(handler Handler)

+ func (r *Relay) Start() error