v030

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 4, 2019 License: MIT Imports: 12 Imported by: 4

Documentation

Overview

Package v030 is a collection of classes for p2p version 0.3.0 It contains IO, handshake, handlers, etc.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type V030Handshaker

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

V030Handshaker exchange status data over protocol version .0.3.0

func NewV030StateHS

func NewV030StateHS(pm p2pcommon.PeerManager, actorServ p2pcommon.ActorService, log *log.Logger, chainID *types.ChainID, peerID types.PeerID, rd io.Reader, wr io.Writer) *V030Handshaker

func (*V030Handshaker) DoForInbound

func (h *V030Handshaker) DoForInbound(ctx context.Context) (*types.Status, error)

onConnect is handle handshake from inbound peer

func (*V030Handshaker) DoForOutbound

func (h *V030Handshaker) DoForOutbound(ctx context.Context) (*types.Status, error)

handshakeOutboundPeer start handshake with outbound peer

func (*V030Handshaker) GetMsgRW

func (h *V030Handshaker) GetMsgRW() p2pcommon.MsgReadWriter

type V030ReadWriter

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

func NewV030ReadWriter

func NewV030ReadWriter(r *bufio.Reader, w *bufio.Writer) *V030ReadWriter

func (*V030ReadWriter) ReadMsg

func (rw *V030ReadWriter) ReadMsg() (p2pcommon.Message, error)

func (*V030ReadWriter) WriteMsg

func (rw *V030ReadWriter) WriteMsg(msg p2pcommon.Message) error

type V030Reader

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

func NewV030Reader

func NewV030Reader(rd *bufio.Reader) *V030Reader

func (*V030Reader) ReadMsg

func (r *V030Reader) ReadMsg() (p2pcommon.Message, error)

ReadMsg() must be used in single thread

type V030Writer

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

func NewV030Writer

func NewV030Writer(wr *bufio.Writer) *V030Writer

func (*V030Writer) WriteMsg

func (w *V030Writer) WriteMsg(msg p2pcommon.Message) error

WriteMsg() must be used in single thread

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL