protocols

Documentation

Index

• Constants
• type Error
  • func (e Error) Error() (message string)
• type Peer
  • func NewPeer(p *p2p.Peer, rw p2p.MsgReadWriter, spec *Spec) *Peer
  • func (p *Peer) Drop(err error)
  • func (p *Peer) Handshake(ctx context.Context, hs interface{}, verify func(interface{}) error) (rhs interface{}, err error)
  • func (p *Peer) Run(handler func(msg interface{}) error) error
  • func (p *Peer) Send(msg interface{}) error
• type Spec
  • func (s *Spec) GetCode(msg interface{}) (uint64, bool)
  • func (s *Spec) Length() uint64
  • func (s *Spec) NewMsg(code uint64) (interface{}, bool)

Constants

const (
	ErrMsgTooLong = iota
	ErrDecode
	ErrWrite
	ErrInvalidMsgCode
	ErrInvalidMsgType
	ErrHandshake
	ErrNoHandler
	ErrHandler
)

Types

type Error

type Error struct {
	Code int
	// contains filtered or unexported fields
}

func (Error) Error

func (e Error) Error() (message string)

type Peer

type Peer struct {
	*p2p.Peer
	// contains filtered or unexported fields
}

func NewPeer

func NewPeer(p *p2p.Peer, rw p2p.MsgReadWriter, spec *Spec) *Peer

func (*Peer) Drop

func (p *Peer) Drop(err error)

func (*Peer) Handshake

func (p *Peer) Handshake(ctx context.Context, hs interface{}, verify func(interface{}) error) (rhs interface{}, err error)

func (*Peer) Run

func (p *Peer) Run(handler func(msg interface{}) error) error

func (*Peer) Send

func (p *Peer) Send(msg interface{}) error

type Spec

type Spec struct {
	Name string

	Version uint

	MaxMsgSize uint32

	Messages []interface{}
	// contains filtered or unexported fields
}

func (*Spec) GetCode

func (s *Spec) GetCode(msg interface{}) (uint64, bool)

func (*Spec) Length

func (s *Spec) Length() uint64

func (*Spec) NewMsg

func (s *Spec) NewMsg(code uint64) (interface{}, bool)